48c6bb79f4
SYSLIB CHANGES: - DS calls to publish / retrieve labels consider endpoints instead of u32_t. VFS CHANGES: - mapdriver() only adds an entry in the dmap table in VFS. - dev_up() is only executed upon reception of a driver up event. INET CHANGES: - INET no longer searches for existing drivers instances at startup. - A newtwork driver is (re)initialized upon reception of a driver up event. - Networking startup is now race-free by design. No need to waste 5 seconds at startup any more. DRIVER CHANGES: - Every driver publishes driver up events when starting for the first time or in case of restart when recovery actions must be taken in the upper layers. - Driver up events are published by drivers through DS. - For regular drivers, VFS is normally the only subscriber, but not necessarily. For instance, when the filter driver is in use, it must subscribe to driver up events to initiate recovery. - For network drivers, inet is the only subscriber for now. - Every VFS driver is statically linked with libdriver, every network driver is statically linked with libnetdriver. DRIVER LIBRARIES CHANGES: - Libdriver is extended to provide generic receive() and ds_publish() interfaces for VFS drivers. - driver_receive() is a wrapper for sef_receive() also used in driver_task() to discard spurious messages that were meant to be delivered to a previous version of the driver. - driver_receive_mq() is the same as driver_receive() but integrates support for queued messages. - driver_announce() publishes a driver up event for VFS drivers and marks the driver as initialized and expecting a DEV_OPEN message. - Libnetdriver is introduced to provide similar receive() and ds_publish() interfaces for network drivers (netdriver_announce() and netdriver_receive()). - Network drivers all support live update with no state transfer now. KERNEL CHANGES: - Added kernel call statectl for state management. Used by driver_announce() to unblock eventual callers sendrecing to the driver.
220 lines
8.5 KiB
C
220 lines
8.5 KiB
C
/* Prototypes for System Event Framework (SEF) functions. */
|
|
|
|
#ifndef _SEF_H
|
|
#define _SEF_H
|
|
|
|
#include <minix/ipc.h>
|
|
|
|
/* SEF entry points for system processes. */
|
|
_PROTOTYPE( void sef_startup, (void) );
|
|
_PROTOTYPE( int sef_receive_status, (endpoint_t src, message *m_ptr,
|
|
int *status_ptr) );
|
|
_PROTOTYPE( void sef_exit, (int status) );
|
|
#define sef_receive(src, m_ptr) sef_receive_status(src, m_ptr, NULL)
|
|
|
|
/* SEF Debug. */
|
|
#include <stdio.h>
|
|
#define sef_dprint printf
|
|
#define sef_debug_begin() (void)(NULL)
|
|
#define sef_debug_end() fflush(stdout)
|
|
|
|
/*===========================================================================*
|
|
* SEF Init *
|
|
*===========================================================================*/
|
|
/* What to intercept. */
|
|
#define INTERCEPT_SEF_INIT_REQUESTS 1
|
|
#define IS_SEF_INIT_REQUEST(mp) ((mp)->m_type == RS_INIT \
|
|
&& (mp)->m_source == RS_PROC_NR)
|
|
|
|
/* Type definitions. */
|
|
typedef struct {
|
|
cp_grant_id_t rproctab_gid;
|
|
} sef_init_info_t;
|
|
|
|
/* Callback type definitions. */
|
|
typedef int(*sef_cb_init_t)(int type, sef_init_info_t *info);
|
|
|
|
/* Callback registration helpers. */
|
|
_PROTOTYPE( void sef_setcb_init_fresh, (sef_cb_init_t cb));
|
|
_PROTOTYPE( void sef_setcb_init_lu, (sef_cb_init_t cb));
|
|
_PROTOTYPE( void sef_setcb_init_restart, (sef_cb_init_t cb));
|
|
|
|
/* Predefined callback implementations. */
|
|
_PROTOTYPE( int sef_cb_init_null, (int type, sef_init_info_t *info) );
|
|
|
|
_PROTOTYPE( int sef_cb_init_fail, (int type, sef_init_info_t *info) );
|
|
_PROTOTYPE( int sef_cb_init_crash, (int type, sef_init_info_t *info) );
|
|
|
|
/* Macros for predefined callback implementations. */
|
|
#define SEF_CB_INIT_FRESH_NULL sef_cb_init_null
|
|
#define SEF_CB_INIT_LU_NULL sef_cb_init_null
|
|
#define SEF_CB_INIT_RESTART_NULL sef_cb_init_null
|
|
|
|
#define SEF_CB_INIT_FRESH_DEFAULT sef_cb_init_null
|
|
#define SEF_CB_INIT_LU_DEFAULT sef_cb_init_null
|
|
#define SEF_CB_INIT_RESTART_DEFAULT sef_cb_init_null
|
|
|
|
/* Init types. */
|
|
#define SEF_INIT_FRESH 0 /* init fresh */
|
|
#define SEF_INIT_LU 1 /* init after live update */
|
|
#define SEF_INIT_RESTART 2 /* init after restart */
|
|
|
|
/* Debug. */
|
|
#define SEF_INIT_DEBUG_DEFAULT 0
|
|
|
|
#ifndef SEF_INIT_DEBUG
|
|
#define SEF_INIT_DEBUG SEF_INIT_DEBUG_DEFAULT
|
|
#endif
|
|
|
|
#define sef_init_dprint sef_dprint
|
|
#define sef_init_debug_begin sef_debug_begin
|
|
#define sef_init_debug_end sef_debug_end
|
|
|
|
/*===========================================================================*
|
|
* SEF Ping *
|
|
*===========================================================================*/
|
|
/* What to intercept. */
|
|
#define INTERCEPT_SEF_PING_REQUESTS 1
|
|
#define IS_SEF_PING_REQUEST(mp, status) (is_ipc_notify(status) \
|
|
&& (mp)->m_source == RS_PROC_NR)
|
|
|
|
/* Callback type definitions. */
|
|
typedef void(*sef_cb_ping_reply_t)(endpoint_t source);
|
|
|
|
/* Callback registration helpers. */
|
|
_PROTOTYPE( void sef_setcb_ping_reply, (sef_cb_ping_reply_t cb));
|
|
|
|
/* Predefined callback implementations. */
|
|
_PROTOTYPE( void sef_cb_ping_reply_null, (endpoint_t source) );
|
|
|
|
_PROTOTYPE( void sef_cb_ping_reply_pong, (endpoint_t source) );
|
|
|
|
/* Macros for predefined callback implementations. */
|
|
#define SEF_CB_PING_REPLY_NULL sef_cb_ping_reply_null
|
|
|
|
#define SEF_CB_PING_REPLY_DEFAULT sef_cb_ping_reply_pong
|
|
|
|
/* Debug. */
|
|
#define SEF_PING_DEBUG_DEFAULT 0
|
|
|
|
#ifndef SEF_PING_DEBUG
|
|
#define SEF_PING_DEBUG SEF_PING_DEBUG_DEFAULT
|
|
#endif
|
|
|
|
#define sef_ping_dprint sef_dprint
|
|
#define sef_ping_debug_begin sef_debug_begin
|
|
#define sef_ping_debug_end sef_debug_end
|
|
|
|
/*===========================================================================*
|
|
* SEF Live update *
|
|
*===========================================================================*/
|
|
/* What to intercept. */
|
|
#define INTERCEPT_SEF_LU_REQUESTS 1
|
|
#define IS_SEF_LU_REQUEST(mp, status) ((mp)->m_type == RS_LU_PREPARE \
|
|
&& (mp)->m_source == RS_PROC_NR)
|
|
|
|
/* Callback type definitions. */
|
|
typedef int(*sef_cb_lu_prepare_t)(int);
|
|
typedef int(*sef_cb_lu_state_isvalid_t)(int);
|
|
typedef void(*sef_cb_lu_state_changed_t)(int, int);
|
|
typedef void(*sef_cb_lu_state_dump_t)(int);
|
|
typedef int(*sef_cb_lu_state_save_t)(int);
|
|
|
|
/* Callback registration helpers. */
|
|
_PROTOTYPE( void sef_setcb_lu_prepare, (sef_cb_lu_prepare_t cb) );
|
|
_PROTOTYPE( void sef_setcb_lu_state_isvalid, (sef_cb_lu_state_isvalid_t cb) );
|
|
_PROTOTYPE( void sef_setcb_lu_state_changed, (sef_cb_lu_state_changed_t cb) );
|
|
_PROTOTYPE( void sef_setcb_lu_state_dump, (sef_cb_lu_state_dump_t cb) );
|
|
_PROTOTYPE( void sef_setcb_lu_state_save, (sef_cb_lu_state_save_t cb) );
|
|
|
|
/* Predefined callback implementations. */
|
|
_PROTOTYPE( int sef_cb_lu_prepare_null, (int state) );
|
|
_PROTOTYPE( int sef_cb_lu_state_isvalid_null, (int state) );
|
|
_PROTOTYPE( void sef_cb_lu_state_changed_null, (int old_state, int state) );
|
|
_PROTOTYPE( void sef_cb_lu_state_dump_null, (int state) );
|
|
_PROTOTYPE( int sef_cb_lu_state_save_null, (int state) );
|
|
|
|
_PROTOTYPE( int sef_cb_lu_prepare_always_ready, (int state) );
|
|
_PROTOTYPE( int sef_cb_lu_prepare_never_ready, (int state) );
|
|
_PROTOTYPE( int sef_cb_lu_prepare_crash, (int state) );
|
|
_PROTOTYPE( int sef_cb_lu_state_isvalid_standard, (int state) );
|
|
_PROTOTYPE( int sef_cb_lu_state_isvalid_workfree, (int state) );
|
|
|
|
/* Macros for predefined callback implementations. */
|
|
#define SEF_CB_LU_PREPARE_NULL sef_cb_lu_prepare_null
|
|
#define SEF_CB_LU_STATE_ISVALID_NULL sef_cb_lu_state_isvalid_null
|
|
#define SEF_CB_LU_STATE_CHANGED_NULL sef_cb_lu_state_changed_null
|
|
#define SEF_CB_LU_STATE_DUMP_NULL sef_cb_lu_state_dump_null
|
|
#define SEF_CB_LU_STATE_SAVE_NULL sef_cb_lu_state_save_null
|
|
|
|
#define SEF_CB_LU_PREPARE_DEFAULT sef_cb_lu_prepare_null
|
|
#define SEF_CB_LU_STATE_ISVALID_DEFAULT sef_cb_lu_state_isvalid_null
|
|
#define SEF_CB_LU_STATE_CHANGED_DEFAULT sef_cb_lu_state_changed_null
|
|
#define SEF_CB_LU_STATE_DUMP_DEFAULT sef_cb_lu_state_dump_null
|
|
#define SEF_CB_LU_STATE_SAVE_DEFAULT sef_cb_lu_state_save_null
|
|
|
|
/* Standard live update states. */
|
|
#define SEF_LU_STATE_NULL 0 /* null state */
|
|
#define SEF_LU_STATE_WORK_FREE 1 /* no work in progress */
|
|
#define SEF_LU_STATE_REQUEST_FREE 2 /* no request in progress */
|
|
#define SEF_LU_STATE_PROTOCOL_FREE 3 /* no protocol in progress */
|
|
#define SEF_LU_STATE_CUSTOM_BASE (SEF_LU_STATE_PROTOCOL_FREE+1)
|
|
#define SEF_LU_STATE_IS_STANDARD(s) ((s) > SEF_LU_STATE_NULL \
|
|
&& (s) < SEF_LU_STATE_CUSTOM_BASE)
|
|
|
|
/* Debug. */
|
|
#define SEF_LU_DEBUG_DEFAULT 1
|
|
|
|
#ifndef SEF_LU_DEBUG
|
|
#define SEF_LU_DEBUG SEF_LU_DEBUG_DEFAULT
|
|
#endif
|
|
|
|
#define sef_lu_dprint sef_dprint
|
|
#define sef_lu_debug_begin sef_debug_begin
|
|
#define sef_lu_debug_end sef_debug_end
|
|
|
|
/*===========================================================================*
|
|
* SEF Signal *
|
|
*===========================================================================*/
|
|
/* What to intercept. */
|
|
#define INTERCEPT_SEF_SIGNAL_REQUESTS 1
|
|
#define IS_SEF_SIGNAL_REQUEST(mp, status) \
|
|
(((mp)->m_type == SIGS_SIGNAL_RECEIVED && (mp)->m_source < INIT_PROC_NR) \
|
|
|| (is_ipc_notify(status) && (mp)->m_source == SYSTEM))
|
|
|
|
/* Callback type definitions. */
|
|
typedef void(*sef_cb_signal_handler_t)(int signo);
|
|
typedef int(*sef_cb_signal_manager_t)(endpoint_t target, int signo);
|
|
|
|
/* Callback registration helpers. */
|
|
_PROTOTYPE( void sef_setcb_signal_handler, (sef_cb_signal_handler_t cb));
|
|
_PROTOTYPE( void sef_setcb_signal_manager, (sef_cb_signal_manager_t cb));
|
|
|
|
/* Predefined callback implementations. */
|
|
_PROTOTYPE( void sef_cb_signal_handler_null, (int signo) );
|
|
_PROTOTYPE( int sef_cb_signal_manager_null, (endpoint_t target, int signo) );
|
|
|
|
_PROTOTYPE( void sef_cb_signal_handler_term, (int signo) );
|
|
_PROTOTYPE( void sef_cb_signal_handler_posix_default, (int signo) );
|
|
|
|
/* Macros for predefined callback implementations. */
|
|
#define SEF_CB_SIGNAL_HANDLER_NULL sef_cb_signal_handler_null
|
|
#define SEF_CB_SIGNAL_MANAGER_NULL sef_cb_signal_manager_null
|
|
|
|
#define SEF_CB_SIGNAL_HANDLER_DEFAULT sef_cb_signal_handler_null
|
|
#define SEF_CB_SIGNAL_MANAGER_DEFAULT sef_cb_signal_manager_null
|
|
|
|
/* Debug. */
|
|
#define SEF_SIGNAL_DEBUG_DEFAULT 0
|
|
|
|
#ifndef SEF_SIGNAL_DEBUG
|
|
#define SEF_SIGNAL_DEBUG SEF_SIGNAL_DEBUG_DEFAULT
|
|
#endif
|
|
|
|
#define sef_signal_dprint sef_dprint
|
|
#define sef_signal_debug_begin sef_debug_begin
|
|
#define sef_signal_debug_end sef_debug_end
|
|
|
|
#endif /* _SEF_H */
|
|
|