Changeset 4076 for trunk/MagicSoft/Cosy/tcpip/MTcpIpIO.cc

Timestamp:

05/15/04 16:46:27 (20 years ago)

Author:

tbretz

Message:

*** empty log message ***

File:

• trunk/MagicSoft/Cosy/tcpip/MTcpIpIO.cc (modified) (4 diffs)

trunk/MagicSoft/Cosy/tcpip/MTcpIpIO.cc

@@ -33 +33 @@
      */
 
-MTcpIpIO::MTcpIpIO(MLog &out) : MThread(false), Log(out), fRxSocket(NULL), fServSock(NULL)
+MTcpIpIO::MTcpIpIO(MLog &out)
+    : MThread(false), Log(out), fRxSocket(NULL), fServSock(NULL), fSendInterval(1000)
 {
     fTxSocket = new TSocket("ceco", 7304);
@@ -49 +50 @@
     // Now delete all TCP/IP objects
     //
-    cout << "Delete TxSocket " << fTxSocket << "..." << flush;
+    //cout << "Delete TxSocket " << fTxSocket << "..." << flush;
     delete fTxSocket;
-    cout << "Done." << endl;
+    //cout << "Done." << endl;
     if (fServSock)
     {
-        cout << "Delete ServSock " << fServSock << "..." << flush;
+        //cout << "Delete ServSock " << fServSock << "..." << flush;
         delete fServSock;
-        cout << "Done." << endl;
+        //cout << "Done." << endl;
     }
     if (fRxSocket)
     {
-        cout << "Delete RxSocket " << fRxSocket << "..." << flush;
+        //cout << "Delete RxSocket " << fRxSocket << "..." << flush;
         delete fRxSocket;
-        cout << "Done." << endl;
+        //cout << "Done." << endl;
     }
 }
@@ -68 +69 @@
 bool MTcpIpIO::Send(const char *msg)
 {
+    const MTime t(-1);
+
+    if ((double)t-(double)fTime<0.001*fSendInterval)
+        return true;
+
+    const Int_t rc = lout.IsOutputDeviceEnabled(MLog::eGui);
+    lout.DisableOutputDevice(MLog::eGui);
+    lout.Lock();
+    lout << msg << flush;
+    lout.UnLock();
+    if (rc)
+        lout.EnableOutputDevice(MLog::eGui);
+
+    fTime = t;
+
     if (!fTxSocket->IsValid())
         return false;
@@ -112 +128 @@
             switch (fServSock->GetErrorCode())
             {
-            case 0: cout << "No error." << endl; break;
+            case  0: cout << "No error." << endl; break;
             case -1: cout << "low level socket() call failed." << endl; break;
             case -2: cout << "low level bind() call failed." << endl; break;