/usr/include/measurement_kit/common/reactor.hpp is in libmeasurement-kit-dev 0.7.1-2build1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 | // Part of measurement-kit <https://measurement-kit.github.io/>.
// Measurement-kit is free software. See AUTHORS and LICENSE for more
// information on the copying conditions.
#ifndef MEASUREMENT_KIT_COMMON_REACTOR_HPP
#define MEASUREMENT_KIT_COMMON_REACTOR_HPP
#include <measurement_kit/common/callback.hpp>
#include <measurement_kit/common/error.hpp>
#include <measurement_kit/common/socket.hpp>
#include <measurement_kit/common/var.hpp>
// Deprecated since v0.4.x
struct event_base;
#define MK_POLLIN 1 << 0
#define MK_POLLOUT 1 << 1
namespace mk {
class Reactor {
public:
static Var<Reactor> make();
static Var<Reactor> global();
virtual ~Reactor();
virtual void call_soon(Callback<> &&cb) = 0;
virtual void call_later(double, Callback<> &&cb) = 0;
// Backward compatibility names
void loop_with_initial_event(Callback<> &&cb) {
run_with_initial_event(std::move(cb));
}
void loop() { run(); }
void break_loop() { stop(); }
/*
POSIX API for dealing with sockets. Slower than APIs in net,
especially under Windows, but suitable to integrate with other
async libraries such as c-ares and perhaps others.
*/
virtual void pollfd(
socket_t sockfd,
short events,
double timeout,
Callback<Error, short> &&callback
) = 0;
// Backward compatibility API
void pollfd(socket_t sockfd, short events, Callback<Error, short> &&cb,
double timeout = -1.0) {
pollfd(sockfd, events, timeout, std::move(cb));
}
// Deprecated since v0.4.x
virtual event_base *get_event_base() = 0;
void run_with_initial_event(Callback<> &&cb);
virtual void run() = 0;
virtual void stop() = 0;
};
void call_soon(Callback<> &&, Var<Reactor> = Reactor::global());
void call_later(double, Callback<> &&, Var<Reactor> = Reactor::global());
void loop_with_initial_event(Callback<> &&, Var<Reactor> = Reactor::global());
void loop(Var<Reactor> = Reactor::global());
void break_loop(Var<Reactor> = Reactor::global());
// Introduced as aliases in v0.4.x
inline void run_with_initial_event(Callback<> &&callback,
Var<Reactor> reactor = Reactor::global()) {
loop_with_initial_event(std::move(callback), reactor);
}
inline void run(Var<Reactor> reactor = Reactor::global()) {
loop(reactor);
}
inline void stop(Var<Reactor> reactor = Reactor::global()) {
break_loop(reactor);
}
} // namespace mk
#endif
|