version check to allow compilation with older fairmq version

Author: rbx

devices/flp2epn-distributed/run/runEPN_distributed.cxx

@@ -219,8 +219,11 @@ int main(int argc, char** argv)
   try {
     epn.ChangeState(EPNex::SETOUTPUT);
     epn.ChangeState(EPNex::SETINPUT);
+// temporary check to allow compilation with older fairmq version
+#ifdef FAIRMQ_INTERFACE_VERSION
     epn.ChangeState(EPNex::BIND);
     epn.ChangeState(EPNex::CONNECT);
+#endif
     epn.ChangeState(EPNex::RUN);
   } catch (const exception& e) {
       LOG(ERROR) << e.what();

devices/flp2epn-distributed/run/runFLPSampler.cxx

@@ -190,8 +190,11 @@ int main(int argc, char** argv)
   try {
     sampler.ChangeState(FLPexSampler::SETOUTPUT);
     sampler.ChangeState(FLPexSampler::SETINPUT);
+// temporary check to allow compilation with older fairmq version
+#ifdef FAIRMQ_INTERFACE_VERSION
     sampler.ChangeState(FLPexSampler::BIND);
     sampler.ChangeState(FLPexSampler::CONNECT);
+#endif
     sampler.ChangeState(FLPexSampler::RUN);
   } catch (const exception& e) {
       LOG(ERROR) << e.what();

devices/flp2epn-distributed/run/runFLP_distributed.cxx

@@ -227,8 +227,11 @@ int main(int argc, char** argv)
   try {
     flp.ChangeState(FLPex::SETOUTPUT);
     flp.ChangeState(FLPex::SETINPUT);
+// temporary check to allow compilation with older fairmq version
+#ifdef FAIRMQ_INTERFACE_VERSION
     flp.ChangeState(FLPex::BIND);
     flp.ChangeState(FLPex::CONNECT);
+#endif
     flp.ChangeState(FLPex::RUN);
   } catch (const exception& e) {
       LOG(ERROR) << e.what();

devices/flp2epn-dynamic/run/runEPN_dynamic.cxx

@@ -182,8 +182,11 @@ int main(int argc, char** argv)
 
     epn.ChangeState(O2EPNex::SETOUTPUT);
     epn.ChangeState(O2EPNex::SETINPUT);
+// temporary check to allow compilation with older fairmq version
+#ifdef FAIRMQ_INTERFACE_VERSION
     epn.ChangeState(O2EPNex::BIND);
     epn.ChangeState(O2EPNex::CONNECT);
+#endif
     epn.ChangeState(O2EPNex::RUN);
 
     // wait until the running thread has finished processing.

devices/flp2epn-dynamic/run/runFLP_dynamic.cxx

@@ -188,8 +188,11 @@ int main(int argc, char** argv)
 
     flp.ChangeState(O2FLPex::SETOUTPUT);
     flp.ChangeState(O2FLPex::SETINPUT);
+// temporary check to allow compilation with older fairmq version
+#ifdef FAIRMQ_INTERFACE_VERSION
     flp.ChangeState(O2FLPex::BIND);
     flp.ChangeState(O2FLPex::CONNECT);
+#endif
     flp.ChangeState(O2FLPex::RUN);
 
     // wait until the running thread has finished processing.

devices/flp2epn/run/runEPN.cxx

@@ -143,8 +143,11 @@ int main(int argc, char** argv)
 
     epn.ChangeState(O2EPNex::SETOUTPUT);
     epn.ChangeState(O2EPNex::SETINPUT);
+// temporary check to allow compilation with older fairmq version
+#ifdef FAIRMQ_INTERFACE_VERSION
     epn.ChangeState(O2EPNex::BIND);
     epn.ChangeState(O2EPNex::CONNECT);
+#endif
     epn.ChangeState(O2EPNex::RUN);
 
     // wait until the running thread has finished processing.

devices/flp2epn/run/runEPN_M.cxx

@@ -143,8 +143,11 @@ int main(int argc, char** argv)
 
     epn.ChangeState(O2EpnMerger::SETOUTPUT);
     epn.ChangeState(O2EpnMerger::SETINPUT);
+// temporary check to allow compilation with older fairmq version
+#ifdef FAIRMQ_INTERFACE_VERSION
     epn.ChangeState(O2EpnMerger::BIND);
     epn.ChangeState(O2EpnMerger::CONNECT);
+#endif
     epn.ChangeState(O2EpnMerger::RUN);
 
     // wait until the running thread has finished processing.

devices/flp2epn/run/runFLP.cxx

@@ -149,8 +149,11 @@ int main(int argc, char** argv)
 
     flp.ChangeState(O2FLPex::SETOUTPUT);
     flp.ChangeState(O2FLPex::SETINPUT);
+// temporary check to allow compilation with older fairmq version
+#ifdef FAIRMQ_INTERFACE_VERSION
     flp.ChangeState(O2FLPex::BIND);
     flp.ChangeState(O2FLPex::CONNECT);
+#endif
     flp.ChangeState(O2FLPex::RUN);
 
     // wait until the running thread has finished processing.

devices/flp2epn/run/runMerger.cxx

@@ -176,8 +176,11 @@ int main(int argc, char** argv)
 
     merger.ChangeState(O2Merger::SETOUTPUT);
     merger.ChangeState(O2Merger::SETINPUT);
+// temporary check to allow compilation with older fairmq version
+#ifdef FAIRMQ_INTERFACE_VERSION
     merger.ChangeState(O2Merger::BIND);
     merger.ChangeState(O2Merger::CONNECT);
+#endif
     merger.ChangeState(O2Merger::RUN);
 
     // wait until the running thread has finished processing.

devices/flp2epn/run/runProxy.cxx

@@ -168,8 +168,11 @@ int main(int argc, char** argv)
 
     proxy.ChangeState(O2Proxy::SETOUTPUT);
     proxy.ChangeState(O2Proxy::SETINPUT);
+// temporary check to allow compilation with older fairmq version
+#ifdef FAIRMQ_INTERFACE_VERSION
     proxy.ChangeState(O2Proxy::BIND);
     proxy.ChangeState(O2Proxy::CONNECT);
+#endif
     proxy.ChangeState(O2Proxy::RUN);