void ReportCallback(int fd, short event, void *arg);
void EndCallback(int fd, short event, void *arg);
void RescanDirCallback(int fd, short event, void *arg);
void ReportCallback(int fd, short event, void *arg);
void EndCallback(int fd, short event, void *arg);
void RescanDirCallback(int fd, short event, void *arg);
// Enter mainloop, if daemonizing
if (wait_time == TINT_NEVER || (long)wait_time > 0) {
// Arno: always, for statsgw, rate control, etc.
// Enter mainloop, if daemonizing
if (wait_time == TINT_NEVER || (long)wait_time > 0) {
// Arno: always, for statsgw, rate control, etc.
IsComplete(single_fd ) ? "DONE" : "done",
Complete(single_fd), Size(single_fd), SeqComplete(single_fd),
Channel::global_dgrams_up, Channel::global_raw_bytes_up,
IsComplete(single_fd ) ? "DONE" : "done",
Complete(single_fd), Size(single_fd), SeqComplete(single_fd),
Channel::global_dgrams_up, Channel::global_raw_bytes_up,
- Channel::global_dgrams_down, Channel::global_raw_bytes_down );
+ Channel::global_dgrams_down, Channel::global_raw_bytes_down,
+ Channel::global_buffers_up, Channel::global_syscalls_up,
+ Channel::global_buffers_down, Channel::global_syscalls_down);
+void TimerCallback(int fd, short event, void *arg) {
+ Channel::messageQueue.Flush();
+ evtimer_add(&evtimer, tint2tv(TIMER_USEC));
+}
+
void EndCallback(int fd, short event, void *arg) {
// Called when wait timer expires == fixed time daemon
event_base_loopexit(Channel::evbase, NULL);
void EndCallback(int fd, short event, void *arg) {
// Called when wait timer expires == fixed time daemon
event_base_loopexit(Channel::evbase, NULL);