0164957abb
RS CHANGES: - Crash recovery is now implemented like live update. Two instances are kept side by side and the dead version is live updated into the new one. The endpoint doesn't change and the failure is not exposed (by default) to other system services. - The new instance can be created reactively (when a crash is detected) or proactively. In the latter case, RS can be instructed to keep a replica of the system service to perform a hot swap when the service fails. The flag SF_USE_REPL is set in that case. - The new flag SF_USE_REPL is supported for services in the boot image and dynamically started services through the RS interface (i.e. -p option in the service utility). - Fixed a free unallocated memory bug for core system services.
221 lines
8.5 KiB
C
221 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;
|
|
endpoint_t old_endpoint;
|
|
} 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 */
|
|
|