139beb93cSSam Leffler /* 239beb93cSSam Leffler * Event loop 339beb93cSSam Leffler * Copyright (c) 2002-2006, Jouni Malinen <j@w1.fi> 439beb93cSSam Leffler * 539beb93cSSam Leffler * This program is free software; you can redistribute it and/or modify 639beb93cSSam Leffler * it under the terms of the GNU General Public License version 2 as 739beb93cSSam Leffler * published by the Free Software Foundation. 839beb93cSSam Leffler * 939beb93cSSam Leffler * Alternatively, this software may be distributed under the terms of BSD 1039beb93cSSam Leffler * license. 1139beb93cSSam Leffler * 1239beb93cSSam Leffler * See README and COPYING for more details. 1339beb93cSSam Leffler * 1439beb93cSSam Leffler * This file defines an event loop interface that supports processing events 1539beb93cSSam Leffler * from registered timeouts (i.e., do something after N seconds), sockets 1639beb93cSSam Leffler * (e.g., a new packet available for reading), and signals. eloop.c is an 1739beb93cSSam Leffler * implementation of this interface using select() and sockets. This is 1839beb93cSSam Leffler * suitable for most UNIX/POSIX systems. When porting to other operating 1939beb93cSSam Leffler * systems, it may be necessary to replace that implementation with OS specific 2039beb93cSSam Leffler * mechanisms. 2139beb93cSSam Leffler */ 2239beb93cSSam Leffler 2339beb93cSSam Leffler #ifndef ELOOP_H 2439beb93cSSam Leffler #define ELOOP_H 2539beb93cSSam Leffler 2639beb93cSSam Leffler /** 2739beb93cSSam Leffler * ELOOP_ALL_CTX - eloop_cancel_timeout() magic number to match all timeouts 2839beb93cSSam Leffler */ 2939beb93cSSam Leffler #define ELOOP_ALL_CTX (void *) -1 3039beb93cSSam Leffler 3139beb93cSSam Leffler /** 3239beb93cSSam Leffler * eloop_event_type - eloop socket event type for eloop_register_sock() 3339beb93cSSam Leffler * @EVENT_TYPE_READ: Socket has data available for reading 3439beb93cSSam Leffler * @EVENT_TYPE_WRITE: Socket has room for new data to be written 3539beb93cSSam Leffler * @EVENT_TYPE_EXCEPTION: An exception has been reported 3639beb93cSSam Leffler */ 3739beb93cSSam Leffler typedef enum { 3839beb93cSSam Leffler EVENT_TYPE_READ = 0, 3939beb93cSSam Leffler EVENT_TYPE_WRITE, 4039beb93cSSam Leffler EVENT_TYPE_EXCEPTION 4139beb93cSSam Leffler } eloop_event_type; 4239beb93cSSam Leffler 4339beb93cSSam Leffler /** 4439beb93cSSam Leffler * eloop_sock_handler - eloop socket event callback type 4539beb93cSSam Leffler * @sock: File descriptor number for the socket 4639beb93cSSam Leffler * @eloop_ctx: Registered callback context data (eloop_data) 4739beb93cSSam Leffler * @sock_ctx: Registered callback context data (user_data) 4839beb93cSSam Leffler */ 4939beb93cSSam Leffler typedef void (*eloop_sock_handler)(int sock, void *eloop_ctx, void *sock_ctx); 5039beb93cSSam Leffler 5139beb93cSSam Leffler /** 5239beb93cSSam Leffler * eloop_event_handler - eloop generic event callback type 5339beb93cSSam Leffler * @eloop_ctx: Registered callback context data (eloop_data) 5439beb93cSSam Leffler * @sock_ctx: Registered callback context data (user_data) 5539beb93cSSam Leffler */ 5639beb93cSSam Leffler typedef void (*eloop_event_handler)(void *eloop_data, void *user_ctx); 5739beb93cSSam Leffler 5839beb93cSSam Leffler /** 5939beb93cSSam Leffler * eloop_timeout_handler - eloop timeout event callback type 6039beb93cSSam Leffler * @eloop_ctx: Registered callback context data (eloop_data) 6139beb93cSSam Leffler * @sock_ctx: Registered callback context data (user_data) 6239beb93cSSam Leffler */ 6339beb93cSSam Leffler typedef void (*eloop_timeout_handler)(void *eloop_data, void *user_ctx); 6439beb93cSSam Leffler 6539beb93cSSam Leffler /** 6639beb93cSSam Leffler * eloop_signal_handler - eloop signal event callback type 6739beb93cSSam Leffler * @sig: Signal number 6839beb93cSSam Leffler * @eloop_ctx: Registered callback context data (global user_data from 6939beb93cSSam Leffler * eloop_init() call) 7039beb93cSSam Leffler * @signal_ctx: Registered callback context data (user_data from 7139beb93cSSam Leffler * eloop_register_signal(), eloop_register_signal_terminate(), or 7239beb93cSSam Leffler * eloop_register_signal_reconfig() call) 7339beb93cSSam Leffler */ 7439beb93cSSam Leffler typedef void (*eloop_signal_handler)(int sig, void *eloop_ctx, 7539beb93cSSam Leffler void *signal_ctx); 7639beb93cSSam Leffler 7739beb93cSSam Leffler /** 7839beb93cSSam Leffler * eloop_init() - Initialize global event loop data 7939beb93cSSam Leffler * @user_data: Pointer to global data passed as eloop_ctx to signal handlers 8039beb93cSSam Leffler * Returns: 0 on success, -1 on failure 8139beb93cSSam Leffler * 8239beb93cSSam Leffler * This function must be called before any other eloop_* function. user_data 8339beb93cSSam Leffler * can be used to configure a global (to the process) pointer that will be 8439beb93cSSam Leffler * passed as eloop_ctx parameter to signal handlers. 8539beb93cSSam Leffler */ 8639beb93cSSam Leffler int eloop_init(void *user_data); 8739beb93cSSam Leffler 8839beb93cSSam Leffler /** 8939beb93cSSam Leffler * eloop_register_read_sock - Register handler for read events 9039beb93cSSam Leffler * @sock: File descriptor number for the socket 9139beb93cSSam Leffler * @handler: Callback function to be called when data is available for reading 9239beb93cSSam Leffler * @eloop_data: Callback context data (eloop_ctx) 9339beb93cSSam Leffler * @user_data: Callback context data (sock_ctx) 9439beb93cSSam Leffler * Returns: 0 on success, -1 on failure 9539beb93cSSam Leffler * 9639beb93cSSam Leffler * Register a read socket notifier for the given file descriptor. The handler 9739beb93cSSam Leffler * function will be called whenever data is available for reading from the 9839beb93cSSam Leffler * socket. The handler function is responsible for clearing the event after 9939beb93cSSam Leffler * having processed it in order to avoid eloop from calling the handler again 10039beb93cSSam Leffler * for the same event. 10139beb93cSSam Leffler */ 10239beb93cSSam Leffler int eloop_register_read_sock(int sock, eloop_sock_handler handler, 10339beb93cSSam Leffler void *eloop_data, void *user_data); 10439beb93cSSam Leffler 10539beb93cSSam Leffler /** 10639beb93cSSam Leffler * eloop_unregister_read_sock - Unregister handler for read events 10739beb93cSSam Leffler * @sock: File descriptor number for the socket 10839beb93cSSam Leffler * 10939beb93cSSam Leffler * Unregister a read socket notifier that was previously registered with 11039beb93cSSam Leffler * eloop_register_read_sock(). 11139beb93cSSam Leffler */ 11239beb93cSSam Leffler void eloop_unregister_read_sock(int sock); 11339beb93cSSam Leffler 11439beb93cSSam Leffler /** 11539beb93cSSam Leffler * eloop_register_sock - Register handler for socket events 11639beb93cSSam Leffler * @sock: File descriptor number for the socket 11739beb93cSSam Leffler * @type: Type of event to wait for 11839beb93cSSam Leffler * @handler: Callback function to be called when the event is triggered 11939beb93cSSam Leffler * @eloop_data: Callback context data (eloop_ctx) 12039beb93cSSam Leffler * @user_data: Callback context data (sock_ctx) 12139beb93cSSam Leffler * Returns: 0 on success, -1 on failure 12239beb93cSSam Leffler * 12339beb93cSSam Leffler * Register an event notifier for the given socket's file descriptor. The 12439beb93cSSam Leffler * handler function will be called whenever the that event is triggered for the 12539beb93cSSam Leffler * socket. The handler function is responsible for clearing the event after 12639beb93cSSam Leffler * having processed it in order to avoid eloop from calling the handler again 12739beb93cSSam Leffler * for the same event. 12839beb93cSSam Leffler */ 12939beb93cSSam Leffler int eloop_register_sock(int sock, eloop_event_type type, 13039beb93cSSam Leffler eloop_sock_handler handler, 13139beb93cSSam Leffler void *eloop_data, void *user_data); 13239beb93cSSam Leffler 13339beb93cSSam Leffler /** 13439beb93cSSam Leffler * eloop_unregister_sock - Unregister handler for socket events 13539beb93cSSam Leffler * @sock: File descriptor number for the socket 13639beb93cSSam Leffler * @type: Type of event for which sock was registered 13739beb93cSSam Leffler * 13839beb93cSSam Leffler * Unregister a socket event notifier that was previously registered with 13939beb93cSSam Leffler * eloop_register_sock(). 14039beb93cSSam Leffler */ 14139beb93cSSam Leffler void eloop_unregister_sock(int sock, eloop_event_type type); 14239beb93cSSam Leffler 14339beb93cSSam Leffler /** 14439beb93cSSam Leffler * eloop_register_event - Register handler for generic events 14539beb93cSSam Leffler * @event: Event to wait (eloop implementation specific) 14639beb93cSSam Leffler * @event_size: Size of event data 14739beb93cSSam Leffler * @handler: Callback function to be called when event is triggered 14839beb93cSSam Leffler * @eloop_data: Callback context data (eloop_data) 14939beb93cSSam Leffler * @user_data: Callback context data (user_data) 15039beb93cSSam Leffler * Returns: 0 on success, -1 on failure 15139beb93cSSam Leffler * 15239beb93cSSam Leffler * Register an event handler for the given event. This function is used to 15339beb93cSSam Leffler * register eloop implementation specific events which are mainly targetted for 15439beb93cSSam Leffler * operating system specific code (driver interface and l2_packet) since the 15539beb93cSSam Leffler * portable code will not be able to use such an OS-specific call. The handler 15639beb93cSSam Leffler * function will be called whenever the event is triggered. The handler 15739beb93cSSam Leffler * function is responsible for clearing the event after having processed it in 15839beb93cSSam Leffler * order to avoid eloop from calling the handler again for the same event. 15939beb93cSSam Leffler * 16039beb93cSSam Leffler * In case of Windows implementation (eloop_win.c), event pointer is of HANDLE 16139beb93cSSam Leffler * type, i.e., void*. The callers are likely to have 'HANDLE h' type variable, 16239beb93cSSam Leffler * and they would call this function with eloop_register_event(h, sizeof(h), 16339beb93cSSam Leffler * ...). 16439beb93cSSam Leffler */ 16539beb93cSSam Leffler int eloop_register_event(void *event, size_t event_size, 16639beb93cSSam Leffler eloop_event_handler handler, 16739beb93cSSam Leffler void *eloop_data, void *user_data); 16839beb93cSSam Leffler 16939beb93cSSam Leffler /** 17039beb93cSSam Leffler * eloop_unregister_event - Unregister handler for a generic event 17139beb93cSSam Leffler * @event: Event to cancel (eloop implementation specific) 17239beb93cSSam Leffler * @event_size: Size of event data 17339beb93cSSam Leffler * 17439beb93cSSam Leffler * Unregister a generic event notifier that was previously registered with 17539beb93cSSam Leffler * eloop_register_event(). 17639beb93cSSam Leffler */ 17739beb93cSSam Leffler void eloop_unregister_event(void *event, size_t event_size); 17839beb93cSSam Leffler 17939beb93cSSam Leffler /** 18039beb93cSSam Leffler * eloop_register_timeout - Register timeout 18139beb93cSSam Leffler * @secs: Number of seconds to the timeout 18239beb93cSSam Leffler * @usecs: Number of microseconds to the timeout 18339beb93cSSam Leffler * @handler: Callback function to be called when timeout occurs 18439beb93cSSam Leffler * @eloop_data: Callback context data (eloop_ctx) 18539beb93cSSam Leffler * @user_data: Callback context data (sock_ctx) 18639beb93cSSam Leffler * Returns: 0 on success, -1 on failure 18739beb93cSSam Leffler * 18839beb93cSSam Leffler * Register a timeout that will cause the handler function to be called after 18939beb93cSSam Leffler * given time. 19039beb93cSSam Leffler */ 19139beb93cSSam Leffler int eloop_register_timeout(unsigned int secs, unsigned int usecs, 19239beb93cSSam Leffler eloop_timeout_handler handler, 19339beb93cSSam Leffler void *eloop_data, void *user_data); 19439beb93cSSam Leffler 19539beb93cSSam Leffler /** 19639beb93cSSam Leffler * eloop_cancel_timeout - Cancel timeouts 19739beb93cSSam Leffler * @handler: Matching callback function 19839beb93cSSam Leffler * @eloop_data: Matching eloop_data or %ELOOP_ALL_CTX to match all 19939beb93cSSam Leffler * @user_data: Matching user_data or %ELOOP_ALL_CTX to match all 20039beb93cSSam Leffler * Returns: Number of cancelled timeouts 20139beb93cSSam Leffler * 20239beb93cSSam Leffler * Cancel matching <handler,eloop_data,user_data> timeouts registered with 20339beb93cSSam Leffler * eloop_register_timeout(). ELOOP_ALL_CTX can be used as a wildcard for 20439beb93cSSam Leffler * cancelling all timeouts regardless of eloop_data/user_data. 20539beb93cSSam Leffler */ 20639beb93cSSam Leffler int eloop_cancel_timeout(eloop_timeout_handler handler, 20739beb93cSSam Leffler void *eloop_data, void *user_data); 20839beb93cSSam Leffler 20939beb93cSSam Leffler /** 21039beb93cSSam Leffler * eloop_is_timeout_registered - Check if a timeout is already registered 21139beb93cSSam Leffler * @handler: Matching callback function 21239beb93cSSam Leffler * @eloop_data: Matching eloop_data 21339beb93cSSam Leffler * @user_data: Matching user_data 21439beb93cSSam Leffler * Returns: 1 if the timeout is registered, 0 if the timeout is not registered 21539beb93cSSam Leffler * 21639beb93cSSam Leffler * Determine if a matching <handler,eloop_data,user_data> timeout is registered 21739beb93cSSam Leffler * with eloop_register_timeout(). 21839beb93cSSam Leffler */ 21939beb93cSSam Leffler int eloop_is_timeout_registered(eloop_timeout_handler handler, 22039beb93cSSam Leffler void *eloop_data, void *user_data); 22139beb93cSSam Leffler 22239beb93cSSam Leffler /** 22339beb93cSSam Leffler * eloop_register_signal - Register handler for signals 22439beb93cSSam Leffler * @sig: Signal number (e.g., SIGHUP) 22539beb93cSSam Leffler * @handler: Callback function to be called when the signal is received 22639beb93cSSam Leffler * @user_data: Callback context data (signal_ctx) 22739beb93cSSam Leffler * Returns: 0 on success, -1 on failure 22839beb93cSSam Leffler * 22939beb93cSSam Leffler * Register a callback function that will be called when a signal is received. 23039beb93cSSam Leffler * The callback function is actually called only after the system signal 23139beb93cSSam Leffler * handler has returned. This means that the normal limits for sighandlers 23239beb93cSSam Leffler * (i.e., only "safe functions" allowed) do not apply for the registered 23339beb93cSSam Leffler * callback. 23439beb93cSSam Leffler * 23539beb93cSSam Leffler * Signals are 'global' events and there is no local eloop_data pointer like 23639beb93cSSam Leffler * with other handlers. The global user_data pointer registered with 23739beb93cSSam Leffler * eloop_init() will be used as eloop_ctx for signal handlers. 23839beb93cSSam Leffler */ 23939beb93cSSam Leffler int eloop_register_signal(int sig, eloop_signal_handler handler, 24039beb93cSSam Leffler void *user_data); 24139beb93cSSam Leffler 24239beb93cSSam Leffler /** 24339beb93cSSam Leffler * eloop_register_signal_terminate - Register handler for terminate signals 24439beb93cSSam Leffler * @handler: Callback function to be called when the signal is received 24539beb93cSSam Leffler * @user_data: Callback context data (signal_ctx) 24639beb93cSSam Leffler * Returns: 0 on success, -1 on failure 24739beb93cSSam Leffler * 24839beb93cSSam Leffler * Register a callback function that will be called when a process termination 24939beb93cSSam Leffler * signal is received. The callback function is actually called only after the 25039beb93cSSam Leffler * system signal handler has returned. This means that the normal limits for 25139beb93cSSam Leffler * sighandlers (i.e., only "safe functions" allowed) do not apply for the 25239beb93cSSam Leffler * registered callback. 25339beb93cSSam Leffler * 25439beb93cSSam Leffler * Signals are 'global' events and there is no local eloop_data pointer like 25539beb93cSSam Leffler * with other handlers. The global user_data pointer registered with 25639beb93cSSam Leffler * eloop_init() will be used as eloop_ctx for signal handlers. 25739beb93cSSam Leffler * 25839beb93cSSam Leffler * This function is a more portable version of eloop_register_signal() since 25939beb93cSSam Leffler * the knowledge of exact details of the signals is hidden in eloop 26039beb93cSSam Leffler * implementation. In case of operating systems using signal(), this function 26139beb93cSSam Leffler * registers handlers for SIGINT and SIGTERM. 26239beb93cSSam Leffler */ 26339beb93cSSam Leffler int eloop_register_signal_terminate(eloop_signal_handler handler, 26439beb93cSSam Leffler void *user_data); 26539beb93cSSam Leffler 26639beb93cSSam Leffler /** 26739beb93cSSam Leffler * eloop_register_signal_reconfig - Register handler for reconfig signals 26839beb93cSSam Leffler * @handler: Callback function to be called when the signal is received 26939beb93cSSam Leffler * @user_data: Callback context data (signal_ctx) 27039beb93cSSam Leffler * Returns: 0 on success, -1 on failure 27139beb93cSSam Leffler * 27239beb93cSSam Leffler * Register a callback function that will be called when a reconfiguration / 27339beb93cSSam Leffler * hangup signal is received. The callback function is actually called only 27439beb93cSSam Leffler * after the system signal handler has returned. This means that the normal 27539beb93cSSam Leffler * limits for sighandlers (i.e., only "safe functions" allowed) do not apply 27639beb93cSSam Leffler * for the registered callback. 27739beb93cSSam Leffler * 27839beb93cSSam Leffler * Signals are 'global' events and there is no local eloop_data pointer like 27939beb93cSSam Leffler * with other handlers. The global user_data pointer registered with 28039beb93cSSam Leffler * eloop_init() will be used as eloop_ctx for signal handlers. 28139beb93cSSam Leffler * 28239beb93cSSam Leffler * This function is a more portable version of eloop_register_signal() since 28339beb93cSSam Leffler * the knowledge of exact details of the signals is hidden in eloop 28439beb93cSSam Leffler * implementation. In case of operating systems using signal(), this function 28539beb93cSSam Leffler * registers a handler for SIGHUP. 28639beb93cSSam Leffler */ 28739beb93cSSam Leffler int eloop_register_signal_reconfig(eloop_signal_handler handler, 28839beb93cSSam Leffler void *user_data); 28939beb93cSSam Leffler 29039beb93cSSam Leffler /** 29139beb93cSSam Leffler * eloop_run - Start the event loop 29239beb93cSSam Leffler * 29339beb93cSSam Leffler * Start the event loop and continue running as long as there are any 29439beb93cSSam Leffler * registered event handlers. This function is run after event loop has been 29539beb93cSSam Leffler * initialized with event_init() and one or more events have been registered. 29639beb93cSSam Leffler */ 29739beb93cSSam Leffler void eloop_run(void); 29839beb93cSSam Leffler 29939beb93cSSam Leffler /** 30039beb93cSSam Leffler * eloop_terminate - Terminate event loop 30139beb93cSSam Leffler * 30239beb93cSSam Leffler * Terminate event loop even if there are registered events. This can be used 30339beb93cSSam Leffler * to request the program to be terminated cleanly. 30439beb93cSSam Leffler */ 30539beb93cSSam Leffler void eloop_terminate(void); 30639beb93cSSam Leffler 30739beb93cSSam Leffler /** 30839beb93cSSam Leffler * eloop_destroy - Free any resources allocated for the event loop 30939beb93cSSam Leffler * 31039beb93cSSam Leffler * After calling eloop_destroy(), other eloop_* functions must not be called 31139beb93cSSam Leffler * before re-running eloop_init(). 31239beb93cSSam Leffler */ 31339beb93cSSam Leffler void eloop_destroy(void); 31439beb93cSSam Leffler 31539beb93cSSam Leffler /** 31639beb93cSSam Leffler * eloop_terminated - Check whether event loop has been terminated 31739beb93cSSam Leffler * Returns: 1 = event loop terminate, 0 = event loop still running 31839beb93cSSam Leffler * 31939beb93cSSam Leffler * This function can be used to check whether eloop_terminate() has been called 32039beb93cSSam Leffler * to request termination of the event loop. This is normally used to abort 32139beb93cSSam Leffler * operations that may still be queued to be run when eloop_terminate() was 32239beb93cSSam Leffler * called. 32339beb93cSSam Leffler */ 32439beb93cSSam Leffler int eloop_terminated(void); 32539beb93cSSam Leffler 32639beb93cSSam Leffler /** 32739beb93cSSam Leffler * eloop_wait_for_read_sock - Wait for a single reader 32839beb93cSSam Leffler * @sock: File descriptor number for the socket 32939beb93cSSam Leffler * 33039beb93cSSam Leffler * Do a blocking wait for a single read socket. 33139beb93cSSam Leffler */ 33239beb93cSSam Leffler void eloop_wait_for_read_sock(int sock); 33339beb93cSSam Leffler 33439beb93cSSam Leffler /** 33539beb93cSSam Leffler * eloop_get_user_data - Get global user data 33639beb93cSSam Leffler * Returns: user_data pointer that was registered with eloop_init() 33739beb93cSSam Leffler */ 33839beb93cSSam Leffler void * eloop_get_user_data(void); 33939beb93cSSam Leffler 34039beb93cSSam Leffler #endif /* ELOOP_H */ 341