network_condition_variable.h

#pragma once

#include <memory>
#include <vector>
#include <mutex>

namespace uicore
{
    class SocketHandle;
    class NetworkConditionVariableImpl;

    class NetworkEvent
    {
    protected:
        virtual SocketHandle *socket_handle() = 0;

        friend class NetworkConditionVariable;
    };

    class NetworkConditionVariable
    {
    public:
        NetworkConditionVariable();

        template<typename Lock>
        bool wait(Lock &lock, int count, NetworkEvent **events, int timeout = -1)
        {
            lock.unlock();
            try
            {
                bool result = wait_impl(count, events, timeout);
                lock.lock();
                return result;
            }
            catch (...)
            {
                lock.lock();
                throw;
            }
        }

        void notify();

    private:
        bool wait_impl(int count, NetworkEvent **events, int timeout);

        std::shared_ptr<NetworkConditionVariableImpl> impl;
    };
}