|
@@ -267,7 +267,7 @@ cmRtNetRC_t _cmRtNetCreateEndpoint( cmRtNet_t* p, cmRtNetNode_t* np, const cmCha
|
267
|
267
|
}
|
268
|
268
|
|
269
|
269
|
unsigned _cmRtNetSyncMsgSerialByteCount( const cmRtNetSyncMsg_t* m )
|
270
|
|
-{ return sizeof(cmRtNetSyncMsg_t) + m->endPtLabel==NULL ? 1 : strlen(m->endPtLabel) + 1; }
|
|
270
|
+{ return sizeof(cmRtNetSyncMsg_t) + (m->endPtLabel==NULL ? 1 : strlen(m->endPtLabel) + 1); }
|
271
|
271
|
|
272
|
272
|
cmRtNetRC_t _cmRtNetSerializeSyncMsg( cmRtNet_t* p, const cmRtNetSyncMsg_t* m, void* buf, unsigned n )
|
273
|
273
|
{
|
|
@@ -781,9 +781,15 @@ bool _cmRtNetTestThreadFunc(void* param)
|
781
|
781
|
{
|
782
|
782
|
_cmRtNetTest_t* p = (_cmRtNetTest_t*)param;
|
783
|
783
|
|
784
|
|
-
|
785
|
|
- if( cmRtNetIsValid(p->netH) && cmRtNetIsInSyncMode(p->netH) )
|
786
|
|
- cmRtNetSyncModeSend(p->netH);
|
|
784
|
+ if( cmRtNetIsValid(p->netH) )
|
|
785
|
+ {
|
|
786
|
+ if( cmRtNetIsInSyncMode(p->netH) )
|
|
787
|
+ cmRtNetSyncModeSend(p->netH);
|
|
788
|
+
|
|
789
|
+ cmRtNetReceive(p->netH);
|
|
790
|
+ }
|
|
791
|
+
|
|
792
|
+ cmSleepMs(40);
|
787
|
793
|
|
788
|
794
|
return true;
|
789
|
795
|
}
|