diff --git a/fairmq/FairMQDevice.cxx b/fairmq/FairMQDevice.cxx index 2eec24a9..955b9012 100644 --- a/fairmq/FairMQDevice.cxx +++ b/fairmq/FairMQDevice.cxx @@ -47,7 +47,9 @@ static void CallSignalHandler(int signal) FairMQDevice::FairMQDevice() : fChannels() + , fConfig(nullptr) , fId() + , fNetworkInterface() , fMaxInitializationAttempts(120) , fNumIoThreads(1) , fPortRangeMin(22000) @@ -55,8 +57,6 @@ FairMQDevice::FairMQDevice() , fLogIntervalInMs(1000) , fCmdSocket(nullptr) , fTransportFactory(nullptr) - , fConfig(nullptr) - , fNetworkInterface() , fInitialValidationFinished(false) , fInitialValidationCondition() , fInitialValidationMutex() diff --git a/fairmq/nanomsg/FairMQSocketNN.cxx b/fairmq/nanomsg/FairMQSocketNN.cxx index 77957cd6..86bff39c 100644 --- a/fairmq/nanomsg/FairMQSocketNN.cxx +++ b/fairmq/nanomsg/FairMQSocketNN.cxx @@ -191,7 +191,7 @@ int64_t FairMQSocketNN::Send(const vector>& msgVec, co LOG(ERROR) << "Failed sending on socket " << fId << ", reason: " << nn_strerror(errno); return nbytes; #else /*MSGPACK_FOUND*/ - LOG(ERROR) << "Cannot use nanomsg multipart because MessagePack was not found."; + LOG(ERROR) << "Cannot send message from vector of size " << msgVec.size() << " and flags " << flags << " with nanomsg multipart because MessagePack is not available."; exit(EXIT_FAILURE); #endif /*MSGPACK_FOUND*/ } @@ -303,7 +303,7 @@ int64_t FairMQSocketNN::Receive(vector>& msgVec, const LOG(ERROR) << "Failed receiving on socket " << fId << ", reason: " << nn_strerror(errno); return nbytes; #else /*MSGPACK_FOUND*/ - LOG(ERROR) << "Cannot use nanomsg multipart because MessagePack was not found."; + LOG(ERROR) << "Cannot receive message into vector of size " << msgVec.size() << " and flags " << flags << " with nanomsg multipart because MessagePack is not available."; exit(EXIT_FAILURE); #endif /*MSGPACK_FOUND*/ } diff --git a/fairmq/options/FairProgOptions.cxx b/fairmq/options/FairProgOptions.cxx index 8129f9d6..46a84cbf 100644 --- a/fairmq/options/FairProgOptions.cxx +++ b/fairmq/options/FairProgOptions.cxx @@ -158,7 +158,7 @@ int FairProgOptions::ParseCfgFile(ifstream& ifs, const po::options_description& } else { - po:store(parse_config_file(ifs, desc, allowUnregistered), varmap); + po::store(parse_config_file(ifs, desc, allowUnregistered), varmap); po::notify(varmap); } return 0; @@ -174,7 +174,7 @@ int FairProgOptions::ParseCfgFile(const string& filename, const po::options_desc } else { - po:store(parse_config_file(ifs, desc, allowUnregistered), varmap); + po::store(parse_config_file(ifs, desc, allowUnregistered), varmap); po::notify(varmap); } return 0;