12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697 |
- /*
- * Copyright 2024 Vsevolod Stakhov
- *
- * 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 RSPAMD_LIBEV_HELPER_H
- #define RSPAMD_LIBEV_HELPER_H
-
- #include "config.h"
- #include "contrib/libev/ev.h"
-
-
- #ifdef __cplusplus
- extern "C" {
- #endif
-
- /*
- * This module is a little helper to simplify libevent->libev transition
- * It allows to create timed IO watchers utilising both
- */
-
- typedef void (*rspamd_ev_cb)(int fd, short what, void *ud);
-
- struct rspamd_io_ev {
- ev_io io;
- ev_timer tm;
- rspamd_ev_cb cb;
- void *ud;
- ev_tstamp timeout;
- };
-
- /**
- * Initialize watcher similar to event_init
- * @param ev
- * @param fd
- * @param what
- * @param cb
- * @param ud
- */
- void rspamd_ev_watcher_init(struct rspamd_io_ev *ev,
- int fd, short what, rspamd_ev_cb cb, void *ud);
-
- /**
- * Start watcher with the specific timeout
- * @param loop
- * @param ev
- * @param timeout
- */
- void rspamd_ev_watcher_start(struct ev_loop *loop,
- struct rspamd_io_ev *ev,
- ev_tstamp timeout);
-
- /**
- * Stops watcher and clean it up
- * @param loop
- * @param ev
- */
- void rspamd_ev_watcher_stop(struct ev_loop *loop,
- struct rspamd_io_ev *ev);
-
- /**
- * Convenience function to reschedule watcher with different events
- * @param loop
- * @param ev
- * @param what
- */
- void rspamd_ev_watcher_reschedule(struct ev_loop *loop,
- struct rspamd_io_ev *ev,
- short what);
-
- /**
- * Convenience function to reschedule watcher with different events and different timeout
- * @param loop
- * @param ev
- * @param what
- */
- void rspamd_ev_watcher_reschedule_at(struct ev_loop *loop,
- struct rspamd_io_ev *ev,
- short what,
- ev_tstamp at);
-
- #ifdef __cplusplus
- }
- #endif
-
- #endif
|