libplumbing/reactor.h

Go to the documentation of this file.

//
// plumbing - C++ wrapper facades for Berkeley sockets
// Copyright (C) 2009 Peter Miller
//
// This program is free software; you can redistribute it and/or modify it
// under the terms of the GNU General Public License, version 3, as published
// by the Free Software Foundation.
//
// This program is distributed in the hope that it will be useful, but WITHOUT
// ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
// FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
// more details.
//
// You should have received a copy of the GNU General Public License along
// with this program. If not, see <http://www.gnu.org/licenses/>.
//

#ifndef LIBPLUMBING_REACTOR_H
#define LIBPLUMBING_REACTOR_H

#include <cstdarg>
#include <list>

#include <libplumbing/endpoint.h>
#include <libplumbing/format_printf.h>
#include <libplumbing/at/service.h>

namespace plumbing {

class endpoint_functor; // forward

class reactor
{
public:
    virtual ~reactor();

    reactor();

    void process(bool block = false);

    void
    run()
    {
        while (still_have_work_to_do())
            process(true);
    }

    void for_each_endpoint(endpoint_functor &func);

    void add_endpoint(const endpoint::pointer &ep);

    void
    register_at_job(const time_value &when, at_job *jp)
    {
        at.register_job(when, jp);
    }

    void
    register_at_job_delta(const time_value &when, at_job *jp)
    {
        at.register_job_delta(when, jp);
    }

    void
    unregister_at_job(at_job *jp)
    {
        at.unregister_job(jp);
    }

    bool still_have_work_to_do() const { return !endpoints.empty(); }

private:
    typedef std::list<endpoint::pointer> endpoints_t;

    endpoints_t endpoints;

    at_service at;

    void fatal_error(const char *fmt, ...)
                                                            FORMAT_PRINTF(2, 3);
    void fatal_error_v(const char *fmt, va_list ap)
                                                            FORMAT_PRINTF(2, 0);

    void kill_suicidal_endpoints();

    reactor(const reactor &);

    reactor &operator=(const reactor &);
};

}

#endif // LIBPLUMBING_REACTOR_H
// vim: set ts=8 sw=4 et

---