pygos/init
1
0
Fork 0
mirror of https://github.com/pygos/init.git synced 2024-05-08 23:06:15 +02:00
Code Issues Releases Wiki Activity

initd: implement handling of socket requests

Browse source 
Actually process requests and send an answer to status inquiries.

Signed-off-by: David Oberhollenzer <goliath@infraroot.at>
This commit is contained in:
David Oberhollenzer 2019-03-18 14:08:17 +01:00
parent 23b713c3b5
commit 40ad83dc6a
3 changed files with 50 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
initd/init.h
View file

@ -67,6 +67,9 @@ void supervisor_init(void);
bool supervisor_process_queues(void);
void supervisor_answer_status_request(int fd, const void *dest_addr,
size_t addrlen);
/********** signal_<platform>.c **********/
/*

21
initd/main.c
View file

@ -43,6 +43,27 @@ static void handle_signal(void)
static void handle_request(void)
{
struct sockaddr_un addr;
init_request_t rq;
socklen_t addrlen;
ssize_t ret;
retry:
memset(&rq, 0, sizeof(rq));
addrlen = sizeof(addr);
ret = recvfrom(sockfd, &rq, sizeof(rq), MSG_DONTWAIT | MSG_TRUNC,
&addr, &addrlen);
if (ret < 0 && errno == EINTR)
goto retry;
if ((size_t)ret < sizeof(rq))
return;
switch (rq.rq) {
case EIR_STATUS:
supervisor_answer_status_request(sockfd, &addr, addrlen);
break;
}
}
void target_completed(int target)

26
initd/supervisor.c
View file

@ -167,3 +167,29 @@ bool supervisor_process_queues(void)
target_completed(target);
return true;
}
static int send_svc_list(int fd, const void *dst, size_t addrlen,
E_SERVICE_STATE state, service_t *list)
{
while (list != NULL) {
if (init_socket_send_status(fd, dst, addrlen, state, list))
return -1;
list = list->next;
}
return 0;
}
void supervisor_answer_status_request(int fd, const void *dst, size_t addrlen)
{
if (send_svc_list(fd, dst, addrlen, ESS_RUNNING, running))
return;
if (send_svc_list(fd, dst, addrlen, ESS_EXITED, completed))
return;
if (send_svc_list(fd, dst, addrlen, ESS_ENQUEUED, queue))
return;
if (send_svc_list(fd, dst, addrlen, ESS_ENQUEUED, terminated))
return;
init_socket_send_status(fd, dst, addrlen, ESS_NONE, NULL);
}