Removing additional 0MQ dependency

[u/mrichter/AliRoot.git] / MONITOR / AliRecoServerThread.cxx

diff --git a/MONITOR/AliRecoServerThread.cxx b/MONITOR/AliRecoServerThread.cxx
index 551871e289854e7e0cb09bd8c8f128225411b13a..e490dc0721bbe77fef4f0c3a74717fccda7df1b4 100644 (file)
--- a/MONITOR/AliRecoServerThread.cxx
+++ b/MONITOR/AliRecoServerThread.cxx
@@ -6,6 +6,7 @@
  * full copyright notice.                                                 *
  **************************************************************************/
 
+#include <RVersion.h>
 #include <stdlib.h>
 
 #include <zmq.hpp>
@@ -108,10 +109,8 @@ void AliRecoServerThread::SendStreamerInfos(TMessage* mess, zmq::socket_t *sock)
          delete minilist;
          if (messinfo.GetStreamerInfos())
             messinfo.GetStreamerInfos()->Clear();
-           
-           messinfo.SetLength();
-           
-          int bufsize = messinfo.Length();
+          
+                                       int bufsize = messinfo.Length();
                char* buf = (char*) malloc(bufsize * sizeof(char));
           memcpy(buf, messinfo.Buffer(), bufsize);
 
@@ -136,8 +135,6 @@ void AliRecoServerThread::SendEvent(AliESDEvent* event, zmq::socket_t* socket)
   TMessage::EnableSchemaEvolutionForAll(kTRUE);
   SendStreamerInfos(&tmess, socket);
 
-  tmess.SetLength();
-
   int bufsize = tmess.Length();
   char* buf = (char*) malloc(bufsize * sizeof(char));
   memcpy(buf, tmess.Buffer(), bufsize);