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