void wsrep::server_state::wait_until_state(

    wsrep::unique_lock<wsrep::mutex>& lock,

    enum wsrep::server_state::state state) const

{

    ++state_waiters_[state];

    while (state_ != state)

    {

        cond_.wait(lock);

        // If the waiter waits for any other state than disconnecting

        // or disconnected and the state has been changed to disconnecting,

        // this usually means that some error was encountered

        if (state != s_disconnecting && state != s_disconnected

            && state_ == s_disconnecting)

        {

            throw wsrep::runtime_error("State wait was interrupted");

        }

    }