Changeset 12598 for trunk/Cosy/tcpip/MTcpIpIO.cc

Timestamp:

11/21/11 13:08:27 (13 years ago)

Author:

tbretz

Message:

Implemented a new class MTcpIpFact using a duplex communication for FACT

File:

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

trunk/Cosy/tcpip/MTcpIpIO.cc

@@ -62 +62 @@
 }
 
-MTcpIpIO::MTcpIpIO(const char *addr, Int_t tx, Int_t rx, UInt_t timeout) : MTcpIpI(rx, timeout), MTcpIpO(addr, tx)
+MTcpIpCC::MTcpIpCC(Int_t rx, UInt_t timeout) : MTcpIpI(rx, timeout)
 {
     MTcpIpI::RunThread();
+}
+
+MTcpIpIO::MTcpIpIO(const char *addr, Int_t tx, Int_t rx, UInt_t timeout) : MTcpIpCC(rx, timeout), MTcpIpO(addr, tx)
+{
 }
 
@@ -277 +281 @@
 }
 
-bool MTcpIpIO::InterpreteStr(TString str)
+bool MTcpIpCC::InterpreteStr(TString str)
 {
     cout << "Rx: " << str << flush;
@@ -283 +287 @@
 }
 
-Bool_t MTcpIpIO::ReadSocket(TSocket &rx)
+Bool_t MTcpIpCC::ReadSocket(TSocket &rx)
 {
     TString str;
@@ -308 +312 @@
 
         // Data received (len==1)
-        if (c!='\n')
+        if (c!='\n' && c!=0)
         {
             str += c;
@@ -331 +335 @@
     }
 
+    fRxMutex.Lock();
+
     fConnectionEstablished = kTRUE;
+    fRxSocket = &sock;
+
+    fRxMutex.UnLock();
 
     MTimeout timeout(fTimeout);
@@ -409 +418 @@
         gLog << all << MTime(-1) << " Connection established to " << MTcpIpO::GetSocketAddress(*socket) << "..." << endl;
 
-        if (!WaitForData(*socket))
-            fConnectionEstablished = kFALSE;
+        WaitForData(*socket);
+
+        fRxMutex.Lock();
+
+        fRxSocket = 0;
+        fConnectionEstablished = kFALSE;
+
+        fRxMutex.UnLock();
 
 #ifdef DEBUG
@@ -455 +470 @@
 
     return 0;
+}
+
+bool MTcpIpFact::Send(const char *msg, int len)
+{
+    const Int_t mtx = fRxMutex.TryLock();
+    if (mtx==13)
+        gLog << warn << "MTcpIpO::Send - mutex is already locked by this thread." << endl;
+
+    // If Mutex cannot be locked, i.e. we are currently reopening
+    // the send socket we cannot wait, because we would block the
+    // executing threrad.
+    if (mtx)
+        return false;
+
+    const bool rc = fRxSocket ? MTcpIpO::SendFrame(*fRxSocket, msg, len) : false;
+
+    fRxMutex.UnLock();
+
+    return rc;
 }