reactor.hpp

Go to the documentation of this file.

/*
 * This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/.
 *
 * This file is part of zmqpp.
 * Copyright (c) 2011-2015 Contributors as noted in the AUTHORS file.
 */

#pragma once

#include <unordered_map>
#include <vector>
#include <map>
#include <functional>

#include "compatibility.hpp"
#include "poller.hpp"

namespace zmqpp
{

    class socket;
    typedef socket socket_t;

    class reactor
    {
    public:
        typedef std::function<void (void) > Callable;
        typedef std::pair<zmq_pollitem_t, Callable> PollItemCallablePair;
        reactor();

        ~reactor();
    
        void add(socket_t& socket, Callable callable, short const event = poller::poll_in);

        void add(raw_socket_t const descriptor, Callable callable, short const event = poller::poll_in | poller::poll_error);

        bool has(socket_t const& socket);

        bool has(raw_socket_t const descriptor);

        void remove(socket_t const& socket);

        void remove(raw_socket_t const descriptor);

        void check_for(socket_t const& socket, short const event);

        void check_for(raw_socket_t const descriptor, short const event);

        bool poll(long timeout = poller::wait_forever);

        short events(socket_t const& socket) const;

        short events(raw_socket_t const descriptor) const;


        poller &get_poller();

        const poller &get_poller() const;

    protected:
        void add(const zmq_pollitem_t &item, Callable callable);

    private:
        std::vector<PollItemCallablePair> items_;
        std::vector<const socket_t *> sockRemoveLater_;
        std::vector<raw_socket_t> fdRemoveLater_;
      
      void flush_remove_later();

      poller poller_;
      bool dispatching_;
    };

}