Download raw body.
rpki-client rename some variables
Yes, much better.
Claudio Jeker <cjeker@diehard.n-r-g.com> wrote:
> Using the generic terms proc, rsync, http, rrdp for the pipe file
> descriptors is hurting my brain. I think this makes it more obvious
> that those things are.
>
> --
> :wq Claudio
>
> Index: main.c
> ===================================================================
> RCS file: /cvs/src/usr.sbin/rpki-client/main.c,v
> diff -u -p -r1.267 main.c
> --- main.c 27 Sep 2024 12:52:58 -0000 1.267
> +++ main.c 23 Oct 2024 09:54:37 -0000
> @@ -970,7 +970,8 @@ suicide(int sig __attribute__((unused)))
> int
> main(int argc, char *argv[])
> {
> - int rc, c, i, st, proc, rsync, http, rrdp, hangup = 0;
> + int rc, c, i, st, hangup = 0;
> + int procfd, rsyncfd, httpfd, rrdpfd;
> pid_t pid, procpid, rsyncpid, httppid, rrdppid;
> struct pollfd pfd[NPFD];
> struct msgbuf *queues[NPFD];
> @@ -1144,12 +1145,12 @@ main(int argc, char *argv[])
> * manifests, certificates, etc.) and returning contents.
> */
>
> - procpid = process_start("parser", &proc);
> + procpid = process_start("parser", &procfd);
> if (procpid == 0) {
> if (!filemode)
> - proc_parser(proc);
> + proc_parser(procfd);
> else
> - proc_filemode(proc);
> + proc_filemode(procfd);
> }
>
> /* Constraints are only needed in the filemode and parser processes. */
> @@ -1163,13 +1164,13 @@ main(int argc, char *argv[])
> */
>
> if (!noop) {
> - rsyncpid = process_start("rsync", &rsync);
> + rsyncpid = process_start("rsync", &rsyncfd);
> if (rsyncpid == 0) {
> - close(proc);
> - proc_rsync(rsync_prog, bind_addr, rsync);
> + close(procfd);
> + proc_rsync(rsync_prog, bind_addr, rsyncfd);
> }
> } else {
> - rsync = -1;
> + rsyncfd = -1;
> rsyncpid = -1;
> }
>
> @@ -1180,15 +1181,15 @@ main(int argc, char *argv[])
> */
>
> if (!noop && rrdpon) {
> - httppid = process_start("http", &http);
> + httppid = process_start("http", &httpfd);
>
> if (httppid == 0) {
> - close(proc);
> - close(rsync);
> - proc_http(bind_addr, http);
> + close(procfd);
> + close(rsyncfd);
> + proc_http(bind_addr, httpfd);
> }
> } else {
> - http = -1;
> + httpfd = -1;
> httppid = -1;
> }
>
> @@ -1199,15 +1200,15 @@ main(int argc, char *argv[])
> */
>
> if (!noop && rrdpon) {
> - rrdppid = process_start("rrdp", &rrdp);
> + rrdppid = process_start("rrdp", &rrdpfd);
> if (rrdppid == 0) {
> - close(proc);
> - close(rsync);
> - close(http);
> - proc_rrdp(rrdp);
> + close(procfd);
> + close(rsyncfd);
> + close(httpfd);
> + proc_rrdp(rrdpfd);
> }
> } else {
> - rrdp = -1;
> + rrdpfd = -1;
> rrdppid = -1;
> }
>
> @@ -1231,10 +1232,10 @@ main(int argc, char *argv[])
> msgbuf_init(&rsyncq);
> msgbuf_init(&httpq);
> msgbuf_init(&rrdpq);
> - procq.fd = proc;
> - rsyncq.fd = rsync;
> - httpq.fd = http;
> - rrdpq.fd = rrdp;
> + procq.fd = procfd;
> + rsyncq.fd = rsyncfd;
> + httpq.fd = httpfd;
> + rrdpq.fd = rrdpfd;
>
> /*
> * The main process drives the top-down scan to leaf ROAs using
> @@ -1242,13 +1243,13 @@ main(int argc, char *argv[])
> * parsing process.
> */
>
> - pfd[0].fd = proc;
> + pfd[0].fd = procfd;
> queues[0] = &procq;
> - pfd[1].fd = rsync;
> + pfd[1].fd = rsyncfd;
> queues[1] = &rsyncq;
> - pfd[2].fd = http;
> + pfd[2].fd = httpfd;
> queues[2] = &httpq;
> - pfd[3].fd = rrdp;
> + pfd[3].fd = rrdpfd;
> queues[3] = &rrdpq;
>
> load_skiplist(skiplistfile);
> @@ -1330,7 +1331,7 @@ main(int argc, char *argv[])
> */
>
> if ((pfd[1].revents & POLLIN)) {
> - b = io_buf_read(rsync, &rsyncbuf);
> + b = io_buf_read(rsyncfd, &rsyncbuf);
> if (b != NULL) {
> unsigned int id;
> int ok;
> @@ -1343,7 +1344,7 @@ main(int argc, char *argv[])
> }
>
> if ((pfd[2].revents & POLLIN)) {
> - b = io_buf_read(http, &httpbuf);
> + b = io_buf_read(httpfd, &httpbuf);
> if (b != NULL) {
> unsigned int id;
> enum http_result res;
> @@ -1362,7 +1363,7 @@ main(int argc, char *argv[])
> * Handle RRDP requests here.
> */
> if ((pfd[3].revents & POLLIN)) {
> - b = io_buf_read(rrdp, &rrdpbuf);
> + b = io_buf_read(rrdpfd, &rrdpbuf);
> if (b != NULL) {
> rrdp_process(b);
> ibuf_free(b);
> @@ -1375,7 +1376,7 @@ main(int argc, char *argv[])
> */
>
> if ((pfd[0].revents & POLLIN)) {
> - b = io_buf_read(proc, &procbuf);
> + b = io_buf_read(procfd, &procbuf);
> if (b != NULL) {
> entity_process(b, &stats, &vrps, &brks, &vaps,
> &vsps);
> @@ -1397,10 +1398,10 @@ main(int argc, char *argv[])
> * This will cause them to exit, then we reap them.
> */
>
> - close(proc);
> - close(rsync);
> - close(http);
> - close(rrdp);
> + close(procfd);
> + close(rsyncfd);
> + close(httpfd);
> + close(rrdpfd);
>
> rc = 0;
> for (;;) {
>
rpki-client rename some variables