diff --git a/fairmq/FairMQDevice.cxx b/fairmq/FairMQDevice.cxx index bba62ab9..1cf08a8c 100644 --- a/fairmq/FairMQDevice.cxx +++ b/fairmq/FairMQDevice.cxx @@ -280,7 +280,7 @@ bool FairMQDevice::AttachChannel(FairMQChannel& ch) } catch (fair::mq::SocketError& se) { - LOG(ERROR) << se.what(); + LOG(error) << se.what(); return false; } } @@ -823,7 +823,7 @@ void FairMQDevice::CreateOwnConfig() try { fDefaultTransportType = fair::mq::TransportTypes.at(fConfig->GetValue("transport")); } catch(const exception& e) { - LOG(ERROR) << "invalid transport type provided: " << fConfig->GetValue("transport"); + LOG(error) << "invalid transport type provided: " << fConfig->GetValue("transport"); } } @@ -867,7 +867,7 @@ void FairMQDevice::SetConfig(FairMQProgOptions& config) try { fDefaultTransportType = fair::mq::TransportTypes.at(fConfig->GetValue("transport")); } catch(const exception& e) { - LOG(ERROR) << "invalid transport type provided: " << fConfig->GetValue("transport"); + LOG(error) << "invalid transport type provided: " << fConfig->GetValue("transport"); } SetTransport(fConfig->GetValue("transport")); } diff --git a/fairmq/options/FairMQProgOptions.cxx b/fairmq/options/FairMQProgOptions.cxx index 3715ceb8..932defb3 100644 --- a/fairmq/options/FairMQProgOptions.cxx +++ b/fairmq/options/FairMQProgOptions.cxx @@ -413,7 +413,7 @@ int FairMQProgOptions::PrintOptions() for (const auto& o : fUnregisteredOptions) { - LOG(WARN) << "detected unregistered option: " << o; + LOG(debug) << "detected unregistered option: " << o; } stringstream ss; diff --git a/fairmq/plugins/DDS/DDS.cxx b/fairmq/plugins/DDS/DDS.cxx index 6f75621c..86b8aae3 100644 --- a/fairmq/plugins/DDS/DDS.cxx +++ b/fairmq/plugins/DDS/DDS.cxx @@ -110,12 +110,12 @@ auto DDS::HandleControl() -> void // and propagate addresses of bound channels to DDS. FillChannelContainers(); - LOG(DEBUG) << "$DDS_TASK_PATH: " << getenv("DDS_TASK_PATH"); - LOG(DEBUG) << "$DDS_GROUP_NAME: " << getenv("DDS_GROUP_NAME"); - LOG(DEBUG) << "$DDS_COLLECTION_NAME: " << getenv("DDS_COLLECTION_NAME"); - LOG(DEBUG) << "$DDS_TASK_NAME: " << getenv("DDS_TASK_NAME"); - LOG(DEBUG) << "$DDS_TASK_INDEX: " << getenv("DDS_TASK_INDEX"); - LOG(DEBUG) << "$DDS_COLLECTION_INDEX: " << getenv("DDS_COLLECTION_INDEX"); + LOG(debug) << "$DDS_TASK_PATH: " << getenv("DDS_TASK_PATH"); + LOG(debug) << "$DDS_GROUP_NAME: " << getenv("DDS_GROUP_NAME"); + LOG(debug) << "$DDS_COLLECTION_NAME: " << getenv("DDS_COLLECTION_NAME"); + LOG(debug) << "$DDS_TASK_NAME: " << getenv("DDS_TASK_NAME"); + LOG(debug) << "$DDS_TASK_INDEX: " << getenv("DDS_TASK_INDEX"); + LOG(debug) << "$DDS_COLLECTION_INDEX: " << getenv("DDS_COLLECTION_INDEX"); // start DDS service - subscriptions will only start firing after this step fService.start(); diff --git a/fairmq/shmem/FairMQSocketSHM.cxx b/fairmq/shmem/FairMQSocketSHM.cxx index fd7d449d..d164b2e8 100644 --- a/fairmq/shmem/FairMQSocketSHM.cxx +++ b/fairmq/shmem/FairMQSocketSHM.cxx @@ -196,7 +196,7 @@ int FairMQSocketSHM::ReceiveImpl(FairMQMessagePtr& msg, const int flags, const i const auto numMsgs = nbytes / sizeof(MetaHeader); if (numMsgs > 1) { - LOG(ERROR) << "Receiving SHM multipart with a single message receive call"; + LOG(error) << "Receiving SHM multipart with a single message receive call"; } assert (numMsgs == 1); @@ -311,13 +311,13 @@ int64_t FairMQSocketSHM::SendImpl(vector& msgVec, const int fl else if (zmq_errno() == ETERM) { zmq_msg_close (&lZmqMsg); - LOG(INFO) << "terminating socket " << fId; + LOG(info) << "terminating socket " << fId; return -1; } else { zmq_msg_close (&lZmqMsg); - LOG(ERROR) << "Failed sending on socket " << fId << ", reason: " << zmq_strerror(errno); + LOG(error) << "Failed sending on socket " << fId << ", reason: " << zmq_strerror(errno); return nbytes; } }