From 19ec97b2b4d228b4fc39abe81679e1dcf8d4022a Mon Sep 17 00:00:00 2001
From: kevin <kpl@larke.org>
Date: Fri, 26 Apr 2013 13:19:55 -0700
Subject: [PATCH] cmRtNet.h/c: More changes to cmRtNetTest().

---
 cmRtNet.c | 15 ++++++++-------
 cmRtNet.h |  2 +-
 2 files changed, 9 insertions(+), 8 deletions(-)

diff --git a/cmRtNet.c b/cmRtNet.c
index 405b333..2375bb6 100644
--- a/cmRtNet.c
+++ b/cmRtNet.c
@@ -759,6 +759,7 @@ void   cmRtNetReport( cmRtNetH_t h )
 
 
 //==========================================================================
+#include "cmThread.h"
 
 typedef struct
 {
@@ -768,7 +769,7 @@ typedef struct
 
 void _cmRtNetTestRecv( void* cbArg, const char* data, unsigned dataByteCnt, const struct sockaddr_in* fromAddr )
 {
-  _cmRtNetTest_t* p = (_cmrtNetTest_t*)cbArg;
+  _cmRtNetTest_t* p = (_cmRtNetTest_t*)cbArg;
 
   if( cmRtNetIsSyncModeMsg(data,dataByteCnt))
     cmRtNetSyncModeRecv(p->netH,data,dataByteCnt,fromAddr);
@@ -778,7 +779,7 @@ void _cmRtNetTestRecv( void* cbArg, const char* data, unsigned dataByteCnt, cons
 
 bool _cmRtNetTestThreadFunc(void* param)
 {
-  _cmrtNetTest_t* p = (_cmRtNetTest_t*)param;
+  _cmRtNetTest_t* p = (_cmRtNetTest_t*)param;
 
   
   if( cmRtNetIsValid(p->netH) && cmRtNetIsInSyncMode(p->netH) )
@@ -787,7 +788,7 @@ bool _cmRtNetTestThreadFunc(void* param)
   return true;
 }
 
-void    cmRtNetTest( cmCtx_t* ctx, bool mstrFl )
+void  cmRtNetTest( cmCtx_t* ctx, bool mstrFl )
 {
   char c;
   _cmRtNetTest_t t;
@@ -799,7 +800,7 @@ void    cmRtNetTest( cmCtx_t* ctx, bool mstrFl )
   if( cmThreadCreate(&p->thH,_cmRtNetTestThreadFunc,p,&ctx->rpt) != kOkThRC )
     goto errLabel;
 
-  if((rc = cmRtNetAlloc(ctx,&p->netH,p)) != kOkNetRC )
+  if((rc = cmRtNetAlloc(ctx,&p->netH,_cmRtNetTestRecv,p)) != kOkNetRC )
     goto errLabel;
 
   if((rc = cmRtNetCreateNode(p->netH, "local", NULL, port )) != kOkNetRC)
@@ -807,10 +808,10 @@ void    cmRtNetTest( cmCtx_t* ctx, bool mstrFl )
 
   if( mstrFl )
   {
-    if((rc = cmRtNetCreate(p->netH,"whirl", "192.168.15.109", port )) != kOkNetRC )
+    if((rc = cmRtNetCreateNode(p->netH,"whirl", "192.168.15.109", port )) != kOkNetRC )
       goto errLabel;
 
-    if((rc = cmRtNetEndPoint(p->netH,"thunk_ep0", 0 )) != kOkNetRC )
+    if((rc = cmRtNetRegisterEndPoint(p->netH,"thunk_ep0", 0 )) != kOkNetRC )
       goto errLabel;
 
     if(( rc = cmRtNetBeginSyncMode(p->netH)) != kOkNetRC )
@@ -819,7 +820,7 @@ void    cmRtNetTest( cmCtx_t* ctx, bool mstrFl )
   }
   else
   {
-    if((rc = cmRtNetEndPoint(p->netH,"whirl_ep0", 0 )) != kOkNetRC )
+    if((rc = cmRtNetRegisterEndPoint(p->netH,"whirl_ep0", 0 )) != kOkNetRC )
       goto errLabel;
   }
   
diff --git a/cmRtNet.h b/cmRtNet.h
index 5be9fc3..3121e23 100644
--- a/cmRtNet.h
+++ b/cmRtNet.h
@@ -87,7 +87,7 @@ extern "C" {
 
   void      cmRtNetReport( cmRtNetH_t h );
     
-  void      cmRtNetTest( cmCtx_t* ctx );
+  void      cmRtNetTest( cmCtx_t* ctx, bool mstrFl );
 
   /*
     Master: