MXS-2314 Remove unnecessary worker states
The removed states were not used for anything useful.
This commit is contained in:
@ -298,10 +298,8 @@ public:
|
|||||||
enum state_t
|
enum state_t
|
||||||
{
|
{
|
||||||
STOPPED,
|
STOPPED,
|
||||||
IDLE,
|
|
||||||
POLLING,
|
POLLING,
|
||||||
PROCESSING,
|
PROCESSING,
|
||||||
ZPROCESSING
|
|
||||||
};
|
};
|
||||||
|
|
||||||
enum execute_mode_t
|
enum execute_mode_t
|
||||||
|
@ -535,7 +535,7 @@ void Worker::run(mxb::Semaphore* pSem)
|
|||||||
|
|
||||||
if (pre_run())
|
if (pre_run())
|
||||||
{
|
{
|
||||||
m_state = IDLE;
|
m_state = PROCESSING;
|
||||||
|
|
||||||
if (pSem)
|
if (pSem)
|
||||||
{
|
{
|
||||||
@ -886,8 +886,6 @@ void Worker::poll_waitevents()
|
|||||||
}
|
}
|
||||||
|
|
||||||
epoll_tick();
|
epoll_tick();
|
||||||
|
|
||||||
m_state = IDLE;
|
|
||||||
} /*< while(1) */
|
} /*< while(1) */
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -152,10 +152,6 @@ void dShowThreads(DCB* dcb)
|
|||||||
state = "Stopped";
|
state = "Stopped";
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case Worker::IDLE:
|
|
||||||
state = "Idle";
|
|
||||||
break;
|
|
||||||
|
|
||||||
case Worker::POLLING:
|
case Worker::POLLING:
|
||||||
state = "Polling";
|
state = "Polling";
|
||||||
break;
|
break;
|
||||||
@ -164,10 +160,6 @@ void dShowThreads(DCB* dcb)
|
|||||||
state = "Processing";
|
state = "Processing";
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case Worker::ZPROCESSING:
|
|
||||||
state = "Collecting";
|
|
||||||
break;
|
|
||||||
|
|
||||||
default:
|
default:
|
||||||
mxb_assert(!true);
|
mxb_assert(!true);
|
||||||
}
|
}
|
||||||
|
@ -625,8 +625,6 @@ void RoutingWorker::epoll_tick()
|
|||||||
{
|
{
|
||||||
dcb_process_idle_sessions(m_id);
|
dcb_process_idle_sessions(m_id);
|
||||||
|
|
||||||
m_state = ZPROCESSING;
|
|
||||||
|
|
||||||
delete_zombies();
|
delete_zombies();
|
||||||
|
|
||||||
check_systemd_watchdog();
|
check_systemd_watchdog();
|
||||||
|
Reference in New Issue
Block a user