浏览代码

Merge pull request #9057 from Michael-Gardner/HPCC-16194

HPCC-16194 SocketEndpointv4 added getUrlStr(StringBuffer &) to struct

Reviewed-By: Richard Chapman <rchapman@hpccsystems.com>
Richard Chapman 8 年之前
父节点
当前提交
a2d708abd3
共有 1 个文件被更改,包括 12 次插入4 次删除
  1. 12 4
      system/mp/mpcomm.cpp

+ 12 - 4
system/mp/mpcomm.cpp

@@ -103,6 +103,12 @@ struct SocketEndpointV4
         val.setNetAddress(sizeof(ip),&ip);
         val.setNetAddress(sizeof(ip),&ip);
         val.port = port;
         val.port = port;
     }
     }
+    StringBuffer & getUrlStr(StringBuffer &val)
+    {
+        SocketEndpoint s;
+        this->get(s);
+        return s.getUrlStr(val);
+    }
 };
 };
 
 
 class PacketHeader // standard packet header - no virtuals 
 class PacketHeader // standard packet header - no virtuals 
@@ -844,7 +850,7 @@ protected: friend class CMPPacketReader;
                                 e->Release();
                                 e->Release();
 
 
 #ifdef _TRACE
 #ifdef _TRACE
-                                LOG(MCdebugInfo(100), unknownJob, "MP: Retrying connection to %s, %d attempts left",remoteep.getUrlStr(str).toCharArray(),retrycount+1);
+                                LOG(MCdebugInfo(100), unknownJob, "MP: Retrying connection to %s, %d attempts left",remoteep.getUrlStr(str).str(),retrycount+1);
 #endif
 #endif
                         }
                         }
                         else
                         else
@@ -1070,7 +1076,7 @@ public:
                 return true;
                 return true;
         }
         }
         StringBuffer ep;
         StringBuffer ep;
-        remoteep.getUrlStr(ep);
+        remoteep.getUrlStr(ep); 
         loop {
         loop {
             CTimeMon pingtm(1000*60);
             CTimeMon pingtm(1000*60);
             if (sendPing(pingtm)) 
             if (sendPing(pingtm)) 
@@ -1927,8 +1933,10 @@ int CMPConnectThread::run()
 #ifdef _FULLTRACE       
 #ifdef _FULLTRACE       
             StringBuffer s;
             StringBuffer s;
             SocketEndpoint ep1;
             SocketEndpoint ep1;
-            sock->getPeerEndpoint(ep1);
-            PROGLOG("MP: Connect Thread: socket accepted from %s",ep1.getUrlStr(s).str());
+            if (sock) {
+                sock->getPeerEndpoint(ep1);
+                PROGLOG("MP: Connect Thread: socket accepted from %s",ep1.getUrlStr(s).str());
+            }
 #endif
 #endif
         }
         }
         catch (IException *e)
         catch (IException *e)