Skip to content

Commit

Permalink
iox-eclipse-iceoryx#171 rename to MQThreadStart
Browse files Browse the repository at this point in the history
Signed-off-by: Kroenke Dietrich (CC-AD/ESW1) <[email protected]>
  • Loading branch information
dkroenke committed Jul 7, 2020
1 parent 60f3726 commit 5ef3f0c
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,8 @@ class RouDiMultiProcess

// indicate whether the message queue thread will start directly or deferred
// this is important for derived classes which may need to initialize their members before the thread starts
enum class MQThreadMode {
START,
enum class MQThreadStart {
IMMEDIATE,
DEFER_START
};

Expand All @@ -57,7 +57,7 @@ class RouDiMultiProcess
PortManager& portManager,
const MonitoringMode f_monitoringMode = MonitoringMode::ON,
const bool f_killProcessesInDestructor = true,
const MQThreadMode mqThreadMode = MQThreadMode::START);
const MQThreadStart mqThreadStart = MQThreadStart::IMMEDIATE);

virtual ~RouDiMultiProcess();

Expand Down
4 changes: 2 additions & 2 deletions iceoryx_posh/source/roudi/roudi_multi_process.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ RouDiMultiProcess::RouDiMultiProcess(RouDiMemoryInterface& roudiMemoryInterface,
PortManager& portManager,
const MonitoringMode monitoringMode,
const bool killProcessesInDestructor,
const MQThreadMode mqThreadMode)
const MQThreadStart mqThreadStart)
: m_killProcessesInDestructor(killProcessesInDestructor)
, m_runThreads(true)
, m_roudiMemoryInterface(&roudiMemoryInterface)
Expand All @@ -55,7 +55,7 @@ RouDiMultiProcess::RouDiMultiProcess(RouDiMemoryInterface& roudiMemoryInterface,
m_processManagementThread = std::thread(&RouDiMultiProcess::processThread, this);
pthread_setname_np(m_processManagementThread.native_handle(), "ProcessMgmt");

if(mqThreadMode == MQThreadMode::START) {
if(mqThreadStart == MQThreadStart::IMMEDIATE) {
startMQThread();
}

Expand Down

0 comments on commit 5ef3f0c

Please sign in to comment.