mahimahi/event_loop.hh at pythonservers · talalahmad/mahimahi

Repository navigation

/* -*-mode:c++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */

#ifndef EVENT_LOOP_HH

#define EVENT_LOOP_HH

#include <functional>

#include <utility>

#include <list>

#include "poller.hh"

#include "file_descriptor.hh"

#include "signalfd.hh"

#include "child_process.hh"

#include "util.hh"

class EventLoop

{

private:

SignalMask signals_;

Poller poller_;

std::list<std::pair<ChildProcess, bool>> child_processes_;

PollerShortNames::Result handle_signal( const signalfd_siginfo & sig );

protected:

void add_action( Poller::Action action ) { poller_.add_action( action ); }

int internal_loop( const std::function<int(void)> & wait_time );

public:

EventLoop();

void add_simple_input_handler( FileDescriptor & fd, const Poller::Action::CallbackType & callback );

void add_child_process( ChildProcess && child_process, bool exit_when_terminated = true )

{

child_processes_.emplace_back( std::make_pair( std::move( child_process ), exit_when_terminated ) );

}

int loop( void ) { return internal_loop( [] () { return -1; } ); } /* no timeout */

virtual ~EventLoop() {}

};

#endif /* EVENT_LOOP_HH */