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

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.h (modified) (5 diffs)

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