1
0
Fork 0
mirror of https://github.com/pygos/init.git synced 2024-11-22 11:19:45 +01:00

cleanup: init status response

- rename init_status_response_t to init_status_t
 - merge code for handling it
 - fix memory leak in status command

Signed-off-by: David Oberhollenzer <goliath@infraroot.at>
This commit is contained in:
David Oberhollenzer 2019-03-29 10:40:59 +01:00
parent 7cfe6e8458
commit c3d14cbfa8
6 changed files with 27 additions and 25 deletions

View file

@ -8,17 +8,11 @@
#include <getopt.h> #include <getopt.h>
#include <unistd.h> #include <unistd.h>
static void free_resp(init_status_response_t *resp)
{
free(resp->filename);
free(resp->service_name);
}
static int cmd_startstop(int argc, char **argv, static int cmd_startstop(int argc, char **argv,
E_SERVICE_STATE filter, E_INIT_REQUEST action) E_SERVICE_STATE filter, E_INIT_REQUEST action)
{ {
int i, fd, ret = EXIT_FAILURE; int i, fd, ret = EXIT_FAILURE;
init_status_response_t resp; init_status_t resp;
char tmppath[256]; char tmppath[256];
bool found; bool found;
@ -41,12 +35,12 @@ static int cmd_startstop(int argc, char **argv,
if (init_socket_recv_status(fd, &resp)) { if (init_socket_recv_status(fd, &resp)) {
perror("reading from initd socket"); perror("reading from initd socket");
free_resp(&resp); free_init_status(&resp);
goto out; goto out;
} }
if (resp.state == ESS_NONE) { if (resp.state == ESS_NONE) {
free_resp(&resp); free_init_status(&resp);
break; break;
} }
@ -68,7 +62,7 @@ static int cmd_startstop(int argc, char **argv,
goto out; goto out;
} }
free_resp(&resp); free_init_status(&resp);
} }
ret = EXIT_SUCCESS; ret = EXIT_SUCCESS;

View file

@ -15,17 +15,11 @@ static const struct option long_opts[] = {
static const char *short_opts = "d"; static const char *short_opts = "d";
static void free_resp(init_status_response_t *resp)
{
free(resp->filename);
free(resp->service_name);
}
static int cmd_status(int argc, char **argv) static int cmd_status(int argc, char **argv)
{ {
bool is_tty, found, show_details = false; bool is_tty, found, show_details = false;
int i, fd, ret = EXIT_FAILURE; int i, fd, ret = EXIT_FAILURE;
init_status_response_t resp; init_status_t resp;
char tmppath[256]; char tmppath[256];
const char *state; const char *state;
service_t *svc; service_t *svc;
@ -63,12 +57,12 @@ static int cmd_status(int argc, char **argv)
if (init_socket_recv_status(fd, &resp)) { if (init_socket_recv_status(fd, &resp)) {
perror("reading from initd socket"); perror("reading from initd socket");
free_resp(&resp); free_init_status(&resp);
goto out; goto out;
} }
if (resp.state == ESS_NONE) { if (resp.state == ESS_NONE) {
free_resp(&resp); free_init_status(&resp);
break; break;
} }
@ -87,8 +81,10 @@ static int cmd_status(int argc, char **argv)
} }
} }
if (!found) if (!found) {
free_init_status(&resp);
continue; continue;
}
} }
switch (resp.state) { switch (resp.state) {
@ -150,7 +146,7 @@ static int cmd_status(int argc, char **argv)
printf("[%s] %s\n", state, resp.filename); printf("[%s] %s\n", state, resp.filename);
} }
free_resp(&resp); free_init_status(&resp);
} }
ret = EXIT_SUCCESS; ret = EXIT_SUCCESS;

View file

@ -1,7 +1,7 @@
libinit_a_SOURCES = lib/init/delsvc.c lib/init/svcmap.c lib/init/rdsvc.c libinit_a_SOURCES = lib/init/delsvc.c lib/init/svcmap.c lib/init/rdsvc.c
libinit_a_SOURCES += lib/init/svcscan.c lib/init/del_svc_list.c libinit_a_SOURCES += lib/init/svcscan.c lib/init/del_svc_list.c
libinit_a_SOURCES += lib/init/svc_tsort.c lib/include/service.h libinit_a_SOURCES += lib/init/svc_tsort.c lib/include/service.h
libinit_a_SOURCES += lib/init/init_socket_open.c libinit_a_SOURCES += lib/init/init_socket_open.c lib/init/free_init_status.c
libinit_a_SOURCES += lib/include/initsock.h lib/init/init_socket_send_request.c libinit_a_SOURCES += lib/include/initsock.h lib/init/init_socket_send_request.c
libinit_a_SOURCES += lib/init/init_socket_recv_status.c libinit_a_SOURCES += lib/init/init_socket_recv_status.c
libinit_a_CPPFLAGS = $(AM_CPPFLAGS) libinit_a_CPPFLAGS = $(AM_CPPFLAGS)

View file

@ -45,12 +45,14 @@ typedef struct {
int id; int id;
char *filename; char *filename;
char *service_name; char *service_name;
} init_status_response_t; } init_status_t;
int init_socket_open(const char *tmppath); int init_socket_open(const char *tmppath);
int init_socket_send_request(int fd, E_INIT_REQUEST rq, ...); int init_socket_send_request(int fd, E_INIT_REQUEST rq, ...);
int init_socket_recv_status(int fd, init_status_response_t *resp); int init_socket_recv_status(int fd, init_status_t *resp);
void free_init_status(init_status_t *resp);
#endif /* INITSOCK_H */ #endif /* INITSOCK_H */

View file

@ -0,0 +1,10 @@
/* SPDX-License-Identifier: ISC */
#include <stdlib.h>
#include "initsock.h"
void free_init_status(init_status_t *resp)
{
free(resp->filename);
free(resp->service_name);
}

View file

@ -61,7 +61,7 @@ static char *read_string(int fd)
return buffer; return buffer;
} }
int init_socket_recv_status(int fd, init_status_response_t *resp) int init_socket_recv_status(int fd, init_status_t *resp)
{ {
uint8_t info[8]; uint8_t info[8];