diff options
Diffstat (limited to 'fluent-bit/lib/monkey/include/monkey/mk_core/mk_event_select.h')
| -rw-r--r-- | fluent-bit/lib/monkey/include/monkey/mk_core/mk_event_select.h | 59 |
1 files changed, 59 insertions, 0 deletions
diff --git a/fluent-bit/lib/monkey/include/monkey/mk_core/mk_event_select.h b/fluent-bit/lib/monkey/include/monkey/mk_core/mk_event_select.h new file mode 100644 index 000000000..b69c0ba38 --- /dev/null +++ b/fluent-bit/lib/monkey/include/monkey/mk_core/mk_event_select.h @@ -0,0 +1,59 @@ +/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ + +/* Monkey HTTP Server + * ================== + * Copyright 2001-2017 Eduardo Silva <eduardo@monkey.io> + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef MK_EVENT_SELECT_H +#define MK_EVENT_SELECT_H + +#ifdef _WIN32 +#include <Winsock2.h> +#else +#include <sys/select.h> +#endif + +struct mk_event_ctx { + int max_fd; + + /* Original set of file descriptors */ + fd_set rfds; + fd_set wfds; + + /* Populated before every select(2) */ + fd_set _rfds; + fd_set _wfds; + + int queue_size; + struct mk_event **events; /* full array to register all events */ + struct mk_event *fired; /* used to create iteration array */ +}; + +#define mk_event_foreach(event, evl) \ + int __i; \ + struct mk_event_ctx *__ctx = evl->data; \ + \ + if (evl->n_events > 0) { \ + event = __ctx->fired[0].data; \ + } \ + \ + for (__i = 0; \ + __i < evl->n_events; \ + __i++, \ + event = ((__i < evl->n_events) ? __ctx->fired[__i].data : NULL) \ + ) + +#endif |