From 1286aea854e5d7f24c1cf9a62b2bc00c7468e8b3 Mon Sep 17 00:00:00 2001
From: kevin <kevin@larke.org>
Date: Sat, 30 Nov 2024 08:46:22 -0500
Subject: [PATCH] main.cpp/main.cpp : Update test interface for socket testers
 by shifting hardcoded values into main.cfg

---
 src/cwtest/cfg/main.cfg |  68 ++++++++++++++++----------
 src/cwtest/main.cpp     | 103 +++++-----------------------------------
 2 files changed, 55 insertions(+), 116 deletions(-)

diff --git a/src/cwtest/cfg/main.cfg b/src/cwtest/cfg/main.cfg
index 91ff88e..06c82f3 100644
--- a/src/cwtest/cfg/main.cfg
+++ b/src/cwtest/cfg/main.cfg
@@ -79,19 +79,55 @@
     audioDevAlsa: {},
     audioDevRpt: {}, // print a list of audio device
 
-    socket: {},
-    socketTcp: {},
-    socketSrvUdp: {},
-    socketSrvTcp: {},
+    // Interactive send/recv tester
+    socketUdp: {
+       localPort: 5687,
+       remoteAddr: "127.0.0.1",  // localhost
+       remotePort: 5688
+    },
+    
+    socketTcpClient: {       
+       localPort: 5687,
+       remoteAddr: "127.0.0.1",  // localhost
+       remotePort: 5688
+       dgramFl: false,
+       serverFl: false,
+       timeOutMs: 100
+    },
+
+    socketTcpServer: {       
+       localPort: 5688,
+       remoteAddr: "127.0.0.1",  // localhost
+       remotePort: 5687,
+       dgramFl: false,
+       serverFl: true,
+       timeOutMs: 100
+    },
+
+    socketSrvUdp: {
+       localPort: 5688,
+       remoteAddr: "127.0.0.1",  // localhost
+       remotePort: 5687,
+    },
+    
+    socketSrvTcp: {
+       localPort: 5688,
+       remoteAddr: "127.0.0.1",  // localhost
+       remotePort: 5687,
+    },
+    
     sockMgrTest: {},
     
     uiTest: {
        ui: {
-         physRootDir: "/home/kevin/src/cwtest/src/libcw/html/uiTest",
+         physRootDir: "~/src/cwtest/src/libcw/html/uiTest",
          dfltPageFn:  "index.html",
          port: 5687,
          rcvBufByteN: 2048,
          xmtBufByteN: 2048,
+	 queueBlkCnt: 8,
+	 queueBlkByteCnt: 8192,
+	 extraLogsFl: true,
          fmtBufByteN: 4096,
          websockTimeOutMs: 50,   // max time out while blocking for a websock event
          uiCfgFn: "ui.cfg",       // default UI resource description
@@ -339,8 +375,6 @@
          },
 
 
-    audioDevRpt: {},
-    
     audioDevTest: {
      srate: 48000,
      bufN: 3,
@@ -360,22 +394,6 @@
       
     },
     
-
-    
-    mtx:
-    {
-      m0: [ [0,3], [1,4], [2,5]  ],
-      m1: [ [0,1,2],[3,4,5] ],
-      
-      m2: [ [[0,1],[2,3]], [[4,5],[6,7]], [[8,9],[10,11]] ],
-      m3: [ 0,1,2 ],
-
-      m4: [ [10,13], [11,14], [12,15]  ],
-
-      y0: [ [5,14],[14,50] ],
-      y1: [ [9,12,15],[12,17,22],[15,22,29] ],
-    },
-
     b23Tree:
     {
     },
@@ -1108,8 +1126,8 @@
           ceiling:  30.0,
           expo:      2.0,
           thresh:   54.0,
-          upr: -0.7,
-          lwr:  2.0,
+          upr:      -0.7,
+          lwr:       2.0,
           mix:       0.0
         }
       }
diff --git a/src/cwtest/main.cpp b/src/cwtest/main.cpp
index 1a53d51..d70943d 100644
--- a/src/cwtest/main.cpp
+++ b/src/cwtest/main.cpp
@@ -384,86 +384,10 @@ cw::rc_t audioDevAlsaTest(     const cw::object_t* cfg, const cw::object_t* args
 cw::rc_t audioDevRpt(          const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] ) { return _no_alsa(); }
 #endif
 
-cw::rc_t socketTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )
-{
-  cw::rc_t rc = cw::kOkRC;
-  
-  if( argc < 3 )
-    rc = cwLogError(cw::kInvalidArgRC,"Invalid arg count to socketTest().");
-  else
-  {
-    unsigned short localPort  = atoi(argv[1]);
-    unsigned short remotePort = atoi(argv[2]);
-    const char* remoteAddr = "127.0.0.1"; //"224.0.0.251"; //"127.0.0.1";
-    printf("local:%i remote:%i\n", localPort, remotePort);
-    
-    rc = cw::net::socket::test( localPort, remoteAddr, remotePort );
-  }
-  return rc;
-}
-
-cw::rc_t socketTestTcp( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )
-{
-  // server: ./cw_rt main.cfg socketTcp 5434 5435 dgram/stream server
-  // client: ./cw_rt main.cfg socketTcp 5435 5434 dgram/stream
-  cw::rc_t rc = cw::kOkRC;
-  
-  if( argc < 4 )
-    rc = cwLogError(cw::kInvalidArgRC,"Invalid arg. count to socketTestTcp().");
-  else
-  {
-    unsigned short localPort  = atoi(argv[1]);
-    unsigned short remotePort = atoi(argv[2]);
-    bool           dgramFl    = strcmp(argv[3],"dgram") == 0;
-    bool           serverFl   = false;
-    
-    if( argc >= 5 )
-      serverFl = strcmp(argv[4],"server") == 0;
-
-    printf("local:%i remote:%i %s %s\n", localPort, remotePort, dgramFl ? "dgram":"stream", serverFl?"server":"client");
-    
-    rc = cw::net::socket::test_tcp( localPort, "127.0.0.1", remotePort, dgramFl, serverFl );
-  }
-
-  return rc;
-}
-
-cw::rc_t socketSrvUdpTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )
-{
-  cw::rc_t rc = cw::kOkRC;
-  
-  if( argc < 4 )
-    rc = cwLogError(cw::kInvalidArgRC,"Invalid arg. count to socketSrvUdpTest().");
-  else
-  {
-    unsigned short localPort  = atoi(argv[1]);
-    const char*    remoteIp   = argv[2];
-    unsigned short remotePort = atoi(argv[3]);
-
-    printf("local:%i to remote:%s %i\n", localPort, remoteIp, remotePort);
-    
-    rc = cw::net::srv::test_udp_srv( localPort, remoteIp, remotePort );
-  }
-  return rc;
-}
-cw::rc_t socketSrvTcpTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )
-{
-  cw::rc_t rc = cw::kOkRC;
-  
-  if( argc < 4 )
-    rc = cwLogError(cw::kInvalidArgRC,"Invaid arg. count to socketSrvTcpTest().");
-  else
-  {
-    unsigned short localPort  = atoi(argv[1]);
-    const char*    remoteIp   = argv[2];
-    unsigned short remotePort = atoi(argv[3]);
-
-    printf("local:%i to remote:%s %i\n", localPort, remoteIp, remotePort);
-    
-    rc = cw::net::srv::test_tcp_srv( localPort, remoteIp, remotePort );
-  }
-  return rc;
-}
+cw::rc_t socketTestUdp(    const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] ) { return cw::net::socket::test_udp(args); }
+cw::rc_t socketTestTcp(    const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] ) { return cw::net::socket::test_tcp(args); }
+cw::rc_t socketSrvUdpTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] ) { return cw::net::srv::test_udp_srv(args); }
+cw::rc_t socketSrvTcpTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] ) { return cw::net::srv::test_tcp_srv(args); }
 
 cw::rc_t sockMgrTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )
 {
@@ -559,15 +483,11 @@ cw::rc_t datasetAdapterTest( const cw::object_t* cfg, const cw::object_t* args,
 
 #else
 
-cw::rc_t mnistTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )
-{  
-  return cw::dataset::mnist::test(cfg);
-}
-
-cw::rc_t datasetTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )     { return cw::dataset::test(args); }
-cw::rc_t datasetWtrTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )  { return cw::dataset::wtr::test(args); }
-cw::rc_t datasetRdrTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )  { return cw::dataset::rdr::test(args); }
-cw::rc_t datasetAdapterTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )  { return cw::dataset::adapter::test(args); }
+cw::rc_t mnistTest(          const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] ) { return cw::dataset::mnist::test(cfg); }
+cw::rc_t datasetTest(        const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] ) { return cw::dataset::test(args); }
+cw::rc_t datasetWtrTest(     const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] ) { return cw::dataset::wtr::test(args); }
+cw::rc_t datasetRdrTest(     const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] ) { return cw::dataset::rdr::test(args); }
+cw::rc_t datasetAdapterTest( const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] ) { return cw::dataset::adapter::test(args); }
 
 cw::rc_t svgTest(   const cw::object_t* cfg, const cw::object_t* args, int argc, const char* argv[] )
 {
@@ -671,8 +591,9 @@ int main( int argc, const char* argv[] )
    { "audioDevAlsa", audioDevAlsaTest },
    { "audioDevRpt", audioDevRpt },
    //{ "nbmem", nbmemTest },
-   { "socket", socketTest },
-   { "socketTcp", socketTestTcp },
+   { "socketUdp", socketTestUdp },
+   { "socketTcpClient", socketTestTcp },
+   { "socketTcpServer", socketTestTcp },
    { "socketSrvUdp", socketSrvUdpTest },
    { "socketSrvTcp", socketSrvTcpTest },
    { "sockMgrTest", sockMgrTest },