xref: /freebsd/contrib/wpa/src/utils/eloop.h (revision 39beb93c3f8bdbf72a61fda42300b5ebed7390c8)
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