Changeset 12598 for trunk/Cosy/tcpip

Timestamp:

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

Author:

tbretz

Message:

Implemented a new class MTcpIpFact using a duplex communication for FACT

Location:

trunk/Cosy/tcpip

Files:

• MTcpIpIO.cc (modified) (7 diffs)
• MTcpIpIO.h (modified) (5 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;
 }
 

trunk/Cosy/tcpip/MTcpIpIO.h

@@ -20 +20 @@
 class MTcpIpI : public MThread
 {
+protected:
+    TSocket *fRxSocket;
+    TMutex   fRxMutex;
+
 private:
     Int_t  fPortRx;     // Port on which to listen for connections
@@ -36 +40 @@
 
 public:
-    MTcpIpI(Int_t rx, UInt_t timeout=5000) : MThread(Form("MTcpIpI::%d", rx)), fPortRx(rx), fTimeout(timeout), fConnectionEstablished(kFALSE) { /*RunThread();*/ }
+    MTcpIpI(Int_t rx, UInt_t timeout=5000) : MThread(Form("MTcpIpI::%d", rx)), fRxSocket(0), fPortRx(rx), fTimeout(timeout), fConnectionEstablished(kFALSE) { /*RunThread();*/ }
     ~MTcpIpI() { CancelThread(); }
 
@@ -65 +69 @@
 };
 
-// This class es espcially meant to receive and send ascii messages
-class MTcpIpIO : public MTcpIpI, public MTcpIpO
+class MTcpIpCC : public MTcpIpI
 {
 private:
@@ -72 +75 @@
 
 public:
-    MTcpIpIO(const char *addr, Int_t tx, Int_t rx, UInt_t timeout=5000);
+    MTcpIpCC(Int_t rx, UInt_t timeout=5000);
 
     virtual bool InterpreteStr(TString str);
+};
+
+// This class es espcially meant to receive and send ascii messages
+class MTcpIpIO : public MTcpIpCC, public MTcpIpO
+{
+
+public:
+    MTcpIpIO(const char *addr, Int_t tx, Int_t rx, UInt_t timeout=5000);
 };
 
@@ -91 +102 @@
 };
 
+class MTcpIpFact : public MTcpIpCC
+{
+private:
+
+public:
+    MTcpIpFact(const char *dumm1, Int_t dummy2, Int_t rx, UInt_t timeout) : MTcpIpCC(rx, timeout)
+    {
+    }
+
+    bool Send(const char *msg, int len);
+};
+
+
 #endif