Lines Matching refs:queues
979 struct msgbuf *queues[NPFD]; in main() local
1253 queues[0] = procq; in main()
1255 queues[1] = rsyncq; in main()
1257 queues[2] = httpq; in main()
1259 queues[3] = rrdpq; in main()
1298 if (msgbuf_queuelen(queues[i]) > 0) in main()
1316 if (msgbuf_write(pfd[i].fd, queues[i]) == -1) { in main()
1337 switch (ibuf_read(pfd[1].fd, queues[1])) { in main()
1343 while ((b = io_buf_get(queues[1])) != NULL) { in main()
1355 switch (ibuf_read(pfd[2].fd, queues[2])) { in main()
1361 while ((b = io_buf_get(queues[2])) != NULL) { in main()
1379 switch (ibuf_read(pfd[3].fd, queues[3])) { in main()
1386 while ((b = io_buf_get(queues[3])) != NULL) { in main()
1398 switch (ibuf_read(pfd[0].fd, queues[0])) { in main()
1404 while ((b = io_buf_get(queues[0])) != NULL) { in main()