Changeset 9432 for trunk/MagicSoft/Cosy/tcpip

Timestamp:

04/22/09 10:46:59 (16 years ago)

Author:

tbretz

Message:

*** empty log message ***

Location:

trunk/MagicSoft/Cosy/tcpip

Files:

• MCeCoCom.cc (modified) (1 diff)
• MCeCoCom.h (modified) (3 diffs)
• MTcpIpIO.cc (modified) (7 diffs)
• MTcpIpIO.h (modified) (1 diff)

trunk/MagicSoft/Cosy/tcpip/MCeCoCom.cc

@@ -133 +133 @@
 
     const TString msg =
-        MString::Format("%s "
+        MString::Format("%s M%d "
              "%02d %04d %02d %02d %02d %02d %02d %03d "
              "%02d %04d %02d %02d %02d %02d %02d %03d "
-             "%s\n", cmd,
+             "%s\n", cmd, fTelescope,
              fStatus,  y1, mon1, d1, h1, m1, s1, ms1,
              fComStat, y2, mon2, d2, h2, m2, s2, ms2,

trunk/MagicSoft/Cosy/tcpip/MCeCoCom.h

@@ -33 +33 @@
     int     fCCStatus;    // global status of CC
 
+    Byte_t  fTelescope;
+
     ComStatus_t fComStat; // communication status
 
@@ -49 +51 @@
 public:
     MCeCoCom(const char *addr, const int tx=7304, const int rx=7404, MLog *out=NULL)
-        : MTcpIpIO(addr, tx, rx), fOut(out), fStatus(0), fComStat(kNoCmdReceived),
+        : MTcpIpIO(addr, tx, rx), fOut(out), fStatus(0),
+        fTelescope(1), fComStat(kNoCmdReceived),
         fHumidity(0), fTemperature(0), fWindSpeed(0), fSolarRadiation(-1),
         fAlarmCounter(0)
@@ -60 +63 @@
     bool SendRep(const char *cmd, const char *str, bool force);
     void SetStatus(Byte_t s) { fStatus=s; }
+
+    void SetTelescope(Byte_t tel) { fTelescope = tel; }
 
     Float_t GetHumidity() const { return fHumidity; }

trunk/MagicSoft/Cosy/tcpip/MTcpIpIO.cc

@@ -15 +15 @@
 
 #undef DEBUG
+//#define DEBUG
 
 using namespace std;
@@ -40 +41 @@
      */
 
-MTcpIpO::MTcpIpO(const char *addr, Int_t tx)
-{
+MTcpIpO::MTcpIpO(const char *addr, Int_t tx) : fPortTx(tx)
+{
+    gLog << inf2 << "- Open send socket to " << addr << ":" << tx << endl;
     fTxSocket = new TSocket(addr, tx);
 }
@@ -147 +149 @@
 bool MTcpIpO::Send(const char *msg, Int_t len)
 {
+    if (!fTxSocket->IsValid())
+    {
+        const TInetAddress &a = fTxSocket->GetInetAddress();
+        if (!a.IsValid())
+            return false;
+#ifdef DEBUG
+        cout << "- Reopen send socket to " << a.GetHostAddress() << ":" << fPortTx << endl;
+#endif
+        delete fTxSocket;
+        fTxSocket = new TSocket(a.GetHostAddress(), fPortTx);
+    }
+
     return SendFrame(*fTxSocket, msg, len);
 }
@@ -206 +220 @@
     fConnectionEstablished = kTRUE;
 
-    MTimeout timeout;
+    MTimeout timeout(fTimeout);
 
     // Get connection on port fPortRx and redirected
@@ -228 +242 @@
             if (timeout.HasTimedOut())
             {
-                gLog << warn << MTime(-1) << " WARNING - Connection to " << MTcpIpO::GetSocketAddress(sock) << " timed out." << endl;
+                gLog << warn << MTime(-1) << " WARNING - Connection to " << MTcpIpO::GetSocketAddress(sock) << " timed out after " << fTimeout << "ms." << endl;
                 return kFALSE;
             }
@@ -285 +299 @@
             fConnectionEstablished = kFALSE;
 
+#ifdef DEBUG
+        cout << "===> DEL SOCKET" << endl;
+#endif
         delete socket;
     }
@@ -314 +331 @@
         }
 
+#ifdef DEBUG
+        cout << "===> DEL SERVER" << endl;
+#endif
         delete server;
 

trunk/MagicSoft/Cosy/tcpip/MTcpIpIO.h

@@ -44 +44 @@
     TSocket *fTxSocket;
 
+    Int_t fPortTx;
+
 public:
     MTcpIpO(const char *addr, Int_t tx);