Changeset 8816 for trunk/MagicSoft/Cosy/tcpip/MTcpIpIO.h

Timestamp:

01/16/08 14:34:11 (17 years ago)

Author:

tbretz

Message:

*** empty log message ***

File:

• trunk/MagicSoft/Cosy/tcpip/MTcpIpIO.h (modified) (2 diffs)

trunk/MagicSoft/Cosy/tcpip/MTcpIpIO.h

@@ -2 +2 @@
 #define COSY_MTcpIpIO
 
-#ifndef COSY_MThread
+#ifndef MARS_MThread
 #include "MThread.h"
-#endif
-#ifndef COSY_Log
-#include "log.h"
 #endif
 #ifndef MARS_MTime
@@ -12 +9 @@
 #endif
 
+
 class TString;
 class TSocket;
 class TServerSocket;
 
-class MTcpIpIO : public MThread, public Log
+// A generalized class for receiving over tcp/ip
+class MTcpIpI : public MyThreadX
 {
 private:
-    TSocket       *fTxSocket;
-    TSocket       *fRxSocket;
-    TServerSocket *fServSock;
+    Int_t fPortRx;
 
-    MTime fTime;
-    Int_t fSendInterval; // [ms]
+    Int_t Thread();
 
-    void Clear();
+    virtual void ReadSocket(TSocket &rx) = 0;
 
 public:
-    MTcpIpIO(MLog &out=gLog);
+    MTcpIpI(Int_t rx) : MyThreadX(Form("MTcpIpI::%d", rx)), fPortRx(rx) { /*RunThread();*/ }
+    ~MTcpIpI() { CancelThread(); }
+};
+
+
+// A generalized class for sending over tcp/ip
+class MTcpIpO
+{
+private:
+    TSocket *fTxSocket;
+
+public:
+    MTcpIpO(Int_t tx);
+    ~MTcpIpO();
+
+    static bool SendFrame(TSocket &tx, const char *msg, int len);
+    static bool SendFrame(const char *addr, int port, const char *msg, int len);
+
+    bool Send(const char *msg, int len);
+};
+
+// This class es espcially meant to receive and send ascii messages
+class MTcpIpIO : public MTcpIpI, public MTcpIpO
+{
+private:
+    void ReadSocket(TSocket &rx);
+
+public:
+    MTcpIpIO(Int_t tx, Int_t rx);
     ~MTcpIpIO();
 
-    virtual bool Send(const char *msg, bool force);
     virtual bool InterpreteStr(TString str);
-
-    void *Thread();
 };