44d3230e40
The getsysinfo(2), getrusage(2), and svrctl(2) calls used the same call number to different services. Since we want to give each service its own call number ranges, this is no longer tenable. This patch introduces per-service call numbers for these calls. Note that the remainder of the COMMON_ range is left intact, as these the remaining requests in it are processed by SEF and thus server- agnostic. The range should really be prefixed with SEF_ now. Change-Id: I80d728bbeb98227359c525494c433965b40fefc3
131 lines
3.9 KiB
C
131 lines
3.9 KiB
C
/* Data Store Server.
|
|
* This service implements a little publish/subscribe data store that is
|
|
* crucial for the system's fault tolerance. Components that require state
|
|
* can store it here, for later retrieval, e.g., after a crash and subsequent
|
|
* restart by the reincarnation server.
|
|
*
|
|
* Created:
|
|
* Oct 19, 2005 by Jorrit N. Herder
|
|
*/
|
|
|
|
#include "inc.h" /* include master header file */
|
|
#include <minix/endpoint.h>
|
|
|
|
/* Allocate space for the global variables. */
|
|
static endpoint_t who_e; /* caller's proc number */
|
|
static int callnr; /* system call number */
|
|
|
|
/* Declare some local functions. */
|
|
static void get_work(message *m_ptr);
|
|
static void reply(endpoint_t whom, message *m_ptr);
|
|
|
|
/* SEF functions and variables. */
|
|
static void sef_local_startup(void);
|
|
|
|
/*===========================================================================*
|
|
* main *
|
|
*===========================================================================*/
|
|
int main(int argc, char **argv)
|
|
{
|
|
/* This is the main routine of this service. The main loop consists of
|
|
* three major activities: getting new work, processing the work, and
|
|
* sending the reply. The loop never terminates, unless a panic occurs.
|
|
*/
|
|
message m;
|
|
int result;
|
|
|
|
/* SEF local startup. */
|
|
env_setargs(argc, argv);
|
|
sef_local_startup();
|
|
|
|
/* Main loop - get work and do it, forever. */
|
|
while (TRUE) {
|
|
|
|
/* Wait for incoming message, sets 'callnr' and 'who'. */
|
|
get_work(&m);
|
|
|
|
if (is_notify(callnr)) {
|
|
printf("DS: warning, got illegal notify from: %d\n", m.m_source);
|
|
result = EINVAL;
|
|
goto send_reply;
|
|
}
|
|
|
|
switch (callnr) {
|
|
case DS_PUBLISH:
|
|
result = do_publish(&m);
|
|
break;
|
|
case DS_RETRIEVE:
|
|
result = do_retrieve(&m);
|
|
break;
|
|
case DS_RETRIEVE_LABEL:
|
|
result = do_retrieve_label(&m);
|
|
break;
|
|
case DS_DELETE:
|
|
result = do_delete(&m);
|
|
break;
|
|
case DS_SUBSCRIBE:
|
|
result = do_subscribe(&m);
|
|
break;
|
|
case DS_CHECK:
|
|
result = do_check(&m);
|
|
break;
|
|
case DS_GETSYSINFO:
|
|
result = do_getsysinfo(&m);
|
|
break;
|
|
default:
|
|
printf("DS: warning, got illegal request from %d\n", m.m_source);
|
|
result = EINVAL;
|
|
}
|
|
|
|
send_reply:
|
|
/* Finally send reply message, unless disabled. */
|
|
if (result != EDONTREPLY) {
|
|
m.m_type = result; /* build reply message */
|
|
reply(who_e, &m); /* send it away */
|
|
}
|
|
}
|
|
return(OK); /* shouldn't come here */
|
|
}
|
|
|
|
/*===========================================================================*
|
|
* sef_local_startup *
|
|
*===========================================================================*/
|
|
static void sef_local_startup()
|
|
{
|
|
/* Register init callbacks. */
|
|
sef_setcb_init_fresh(sef_cb_init_fresh);
|
|
sef_setcb_init_restart(sef_cb_init_fail);
|
|
|
|
/* No live update support for now. */
|
|
|
|
/* Let SEF perform startup. */
|
|
sef_startup();
|
|
}
|
|
|
|
/*===========================================================================*
|
|
* get_work *
|
|
*===========================================================================*/
|
|
static void get_work(
|
|
message *m_ptr /* message buffer */
|
|
)
|
|
{
|
|
int status = sef_receive(ANY, m_ptr); /* blocks until message arrives */
|
|
if (OK != status)
|
|
panic("failed to receive message!: %d", status);
|
|
who_e = m_ptr->m_source; /* message arrived! set sender */
|
|
callnr = m_ptr->m_type; /* set function call number */
|
|
}
|
|
|
|
/*===========================================================================*
|
|
* reply *
|
|
*===========================================================================*/
|
|
static void reply(
|
|
endpoint_t who_e, /* destination */
|
|
message *m_ptr /* message buffer */
|
|
)
|
|
{
|
|
int s = send(who_e, m_ptr); /* send the message */
|
|
if (OK != s)
|
|
printf("DS: unable to send reply to %d: %d\n", who_e, s);
|
|
}
|
|
|