Fix bug introduced, attempted an optimisation not very successfully

parent f7f01ba6
...@@ -1376,19 +1376,16 @@ void PollGuard::wait_for_input(int wait_time) ...@@ -1376,19 +1376,16 @@ void PollGuard::wait_for_input(int wait_time)
receiving data we will check if all data is received, if not we receiving data we will check if all data is received, if not we
poll again. poll again.
*/ */
if (t_poll_owner)
{
#ifdef NDB_SHM_TRANSPORTER #ifdef NDB_SHM_TRANSPORTER
/* /*
If shared memory transporters are used we need to set our sigmask If shared memory transporters are used we need to set our sigmask
such that we wake up also on interrupts on the shared memory such that we wake up also on interrupts on the shared memory
interrupt signal. interrupt signal.
*/ */
NdbThread_set_shm_sigmask(FALSE); NdbThread_set_shm_sigmask(FALSE);
#endif #endif
m_tp->set_poll_owner(m_waiter); m_tp->set_poll_owner(m_waiter);
m_waiter->set_poll_owner(true); m_waiter->set_poll_owner(true);
}
m_tp->external_poll((Uint32)wait_time); m_tp->external_poll((Uint32)wait_time);
} }
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment