cmRtNet.h/c: Iniital commit.

Makefile.am

@@ -30,8 +30,8 @@ cmSRC += src/libcm/cmMidiFilePlay.c src/libcm/cmMidiPort.c src/libcm/cmMidiFile.
 cmHDR += src/libcm/cmAudioFile.h src/libcm/cmAudioFileMgr.h src/libcm/cmMsgProtocol.h src/libcm/cmAudioSys.h src/libcm/cmAudioPortFile.h src/libcm/cmAudioFileDev.h 
 cmSRC += src/libcm/cmAudioFile.c src/libcm/cmAudioFileMgr.c src/libcm/cmMsgProtocol.c src/libcm/cmAudioSys.c src/libcm/cmAudioPortFile.c src/libcm/cmAudioFileDev.c
 
-cmHDR += src/libcm/cmRtSys.h src/libcm/cmUiRtSysMstr.h src/libcm/cmRtSysMsg.h 
-cmHDR += src/libcm/cmRtSys.c src/libcm/cmUiRtSysMstr.c
+cmHDR += src/libcm/cmRtSys.h src/libcm/cmRtNet.h src/libcm/cmUiRtSysMstr.h src/libcm/cmRtSysMsg.h 
+cmSRC += src/libcm/cmRtSys.c src/libcm/cmRtNet.c src/libcm/cmUiRtSysMstr.c
 
 cmHDR += src/libcm/cmDevCfg.h src/libcm/cmUi.h src/libcm/cmUiDrvr.h 
 cmSRC += src/libcm/cmDevCfg.c src/libcm/cmUi.c src/libcm/cmUiDrvr.c

cmRtNet.c

@@ -0,0 +1,751 @@
+#include "cmGlobal.h"
+#include "cmRpt.h"
+#include "cmErr.h"
+#include "cmCtx.h"
+#include "cmMem.h"
+#include "cmMallocDebug.h"
+#include "cmUdpPort.h"
+#include "cmRtNet.h"
+#include "cmTime.h"
+#include "cmRtSysMsg.h"
+
+enum
+{
+  kLocalNetFl = 0x01,
+  kSockAddrNetFl = 0x02
+};
+
+typedef enum
+{
+  kSendHelloStNetId = 0,
+  kWaitHelloAckStNetId,
+  kSendEndpointStNetId,
+  kWaitEndpointAckStNetId,
+  kDoneStNetId,
+  kErrorStNetId,
+  kInvalidStNetId,
+} cmRtNetNodeState_t;
+
+typedef enum
+{
+  kHelloSelNetId,
+  kHelloAckSelNetId,
+  kEndpointSelNetId,
+  kEndpointAckSelNetId
+} cmRtNetSelId_t;
+
+typedef struct cmRtNetEnd_str
+{
+  cmChar_t*              endPtLabel;
+  unsigned               endPtId;
+  struct cmRtNetEnd_str* link;
+} cmRtNetEnd_t;
+
+
+typedef struct cmRtNetNode_str
+{
+  cmChar_t*               label;
+  struct sockaddr_in      sockaddr;
+  cmChar_t*               addr;
+  cmUdpPort_t             port;
+  unsigned                flags;
+  cmRtNetNodeState_t      state;
+  unsigned                epIdx;
+  cmTimeSpec_t            lastSendTime;
+  cmRtNetEnd_t*           ends;
+  struct cmRtNetNode_str* link;
+} cmRtNetNode_t;
+
+typedef struct
+{
+  cmErr_t         err;
+  cmUdpH_t        udpH;
+  cmUdpCallback_t cbFunc;
+  void*           cbArg;
+  cmRtNetNode_t*  nodes;
+  cmRtNetNode_t*  localNode;
+  bool            syncModeFl;
+  unsigned        udpRecvBufByteCnt;
+  unsigned        udpTimeOutMs;
+  unsigned        interSyncSendTimeMs;
+} cmRtNet_t;
+
+
+typedef struct
+{
+  cmRtSysMsgHdr_t hdr;
+  cmRtNetSelId_t    selId;
+  const cmChar_t* endPtLabel;
+  unsigned        endPtId;
+} cmRtNetSyncMsg_t;
+
+cmRtNetH_t cmRtNetNullHandle = cmSTATIC_NULL_HANDLE;
+
+cmRtNet_t* _cmRtNetHandleToPtr( cmRtNetH_t h )
+{
+  cmRtNet_t* p = (cmRtNet_t*)h.h;
+  assert( p != NULL );
+  return p;
+}
+
+void _cmRtNetVRpt( cmRtNet_t* p, const cmChar_t* fmt, va_list vl )
+{
+  cmRptVPrintf(p->err.rpt,fmt,vl);
+}
+
+void _cmRtNetRpt( cmRtNet_t* p, const cmChar_t* fmt, ... )
+{
+  va_list vl;
+  va_start(vl,fmt);
+  _cmRtNetVRpt(p,fmt,vl);
+  va_end(vl);
+}
+
+cmRtNetNode_t* _cmRtNetFindNode( cmRtNet_t* p, const cmChar_t* label )
+{
+  if( label == NULL )
+    return NULL;
+
+  cmRtNetNode_t* np = p->nodes;
+  for(; np!=NULL; np=np->link)
+    if( strcmp(label,np->label)==0)
+      return np;
+
+  return NULL;
+}
+
+cmRtNetNode_t* _cmRtNetFindNodeFromSockAddr( cmRtNet_t* p, const struct sockaddr_in* saddr )
+{
+  if( saddr == NULL )
+    return NULL;
+
+  cmRtNetNode_t* np = p->nodes;
+  for(; np!=NULL; np=np->link)
+    if( cmIsFlag(np->flags,kSockAddrNetFl) && np->sockaddr.sin_addr.s_addr == saddr->sin_addr.s_addr && np->sockaddr.sin_port == saddr->sin_port )
+      return np;
+  
+  return NULL;
+}
+
+void _cmRtNetFreeNode( cmRtNetNode_t* np )
+{
+  cmRtNetEnd_t* ep = np->ends;
+  while( ep != NULL )
+  {
+    cmRtNetEnd_t* nep = ep->link;
+    cmMemFree(ep->endPtLabel);
+    cmMemFree(ep);
+    ep = nep;
+  }
+
+  cmMemFree(np->label);
+  cmMemFree(np->addr);
+  cmMemFree(np);
+}
+
+void _cmRtNetReleaseNodes( cmRtNet_t* p )
+{
+  cmRtNetNode_t* np = p->nodes;
+  while( np != NULL )
+  {
+    cmRtNetNode_t* nnp = np->link;
+
+    _cmRtNetFreeNode(np);
+
+    np = nnp;
+  }
+  p->nodes = NULL;
+  p->localNode = NULL;
+}
+
+cmRtNetRC_t  _cmRtNetReleaseNode( cmRtNet_t* p, cmRtNetNode_t* np )
+{
+  // we should never release the local node via this function
+  assert( np != p->localNode );
+
+  cmRtNetNode_t* cnp = p->nodes;
+  cmRtNetNode_t* pnp = NULL;
+
+  while( cnp != NULL )
+  {
+    cmRtNetNode_t* nnp = cnp->link;
+    if( np == cnp )
+    {
+      if( pnp == NULL )
+        p->nodes = np->link;
+      else
+        pnp->link = np->link;
+
+      _cmRtNetFreeNode(np);
+
+      return kOkNetRC;
+    }
+
+    pnp = np;
+    cnp = nnp;
+  }
+
+  assert(0);
+  return cmErrMsg(&p->err,kNodeNotFoundNetRC,"Node to release not found.");
+}
+
+cmRtNetRC_t _cmRtNetCreateNode( cmRtNet_t* p, const cmChar_t* label, const cmChar_t* addr, cmUdpPort_t port, const struct sockaddr_in* saddr )
+{
+  cmRtNetNode_t* np;
+
+  if( label == NULL )
+    return cmErrMsg(&p->err,kInvalidLabelNetRC,"A null or blank node label was encountered.");
+
+  if((np = _cmRtNetFindNode(p,label)) != NULL )
+    return cmErrMsg(&p->err,kDuplLabelNetRC,"The node label '%s' is already in use.",cmStringNullGuard(label));
+
+  bool localNodeFl = addr==NULL && saddr==NULL;
+  
+  if( localNodeFl && p->localNode != NULL )
+    return cmErrMsg(&p->err,kDuplLocalNetRC,"The local node '%s' has already been set.",cmStringNullGuard(p->localNode->label));
+
+  np = cmMemAllocZ(cmRtNetNode_t,1);
+  np->label = cmMemAllocStr(label);
+  np->addr  = addr==NULL ? NULL : cmMemAllocStr(addr);
+  np->port  = port;
+  np->flags = cmEnaFlag(np->flags,kLocalNetFl,localNodeFl);
+  np->link  = p->nodes;
+  p->nodes  = np;
+
+  if( localNodeFl )
+    p->localNode = np;
+
+  if( saddr != NULL )
+  {
+    np->sockaddr = *saddr;
+    np->flags = cmSetFlag(np->flags,kSockAddrNetFl);
+  }
+
+  return kOkNetRC;
+}
+
+cmRtNetEnd_t* _cmRtNetFindNodeEnd(cmRtNetNode_t* np, const cmChar_t* endPtLabel )
+{
+  cmRtNetEnd_t* ep = np->ends;
+  for(; ep!=NULL; ep=ep->link)
+    if( strcmp(ep->endPtLabel,endPtLabel)==0 )
+      return ep;
+  return NULL;
+}
+
+cmRtNetEnd_t* _cmRtNetIndexToEndpoint( cmRtNet_t* p, cmRtNetNode_t* np, unsigned endIndex )
+{
+  cmRtNetEnd_t* ep = np->ends;
+  unsigned i;
+  for(i=0; ep!=NULL; ep=ep->link)
+  {
+    if( i == endIndex )
+      return ep;
+    ++i;
+  }
+
+  return NULL;
+}
+
+cmRtNetRC_t _cmRtNetCreateEndpoint( cmRtNet_t* p, cmRtNetNode_t* np, const cmChar_t* endPtLabel, unsigned endPtId )
+{
+  if( endPtLabel == NULL )
+    return cmErrMsg(&p->err,kInvalidLabelNetRC,"A null or blank node label was encountered.");
+
+  if( _cmRtNetFindNodeEnd( np, endPtLabel) != NULL)
+    return cmErrMsg(&p->err,kDuplEndNetRC,"A duplicate endpoint ('%s') was encountered on node '%s'.",endPtLabel,np->label);
+
+  cmRtNetRC_t   rc = kOkNetRC;
+  cmRtNetEnd_t* ep = cmMemAllocZ(cmRtNetEnd_t,1);
+
+  ep->endPtLabel = cmMemAllocStr(endPtLabel);
+  ep->endPtId    = endPtId;
+  ep->link      = np->ends;
+  np->ends      = ep;
+
+  return rc;
+}
+
+unsigned _cmRtNetSyncMsgSerialByteCount( const cmRtNetSyncMsg_t* m )
+{ return sizeof(cmRtNetSyncMsg_t) + m->endPtLabel==NULL ? 1 : strlen(m->endPtLabel) + 1; }
+
+cmRtNetRC_t _cmRtNetSerializeSyncMsg( cmRtNet_t* p, const cmRtNetSyncMsg_t* m, void* buf, unsigned n )
+{
+  unsigned bn = _cmRtNetSyncMsgSerialByteCount(m);
+  char*    b  = (char*)buf;
+
+  if( bn > n )
+    return cmErrMsg(&p->err,kBufToSmallNetRC,"Serialize buffer too small.");
+
+  memcpy(b,m,sizeof(*m));
+  strcpy(b + sizeof(*m),m->endPtLabel==NULL ? "" : m->endPtLabel);
+  return kOkNetRC;
+}
+
+cmRtNetRC_t _cmRtNetDeserializeSyncMsg( const void* buf, unsigned n, cmRtNetSyncMsg_t* m )
+{
+  assert( n > sizeof(*m));
+  memcpy(m,buf,sizeof(*m));
+  const cmRtNetSyncMsg_t* mp = (const cmRtNetSyncMsg_t*)buf;
+  const cmChar_t*   s  = (const cmChar_t*)(mp+1);
+  m->endPtLabel = cmMemAllocStr(s);
+  return kOkNetRC;
+}
+
+cmRtNetRC_t _cmRtNetSendSyncMsg( cmRtNet_t* p, cmRtNetNode_t* np, cmRtNetSelId_t selId, const cmChar_t* endPtLabel, unsigned endPtId, cmRtNetNodeState_t nextStId )
+{
+  cmRtNetSyncMsg_t m;
+  cmRtNetRC_t      rc = kOkNetRC;
+
+  m.hdr.rtSubIdx = cmInvalidIdx;
+  m.hdr.selId    = kNetSyncSelRtId;
+  m.selId        = selId;
+  m.endPtLabel    = endPtLabel;
+  m.endPtId       = endPtId;
+
+  // determine size of msg to send
+  unsigned n  = _cmRtNetSyncMsgSerialByteCount(&m);
+  cmChar_t buf[n];
+
+  // serialize msg into buf[]
+  if((rc = _cmRtNetSerializeSyncMsg(p,&m,buf,n)) != kOkNetRC )
+    return rc;
+
+  // store this nodes current sync state
+  cmRtNetNodeState_t orgState = np->state;
+  np->state = nextStId;
+
+  // send the msg
+  cmUdpRC_t udpRC;
+  if( cmIsFlag(np->flags,kSockAddrNetFl) )
+    udpRC = cmUdpSendTo(p->udpH, buf, n, &np->sockaddr );
+  else
+    udpRC = cmUdpSend2(p->udpH, buf, n, np->addr, np->port );
+
+  // check for send errors
+  if( udpRC != kOkUdpRC )
+  {
+    rc = cmErrMsg(&p->err,kUdpPortFailNetRC,"Sync msg. send on UDP port failed.");
+    np->state = orgState;  // restore node state so we can try again
+  }
+  else
+  {
+    // record the last send time
+    cmTimeGet(&np->lastSendTime);
+  }
+
+  return rc;
+}
+
+cmRtNetRC_t _cmRtNetFree( cmRtNet_t* p )
+{
+  cmRtNetRC_t rc = kOkNetRC;
+  
+  if( cmUdpFree(&p->udpH) != kOkUdpRC )
+    cmErrMsg(&p->err,kUdpPortFailNetRC,"UDP Port free failed.");
+
+  _cmRtNetReleaseNodes(p);
+
+  cmMemFree(p);
+  return rc;
+}
+
+
+cmRtNetRC_t cmRtNetAlloc( cmCtx_t* ctx, cmRtNetH_t* hp, cmUdpCallback_t cbFunc, void* cbArg )
+{
+  cmRtNetRC_t rc;
+  if((rc = cmRtNetFree(hp)) != kOkNetRC )
+    return rc;
+
+  cmRtNet_t* p = cmMemAllocZ(cmRtNet_t,1);
+  cmErrSetup(&p->err,&ctx->rpt,"cmRtNet");
+ 
+  // allocate the UDP port
+  if(cmUdpAlloc(ctx,&p->udpH) != kOkUdpRC )
+  {
+    cmErrMsg(&p->err,kUdpPortFailNetRC,"UDP Port allocate failed.");
+    goto errLabel;
+  }
+
+  p->udpTimeOutMs        = 50;
+  p->udpRecvBufByteCnt   = 8192;
+  p->interSyncSendTimeMs = 10;
+  p->cbFunc = cbFunc;
+  p->cbArg  = cbArg;
+
+  hp->h = p;
+
+ errLabel:
+  if(rc != kOkNetRC )
+    _cmRtNetFree(p);
+
+  return rc;
+}
+
+cmRtNetRC_t cmRtNetFree( cmRtNetH_t* hp )
+{
+  cmRtNetRC_t rc = kOkNetRC;
+
+  if( hp==NULL || cmRtNetIsValid(*hp)==false )
+    return rc;
+
+  cmRtNet_t* p = _cmRtNetHandleToPtr(*hp);
+
+  if((rc = _cmRtNetFree(p)) != kOkNetRC )
+    return rc;
+
+  hp->h = NULL;
+
+  return rc;
+}
+
+bool cmRtNetIsValid( cmRtNetH_t h )
+{ return h.h !=NULL; }
+
+cmUdpH_t  cmRtNetUdpPortHandle( cmRtNetH_t h )
+{
+  cmRtNet_t*  p = _cmRtNetHandleToPtr(h);
+  return p->udpH;
+}
+
+
+cmRtNetRC_t cmRtNetCreateNode( cmRtNetH_t h, const cmChar_t* nodeLabel, const cmChar_t* ipAddr, cmUdpPort_t port )
+{
+  cmRtNet_t*  p = _cmRtNetHandleToPtr(h);
+  cmRtNetRC_t rc;
+
+  // create a node
+  if((rc = _cmRtNetCreateNode(p,nodeLabel,ipAddr, port, NULL)) != kOkNetRC )
+    return rc;
+
+  // if this is not the local node
+  if( ipAddr != NULL )
+    return rc;
+
+  // if this is the local node then initialze the local socket
+  if( cmUdpInit(p->udpH,port,kNonBlockingUdpFl,p->cbFunc,p->cbArg,NULL,0,p->udpRecvBufByteCnt,p->udpTimeOutMs) != kOkUdpRC )
+  {
+    rc = cmErrMsg(&p->err,kUdpPortFailNetRC,"The UDP port initialization failed.");
+    goto errLabel;
+  }
+
+  // begin listening on the local port
+  if( cmUdpEnableListen(p->udpH, true ) != kOkUdpRC )
+  {
+    rc = cmErrMsg(&p->err,kUdpPortFailNetRC,"The UDP port failed to enter 'listen' mode.");
+    goto errLabel;
+  }
+
+
+ errLabel:
+  return rc;
+}
+
+cmRtNetRC_t cmRtNetRegisterEndPoint( cmRtNetH_t h, const cmChar_t* endPtLabel, unsigned endPtId )
+{
+  cmRtNet_t* p = _cmRtNetHandleToPtr(h);
+
+  if( p->localNode == NULL )
+    return cmErrMsg(&p->err,kLocalNodeNetRC,"Local endpoints may not be added if a local node has not been defined.");
+
+  return _cmRtNetCreateEndpoint(p, p->localNode,endPtLabel,endPtId );
+
+}
+
+cmRtNetRC_t cmRtNetClearAll( cmRtNetH_t h )
+{
+  cmRtNet_t* p = _cmRtNetHandleToPtr(h);
+  _cmRtNetReleaseNodes(p);
+  return kOkNetRC;
+}
+
+cmRtNetRC_t cmRtNetBeginSyncMode( cmRtNetH_t h )
+{
+  cmRtNetRC_t rc = kOkNetRC;
+  
+  cmRtNet_t* p = _cmRtNetHandleToPtr(h);
+
+  p->syncModeFl = true;
+  
+  return rc;
+}
+
+bool      cmRtNetIsInSyncMode(  cmRtNetH_t h )
+{
+  cmRtNet_t* p = _cmRtNetHandleToPtr(h);
+
+  return p->syncModeFl;
+}
+
+
+// Used by slaves to send the master an 'ack' msg.
+cmRtNetRC_t _cmRtNetSendAck( cmRtNet_t* p, cmRtNetSelId_t ackSelId, const struct sockaddr_in* saddr )
+{
+  cmRtNetNode_t* np;
+
+  if((np = _cmRtNetFindNodeFromSockAddr(p,saddr)) != NULL )
+    return cmErrMsg(&p->err,kNodeNotFoundNetRC,"The net node associated with an ack cmd was not found. Ack not sent.");
+
+  return _cmRtNetSendSyncMsg(p,np,ackSelId,NULL,cmInvalidId,kInvalidStNetId);
+}
+
+// Used by master to update state upon receipt of 'ack' msg
+cmRtNetRC_t _cmRtNetRecvAck( cmRtNet_t* p, const struct sockaddr_in* fromAddr, cmRtNetNodeState_t expectedState, cmRtNetNodeState_t nextState )
+{
+  cmRtNetNode_t* np;
+  cmRtNetRC_t rc = kOkNetRC;
+
+  if((np = _cmRtNetFindNodeFromSockAddr(p,fromAddr)) == NULL )
+  {
+    rc = cmErrMsg(&p->err,kNodeNotFoundNetRC,"The net node associated with a  ack receive was not found.");
+    goto errLabel;
+  }
+
+  if( np->state != expectedState )
+  {
+    rc = cmErrMsg(&p->err,kNodeStateErrNetRC,"Node '%s' expected in state %i was in state %i.",kWaitHelloAckStNetId,np->state);
+    np->state = kErrorStNetId;
+    goto errLabel;
+  }
+
+  np->state = nextState;
+
+ errLabel:
+  return rc;
+}
+
+
+cmRtNetRC_t  cmRtNetSyncModeRecv( cmRtNetH_t h, const char* data, unsigned dataByteCnt, const struct sockaddr_in* fromAddr )
+{
+  cmRtNet_t*       p  = _cmRtNetHandleToPtr(h);
+  cmRtNetRC_t      rc = kOkNetRC;
+  cmRtNetNode_t*   np = NULL;
+  cmRtNetSyncMsg_t m;
+
+  assert( p->syncModeFl );
+  
+  if( _cmRtNetDeserializeSyncMsg(data,dataByteCnt,&m) != kOkNetRC )
+  {
+    rc = cmErrMsg(&p->err,rc,"Net sync. receive failed due to deserialize fail.");
+    goto errLabel;
+  }
+
+  assert( m.hdr.selId == kNetSyncSelRtId );
+
+  switch( m.selId )
+  {
+    
+    case kHelloSelNetId: // slave response
+      {
+        _cmRtNetRpt(p,"rcv hello\n");
+
+        // attempt to locate the remote node which sent the endpoint 
+        if((np = _cmRtNetFindNodeFromSockAddr(p,fromAddr)) != NULL )
+        {
+          // delete the existing node because we are about to get new info. about it.
+          if((rc =  _cmRtNetReleaseNode(p,np )) != kOkNetRC )
+            goto errLabel;
+        }
+
+        //  create a node proxy to represent the remote node
+        if(( rc = _cmRtNetCreateNode(p,m.endPtLabel,NULL,0,fromAddr)) != kOkNetRC )
+          goto errLabel;
+
+        // send an ackknowledgement of the 'hello' msg
+        rc = _cmRtNetSendAck(p,kHelloAckSelNetId,fromAddr);
+      }
+      break;
+
+    
+    case kEndpointSelNetId: // slave response
+      {
+        cmRtNetEnd_t* ep;
+
+        _cmRtNetRpt(p,"rcv endpoint\n");
+
+
+        // locate the remote node which sent the endpoint
+        if((np = _cmRtNetFindNodeFromSockAddr(p,fromAddr)) == NULL )
+        {
+          rc = cmErrMsg(&p->err,kNodeNotFoundNetRC,"The net node associated with an endpoint receive was not found.");
+          goto errLabel;
+        }
+        
+        // attempt to find the end point 
+        if((ep = _cmRtNetFindNodeEnd(np,m.endPtLabel)) != NULL )
+          ep->endPtId = m.endPtId; // the endpoint was found update the endPtId
+        else
+        {
+          // create a local proxy for the endpoint
+          if((rc = _cmRtNetCreateEndpoint(p,np,m.endPtLabel,m.endPtId)) != kOkNetRC )
+            goto errLabel;
+        }
+
+        // ack. the endpoint msg
+        rc = _cmRtNetSendAck(p,kEndpointAckSelNetId,fromAddr);
+      }
+      break;
+
+    case kHelloAckSelNetId: // master response
+      _cmRtNetRpt(p,"rcv hello ack\n");
+      rc = _cmRtNetRecvAck(p,fromAddr,kWaitHelloAckStNetId,kSendEndpointStNetId);
+      break;
+
+    case kEndpointAckSelNetId: // master response
+      _cmRtNetRpt(p,"rcv endpoint ack\n");
+      rc = _cmRtNetRecvAck(p,fromAddr,kWaitEndpointAckStNetId,kSendEndpointStNetId);
+      break;
+
+    default:
+      break;
+  }
+
+ errLabel:
+  return rc;
+}
+
+
+cmRtNetRC_t _cmRtNetSendNodeSync( cmRtNet_t* p, cmRtNetNode_t* np )
+{
+  cmRtNetRC_t rc = kOkNetRC;
+
+  switch( np->state )
+  {
+    case kSendHelloStNetId:
+      // send a 'hello' to this remote node
+      if((rc = _cmRtNetSendSyncMsg(p,np,kHelloSelNetId,p->localNode->label, cmInvalidId, kWaitHelloAckStNetId )) != kOkNetRC )
+        rc = cmErrMsg(&p->err,rc,"Send 'hello' to %s:%s:%i failed.",cmStringNullGuard(np->label),cmStringNullGuard(np->addr),np->port);
+      else
+        _cmRtNetRpt(p,"send hello\n");
+      break;
+
+    case kSendEndpointStNetId:
+      {
+        cmRtNetEnd_t* ep;
+
+        // if all of the endpoints have been sent to this node ...
+        if((ep = _cmRtNetIndexToEndpoint(p,p->localNode,np->epIdx)) == NULL )
+          np->state = kDoneStNetId; // ... we are done
+        else
+        {
+          // send an endpoint to this node 
+          if((rc = _cmRtNetSendSyncMsg(p,np,kHelloSelNetId,ep->endPtLabel, ep->endPtId, kWaitEndpointAckStNetId )) != kOkNetRC )
+            rc = cmErrMsg(&p->err,rc,"Endpoint (%s index:%i) transmission to %s:%s:%i failed.",cmStringNullGuard(ep->endPtLabel),cmStringNullGuard(np->label),cmStringNullGuard(np->addr),np->port);
+          else
+            _cmRtNetRpt(p,"send endpoint\n");
+
+        }
+      }
+      break;
+
+    case kWaitHelloAckStNetId:
+    case kWaitEndpointAckStNetId:
+      {
+        cmTimeSpec_t t;
+        cmTimeGet(&t);
+        unsigned fiveSecs = 5000000;
+        if( cmTimeElapsedMicros(&np->lastSendTime,&t) > fiveSecs)
+        {
+          const cmChar_t* ackStr = np->state==kWaitHelloAckStNetId ? "hello" : "endpoint";
+          rc = cmErrMsg(&p->err,kTimeOutErrNetRC,"The node %s:%s:%i did not give a '%s' acknowledge.",cmStringNullGuard(np->label),cmStringNullGuard(np->addr),np->port,ackStr);         
+        }
+      }
+      break;
+
+    default:
+      break;
+  }
+      
+  // if an error occurred put the node into an error state
+  if( rc != kOkNetRC )
+    np->state = kErrorStNetId;
+      
+  return rc;
+}
+
+
+
+cmRtNetRC_t cmRtNetSyncModeSend( cmRtNetH_t h )
+{
+  cmRtNetRC_t rc = kOkNetRC;
+  cmRtNet_t*  p  = _cmRtNetHandleToPtr(h);
+
+  if( p->syncModeFl == false )
+    return rc;
+  
+  unsigned     activeCnt = 0;
+  cmRtNetNode_t* np        = p->nodes;
+  for(; np != NULL; np=np->link )
+    if( np != p->localNode && np->state != kDoneStNetId && np->state != kErrorStNetId )
+    {
+      _cmRtNetSendNodeSync(p,np);
+      activeCnt += 1;
+    }
+    
+  if( activeCnt == 0 )
+    p->syncModeFl = false;
+
+  return rc;
+}
+
+
+cmRtNetRC_t cmRtNetReceive( cmRtNetH_t h )
+{
+  cmRtNetRC_t rc = kOkNetRC;
+  cmRtNet_t*  p  = _cmRtNetHandleToPtr(h);
+
+  if( cmUdpGetAvailData(p->udpH, NULL, NULL, NULL ) != kOkUdpRC )
+  {
+    cmErrMsg(&p->err,kUdpPortFailNetRC,"UDP port query failed.");
+    goto errLabel;
+  }
+ errLabel:
+  return rc;
+}
+
+unsigned  cmRtNetEndPointIndex( cmRtNetH_t h, const cmChar_t* nodeLabel, const cmChar_t* endPtLabel )
+{
+  //cmRtNet_t* p = _cmRtNetHandleToPtr(h);
+  return cmInvalidIdx;
+}  
+
+cmRtNetRC_t cmRtNetSend( cmRtNetH_t h, unsigned endPointIndex, const void* msg, unsigned msgByteCnt )
+{
+  cmRtNetRC_t rc = kOkNetRC;
+  //cmRtNet_t* p = _cmRtNetHandleToPtr(h);
+  return rc;
+}
+
+void   cmRtNetReport( cmRtNetH_t h )
+{
+  cmRtNet_t* p = _cmRtNetHandleToPtr(h);
+  cmRpt_t* rpt = p->err.rpt;
+
+  cmRptPrintf(rpt,"Sync Mode:%s\n",p->syncModeFl ? "ON" : "OFF");
+
+  cmRtNetNode_t* np = p->nodes;
+  for(; np!=NULL; np=np->link)
+  {
+    cmRptPrintf(rpt,"Node: %s ",np->label);
+
+    if( np->addr != NULL )
+      cmRptPrintf(rpt,"%s ",np->addr );
+
+    if( cmIsFlag(np->flags,kLocalNetFl) )
+      cmRptPrintf(rpt,"LOCAL ");
+
+    if( cmIsFlag(np->flags,kSockAddrNetFl) )
+      cmRptPrintf(rpt,"%s ",cmStringNullGuard(cmUdpAddrToString(p->udpH,&np->sockaddr)));
+
+    if( np->port != cmInvalidId )
+      cmRptPrintf(rpt,"%i ",np->port );
+
+    cmRptPrintf(rpt,"\n");
+
+    cmRtNetEnd_t* ep = np->ends;
+    for(; ep!=NULL; ep=ep->link)
+    {
+      cmRptPrintf(rpt,"  endpt: %i %s\n",ep->endPtId,cmStringNullGuard(ep->endPtLabel));
+    }
+  }
+}

cmRtNet.h

@@ -0,0 +1,94 @@
+#ifndef cmNet_h
+#define cmNet_h
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+  enum
+  {
+    kOkNetRC = cmOkRC,
+    kUdpPortFailNetRC,
+    kInvalidLabelNetRC,
+    kDuplLabelNetRC,
+    kDuplLocalNetRC,
+    kDuplEndNetRC,
+    kThreadFailNetRC,
+    kBufToSmallNetRC,
+    kNodeNotFoundNetRC,
+    kNodeStateErrNetRC,
+    kTimeOutErrNetRC,
+    kLocalNodeNetRC,
+  };
+
+  typedef cmRC_t     cmRtNetRC_t;
+  typedef cmHandle_t cmRtNetH_t;
+
+
+  extern cmRtNetH_t cmRtNetNullHandle;
+
+  // 'cbFunc' will be called within the context of cmRtNetReceive() to receive
+  // incoming network messages.
+  cmRtNetRC_t cmRtNetAlloc( cmCtx_t* ctx, cmRtNetH_t* hp, cmUdpCallback_t cbFunc, void* cbArg );
+  cmRtNetRC_t cmRtNetFree( cmRtNetH_t* hp );
+
+  bool      cmRtNetIsValid( cmRtNetH_t h );
+
+
+  // Create a network node.
+  // The 'nodeLabel' refers to a network device cfg. (see cmDevCfg).
+  // Set 'ipAddr' to NULL if this is the local node.
+  // During sync mode this node will attempt to sync with all
+  // nodes in the node list.
+  cmRtNetRC_t cmRtNetCreateNode( cmRtNetH_t h, const cmChar_t* nodeLabel, const cmChar_t* ipAddr, cmUdpPort_t ipPort );
+
+  // Register the local endpoints.
+  // Remote nodes will be able to send messages to these endpoints by
+  // referring to (nodeLabel/endPtLabel)
+  cmRtNetRC_t cmRtNetRegisterEndPoint( cmRtNetH_t h, const cmChar_t* endPtLabel, unsigned endPtId );
+
+  // Delete all nodes and endpoints.
+  cmRtNetRC_t cmRtNetClearAll( cmRtNetH_t h );
+
+
+  // Go into 'sync' node.
+  // When a node enters sync mode it systematically transmits all of it's local endpoint 
+  // information to each registered remote node.  Prior to entering sync mode a node 
+  // must therefore have been setup with a list of remote nodes (via cmRtNetCreateNode()) 
+  // and a list of local endpoints (cmRtNetRegisterEndpoint()). 
+  // During sync mode a node sends it's local endpoint list to each registered remote node.
+  // When a remote node receives an endpoint it updates it's own remote node/endpoint 
+  // list.
+  cmRtNetRC_t cmRtNetBeginSyncMode( cmRtNetH_t h );
+  bool      cmRtNetIsInSyncMode(  cmRtNetH_t h );
+
+  // When the network message recieve function (See cmRtNetAlloc() 'cbFunc') 
+  // receives a message with the cmRtSysMsgHdr_t.selId == kNetSyncSelRtId
+  // it should call this function to update the current sync state of the
+  // cmRtNet.
+  cmRtNetRC_t  cmRtNetSyncModeRecv( cmRtNetH_t h, const char* data, unsigned dataByteCnt, const struct sockaddr_in* fromAddr );
+
+  
+  // When in the network is in sync mode (cmRtNetIsSync()==true) 
+  // the client system must poll this function to update the networks sync state.
+  cmRtNetRC_t cmRtNetSyncModeSend( cmRtNetH_t h );
+
+  // This function must be polled to receive incoming network messages
+  // via the callback funcion 'cbFunc' as passed to cmRtNetAlloc()
+  cmRtNetRC_t cmRtNetReceive( cmRtNetH_t h );
+
+  unsigned  cmRtNetEndPointIndex( cmRtNetH_t h, const cmChar_t* nodeLabel, const cmChar_t* endPtLabel );
+  
+
+  cmRtNetRC_t cmRtNetSend( cmRtNetH_t h, unsigned endPointIndex, const void* msg, unsigned msgByteCnt );
+
+  void      cmRtNetReport( cmRtNetH_t h );
+    
+  
+
+#ifdef __cplusplus
+}
+#endif
+
+
+#endif