SyncManager.cpp 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371
  1. #include "stdafx.h"
  2. #include"SyncManager.h"
  3. #include <deque>
  4. #include <Eigen/Dense>
  5. #include <fstream>
  6. #include <iostream>
  7. #include <direct.h>
  8. #include <io.h>
  9. #include "../ProcessRemodule.h"
  10. #include "../log_process_module.h"
  11. #include "./../system_basic_info/SystemAnalysis.h"
  12. #pragma warning(disable: 4244)
  13. HostServer::SyncManager::SyncManager()
  14. {
  15. init();
  16. }
  17. void HostServer::SyncManager::init()
  18. {
  19. InitializeCriticalSectionAndSpinCount(&m_csSyncTime, 4000);
  20. //InitializeCriticalSection(&m_csCalcLiner);
  21. _anchors.swap(unordered_map<unsigned long long, Position>());
  22. //_syncTimeMsgs.clear();
  23. //_historySync.clear();
  24. _distance.swap(unordered_map<unsigned long long,unordered_map<unsigned long long, double>>());
  25. logDir = ".\\synclog\\";
  26. if(0 != _access(logDir.c_str(), 0)){
  27. _mkdir(logDir.c_str());
  28. }
  29. isOutputLog = false;
  30. }
  31. void HostServer::SyncManager::analyzeSyncMsg(SyncTimeMsg &msg)
  32. {
  33. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_10);
  34. EnterCriticalSection(&m_csSyncTime);
  35. int idx = FindSyncTimeMsg(msg.RootIdCode(), msg.SyncNum());
  36. if( -1 == idx){ // 没找到
  37. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_72);
  38. // 如果时间同步消息的版本数量超过最大限制,则删除最早添加的消息
  39. if(_syncTimeMsgs[msg.RootIdCode()].size() >= MAX_SYNCTIME_NUM){ // 删除第一个
  40. // 可能有泄露
  41. _syncTimeMsgs[msg.RootIdCode()].pop_front();
  42. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_12);
  43. }
  44. SyncTimeMsgItem it;
  45. it.SyncNum = msg.SyncNum();
  46. it.SyncTimeMsgs[msg.LocalIdCode()] = msg;
  47. _syncTimeMsgs[msg.RootIdCode()].push_back(it);
  48. idx = _syncTimeMsgs[msg.RootIdCode()].size() - 1;
  49. }else{
  50. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_73);
  51. _syncTimeMsgs[msg.RootIdCode()][idx].SyncTimeMsgs[msg.LocalIdCode()] = msg;
  52. }
  53. //
  54. while(_historySync[msg.RootIdCode()].size() > MAX_SYNCTIME_NUM){
  55. _historySync[msg.RootIdCode()].pop_front();
  56. }
  57. // 更新时间同步并计算
  58. for(auto it :_syncTimeMsgs[msg.RootIdCode()][idx].SyncTimeMsgs)
  59. {
  60. updateSync(msg.RootIdCode(), idx, msg.SyncNum(), it.first);
  61. }
  62. LeaveCriticalSection(&m_csSyncTime);
  63. }
  64. bool HostServer::SyncManager::updateSync(unsigned long long rootIdCode, int idx, unsigned short SyncNum, unsigned long long localIdCode)
  65. {
  66. if(-1 == idx){
  67. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_74);
  68. return false;
  69. }
  70. // 如果当前版本的时间同步消息未收到则返回false
  71. unordered_map<unsigned long long, SyncTimeMsg>::iterator itSyncTime = _syncTimeMsgs[rootIdCode][idx].SyncTimeMsgs.find(localIdCode);
  72. if(itSyncTime == _syncTimeMsgs[rootIdCode][idx].SyncTimeMsgs.end()){
  73. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_75);
  74. return false;
  75. }
  76. SyncTimeMsg &msg = _syncTimeMsgs[rootIdCode][idx].SyncTimeMsgs[localIdCode];
  77. // 如果当前的为root,则返回true
  78. if(msg.SyncLevel() == 0){
  79. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_76);
  80. return true;
  81. }
  82. int idx_synctime = FindHisSyncTime(rootIdCode, SyncNum);
  83. // 如果时间同步已经计算过,则返回true
  84. if(-1 != idx_synctime){
  85. unordered_map<unsigned long long, SyncTime>::iterator itHistSync = _historySync[rootIdCode][idx_synctime].HistSync.find(localIdCode);
  86. if(itHistSync != _historySync[rootIdCode][idx_synctime].HistSync.end()){
  87. if(itHistSync->second.TimeDelay())
  88. return true;
  89. }
  90. }
  91. // 如果已经收到了上一级的同步消息
  92. if(_syncTimeMsgs[rootIdCode][idx].SyncTimeMsgs.count(msg.UpperIdCode())){
  93. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_77);
  94. if(!updateSync(rootIdCode, idx, SyncNum, msg.UpperIdCode())){
  95. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_78);
  96. return false;
  97. }
  98. SyncTimeMsg &upperMsg = _syncTimeMsgs[rootIdCode][idx].SyncTimeMsgs[msg.UpperIdCode()];
  99. SyncTime* s = NULL;
  100. for(auto it(_historySync[rootIdCode].rbegin()); it != _historySync[rootIdCode].rend(); ++it)
  101. {
  102. if(it->SyncNum != msg.SyncNum() && it->HistSync.count(localIdCode))
  103. {
  104. s = &(it->HistSync.find(localIdCode)->second);
  105. break;
  106. }
  107. }
  108. idx_synctime = FindHisSyncTime(rootIdCode, SyncNum);
  109. if(-1 == idx_synctime){
  110. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_79);
  111. SyncTimeItem it;
  112. it.SyncNum = msg.SyncNum();
  113. it.HistSync[localIdCode] = SyncTime(msg, upperMsg, s);
  114. _historySync[rootIdCode].push_back(it);
  115. idx_synctime = _historySync[rootIdCode].size() - 1;
  116. }else{
  117. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_80);
  118. _historySync[rootIdCode][idx_synctime].HistSync[localIdCode] = SyncTime(msg, upperMsg, s);
  119. }
  120. // 计算时间同步
  121. long long upperTimeDelay = 0;
  122. if(_syncTimeMsgs[rootIdCode][idx].SyncTimeMsgs[msg.UpperIdCode()].SyncLevel() != 0)
  123. {
  124. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_81);
  125. upperTimeDelay = _historySync[rootIdCode][idx_synctime].HistSync[msg.UpperIdCode()].TimeDelay();
  126. }
  127. long long sendTime = _historySync[rootIdCode][idx_synctime].HistSync[localIdCode].SendTime();
  128. long long receiveTime = _historySync[rootIdCode][idx_synctime].HistSync[localIdCode].ReceiveTime();
  129. long long timeDelay = receiveTime - sendTime - _distance[localIdCode][msg.UpperIdCode()];
  130. timeDelay += upperTimeDelay;
  131. // 从不同的Upper来的同步数据,跨周期判断可能不正确,将时间差控制在一个周期内
  132. while(timeDelay > TIME_MAX){
  133. timeDelay -= TIME_MAX;
  134. }
  135. while(timeDelay + TIME_MAX < 0 ){
  136. timeDelay += TIME_MAX;
  137. }
  138. _historySync[rootIdCode][idx_synctime].HistSync[localIdCode].TimeDelay(timeDelay);
  139. //debug_print_syslog(0, "Delay info, syncnum:%d, station id: 0x%x, timeDelay:%I64u",
  140. // SyncNum, localIdCode, timeDelay);
  141. if(isOutputLog){
  142. char filename[100];
  143. char temp[200];
  144. long long aa = timeDelay;
  145. if(aa < 0){
  146. aa += TIME_MAX;
  147. }
  148. int bb = (receiveTime > TIME_MAX) ? 1 : 0;
  149. int cc = (sendTime > TIME_MAX) ? 1 : 0;
  150. int dd = msg.UpperIdCode() >> 8;
  151. sprintf_s(filename, "%s\\%d.log", logDir.c_str(), localIdCode>>8);
  152. ofstream outfile(filename, ofstream::app);
  153. //sprintf(temp, "%d, %d, %I64d, %I64d\r", SyncNum, dd, receiveTime, timeDelay );
  154. sprintf_s(temp, "sn:%d, up:%d, rec:%I64d, snd:%I64d, del:%I64d, crt:%I64d, r_crs:%d, s_crs:%d\r", SyncNum, dd, receiveTime, sendTime, timeDelay, aa, bb, cc);
  155. outfile << temp;
  156. }
  157. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_69);
  158. return true;
  159. }else{
  160. LOCATION_SYSTEM_BRANCH(LOCATION_SYSTEM_BRANCH_110);
  161. }
  162. return false;
  163. }
  164. unsigned long long HostServer::SyncManager::calTimeByLinar(TagMsg &tag)
  165. {
  166. //EnterCriticalSection(&m_csCalcLiner);
  167. EnterCriticalSection(&m_csSyncTime);
  168. // 获取历史记录中与此tag最近的两条
  169. deque<SyncTime> hisSync;
  170. //ofstream fout("test/linar_513.txt",ios::app);
  171. unsigned long long rootIdCode = tag.SyncRootIdCode;
  172. int i = 0;
  173. int idx = FindSyncTimeMsg(rootIdCode, tag.SyncNum);
  174. if(-1 != idx){
  175. unordered_map<unsigned long long, SyncTimeMsg>::iterator it = _syncTimeMsgs[rootIdCode][idx].SyncTimeMsgs.find(tag.StationIdCode);
  176. if(it != _syncTimeMsgs[rootIdCode][idx].SyncTimeMsgs.end()){
  177. if(it->second.SyncLevel() == 0){
  178. //LeaveCriticalSection(&m_csCalcLiner);
  179. LeaveCriticalSection(&m_csSyncTime);
  180. return tag.ReceiveTime;
  181. }
  182. }
  183. }
  184. int idx_sync = -1;
  185. while(hisSync.size() < 2 && i < MAX_CALCLINER_NUM)
  186. {
  187. auto syncNum = tag.SyncNum - i;
  188. idx_sync = FindHisSyncTime(rootIdCode, syncNum);
  189. if(-1 != idx_sync){
  190. if(_historySync[rootIdCode][idx_sync].HistSync.count(tag.StationIdCode)){
  191. hisSync.push_front(_historySync[rootIdCode][idx_sync].HistSync[tag.StationIdCode]);
  192. }
  193. }
  194. i++;
  195. }
  196. // 如果满足条件的历史记录不足两个则返回
  197. if(hisSync.size() < 2){
  198. //LeaveCriticalSection(&m_csCalcLiner);
  199. LeaveCriticalSection(&m_csSyncTime);
  200. return LLONG_MAX;
  201. }
  202. // 计算预估值
  203. long long y1(hisSync.at(0).ReceiveTime() - hisSync.at(0).TimeDelay()),y2(hisSync.at(1).ReceiveTime() - hisSync.at(1).TimeDelay());
  204. long long x1(hisSync.at(0).RealReceiveTime()), x2(hisSync.at(1).RealReceiveTime()), x3(tag.ReceiveTime);
  205. LeaveCriticalSection(&m_csSyncTime);
  206. unsigned long long res;
  207. if(x1 > x2)
  208. {
  209. x2 += TIME_MAX;
  210. }
  211. if(x2 > x3)
  212. {
  213. x3 += TIME_MAX;
  214. }
  215. if(y1 < 0){ // 理论y值不能小于0
  216. y1 += TIME_MAX;
  217. }
  218. if(y2 < 0 ){
  219. y2 += TIME_MAX;
  220. }
  221. if(y1 > y2){
  222. y2 += TIME_MAX;
  223. }else if(y2-y1 > TIME_MAX){
  224. y2 -=TIME_MAX;
  225. }
  226. // y1 = k*x1 + b;
  227. // y2 = k*x2 + b;
  228. // k = (x1-x2)/(y1-y2);
  229. // b = y1 - k*x1;
  230. Eigen::Matrix3d a;
  231. a << x1 ,1 , 0,
  232. x2 ,1 , 0,
  233. x3, 1, -1;
  234. Eigen::Vector3d b(y1, y2, 0);
  235. Eigen::Vector3d X = a.colPivHouseholderQr().solve(b);
  236. res = X(2);
  237. res &= TIME_MAX;
  238. return res;
  239. }
  240. void HostServer::SyncManager::updateDistance(unsigned int localId, unsigned char localAntNum, unsigned int upperId, unsigned char uppderAntNum, double d)
  241. {
  242. unsigned long long lId = SyncHelper::parseId(localId, localAntNum);
  243. unsigned long long uId = SyncHelper::parseId(upperId, uppderAntNum);
  244. if(_anchors.count(lId) == 0)
  245. {
  246. _anchors[lId] = Position();
  247. }
  248. if(_anchors.count(uId) == 0)
  249. {
  250. _anchors[uId] = Position();
  251. }
  252. _distance[lId][uId] = d;
  253. _distance[uId][lId] = d;
  254. // 删除所有版本的消息记录
  255. _historySync.clear();
  256. _syncTimeMsgs.clear();
  257. //_historySync.swap(unordered_map<unsigned short, unordered_map<unsigned long long, SyncTime>>());
  258. //_syncTimeMsgs.swap(unordered_map<unsigned short, unordered_map<unsigned long long, SyncTimeMsg>>());
  259. }
  260. void HostServer::SyncManager::updateAnchor(unsigned int localId, unsigned char localAntNum, double x, double y, double z)
  261. {
  262. deleteAnchor(localId, localAntNum);
  263. unsigned long long lId = SyncHelper::parseId(localId, localAntNum);
  264. _anchors[lId] = Position( x, y, z);
  265. }
  266. void HostServer::SyncManager::deleteAnchor(unsigned int localId, unsigned char localAntNum)
  267. {
  268. unsigned long long lId = SyncHelper::parseId(localId, localAntNum);
  269. auto it = _anchors.find(lId);
  270. if(it == _anchors.end()) return;
  271. // 删除anchor
  272. _anchors.erase(it);
  273. // 删除与此anchor相关的距离信息
  274. _distance.erase(_distance.find(lId));
  275. for(auto it(_distance.begin()); it != _distance.end(); it++)
  276. {
  277. it->second.erase(it->second.find(lId));
  278. if(it->second.size() == 0)
  279. {
  280. it = _distance.erase(it);
  281. }
  282. }
  283. // 删除所有版本的消息记录
  284. _historySync.clear();
  285. _syncTimeMsgs.clear();
  286. //_historySync.swap(unordered_map<unsigned short, unordered_map<unsigned long long, SyncTime>>());
  287. //_syncTimeMsgs.swap(unordered_map<unsigned short, unordered_map<unsigned long long, SyncTimeMsg>>());
  288. }
  289. HostServer::SyncManager::~SyncManager()
  290. {
  291. //DeleteCriticalSection(&m_csCalcLiner);
  292. DeleteCriticalSection(&m_csSyncTime);
  293. }
  294. int HostServer::SyncManager::FindSyncTimeMsg(unsigned long long rootIdCode, unsigned short SyncNum )
  295. {
  296. int idx = -1;
  297. for(int i = _syncTimeMsgs[rootIdCode].size() - 1; i >= 0; i--){
  298. if(_syncTimeMsgs[rootIdCode][i].SyncNum == SyncNum ){
  299. return i;
  300. }
  301. }
  302. return idx;
  303. }
  304. int HostServer::SyncManager::FindHisSyncTime(unsigned long long rootIdCode, unsigned short SyncNum )
  305. {
  306. int idx = -1;
  307. for(int i = _historySync[rootIdCode].size() - 1; i >= 0; i--){
  308. if(_historySync[rootIdCode][i].SyncNum == SyncNum ){
  309. return i;
  310. }
  311. }
  312. return idx;
  313. }