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.
131 lines
4.2 KiB
C
131 lines
4.2 KiB
C
#include "syslib.h"
|
|
#include <assert.h>
|
|
#include <minix/sysutil.h>
|
|
|
|
/* SEF Init callbacks. */
|
|
PRIVATE struct sef_cbs {
|
|
sef_cb_init_t sef_cb_init_fresh;
|
|
sef_cb_init_t sef_cb_init_lu;
|
|
sef_cb_init_t sef_cb_init_restart;
|
|
} sef_cbs = {
|
|
SEF_CB_INIT_FRESH_DEFAULT,
|
|
SEF_CB_INIT_LU_DEFAULT,
|
|
SEF_CB_INIT_RESTART_DEFAULT
|
|
};
|
|
|
|
/* SEF Init prototypes for sef_startup(). */
|
|
PUBLIC _PROTOTYPE( int do_sef_rs_init, (void) );
|
|
PUBLIC _PROTOTYPE( int do_sef_init_request, (message *m_ptr) );
|
|
|
|
/* Debug. */
|
|
EXTERN _PROTOTYPE( char* sef_debug_header, (void) );
|
|
|
|
/*===========================================================================*
|
|
* do_sef_rs_init *
|
|
*===========================================================================*/
|
|
PUBLIC int do_sef_rs_init()
|
|
{
|
|
/* Special SEF Init for RS. */
|
|
return sef_cbs.sef_cb_init_fresh(SEF_INIT_FRESH, NULL);
|
|
}
|
|
|
|
/*===========================================================================*
|
|
* do_sef_init_request *
|
|
*===========================================================================*/
|
|
PUBLIC int do_sef_init_request(message *m_ptr)
|
|
{
|
|
/* Handle a SEF Init request. */
|
|
int r;
|
|
int type;
|
|
sef_init_info_t info;
|
|
|
|
/* Debug. */
|
|
#if SEF_INIT_DEBUG
|
|
sef_init_debug_begin();
|
|
sef_init_dprint("%s. Got a SEF Init request of type: %d. About to init.\n",
|
|
sef_debug_header(), m_ptr->RS_INIT_TYPE);
|
|
sef_init_debug_end();
|
|
#endif
|
|
|
|
/* Let the callback code handle the request. */
|
|
type = m_ptr->RS_INIT_TYPE;
|
|
info.rproctab_gid = m_ptr->RS_INIT_RPROCTAB_GID;
|
|
info.old_endpoint = m_ptr->RS_INIT_OLD_ENDPOINT;
|
|
switch(type) {
|
|
case SEF_INIT_FRESH:
|
|
r = sef_cbs.sef_cb_init_fresh(type, &info);
|
|
break;
|
|
case SEF_INIT_LU:
|
|
r = sef_cbs.sef_cb_init_lu(type, &info);
|
|
break;
|
|
case SEF_INIT_RESTART:
|
|
r = sef_cbs.sef_cb_init_restart(type, &info);
|
|
break;
|
|
|
|
default:
|
|
/* Not a valid SEF init type. */
|
|
r = EINVAL;
|
|
break;
|
|
}
|
|
|
|
/* Report back to RS. */
|
|
m_ptr->RS_INIT_RESULT = r;
|
|
r = sendrec(RS_PROC_NR, m_ptr);
|
|
|
|
return r;
|
|
}
|
|
|
|
/*===========================================================================*
|
|
* sef_setcb_init_fresh *
|
|
*===========================================================================*/
|
|
PUBLIC void sef_setcb_init_fresh(sef_cb_init_t cb)
|
|
{
|
|
assert(cb != NULL);
|
|
sef_cbs.sef_cb_init_fresh = cb;
|
|
}
|
|
|
|
/*===========================================================================*
|
|
* sef_setcb_init_lu *
|
|
*===========================================================================*/
|
|
PUBLIC void sef_setcb_init_lu(sef_cb_init_t cb)
|
|
{
|
|
assert(cb != NULL);
|
|
sef_cbs.sef_cb_init_lu = cb;
|
|
}
|
|
|
|
/*===========================================================================*
|
|
* sef_setcb_init_restart *
|
|
*===========================================================================*/
|
|
PUBLIC void sef_setcb_init_restart(sef_cb_init_t cb)
|
|
{
|
|
assert(cb != NULL);
|
|
sef_cbs.sef_cb_init_restart = cb;
|
|
}
|
|
|
|
/*===========================================================================*
|
|
* sef_cb_init_null *
|
|
*===========================================================================*/
|
|
PUBLIC int sef_cb_init_null(int UNUSED(type),
|
|
sef_init_info_t *UNUSED(info))
|
|
{
|
|
return OK;
|
|
}
|
|
|
|
/*===========================================================================*
|
|
* sef_cb_init_fail *
|
|
*===========================================================================*/
|
|
PUBLIC int sef_cb_init_fail(int UNUSED(type), sef_init_info_t *UNUSED(info))
|
|
{
|
|
return ENOSYS;
|
|
}
|
|
|
|
/*===========================================================================*
|
|
* sef_cb_init_crash *
|
|
*===========================================================================*/
|
|
PUBLIC int sef_cb_init_crash(int UNUSED(type), sef_init_info_t *UNUSED(info))
|
|
{
|
|
panic("Simulating a crash at initialization time...");
|
|
|
|
return OK;
|
|
}
|
|
|