-/* $OpenBSD: filemode.c,v 1.48 2024/07/25 08:44:39 tb Exp $ */
+/* $OpenBSD: filemode.c,v 1.49 2024/08/20 13:31:49 claudio Exp $ */
/*
* Copyright (c) 2019 Claudio Jeker <claudio@openbsd.org>
* Copyright (c) 2019 Kristaps Dzonsons <kristaps@bsd.lv>
for (;;) {
pfd.events = POLLIN;
- if (msgq.queued)
+ if (msgbuf_queuelen(&msgq) > 0)
pfd.events |= POLLOUT;
if (poll(&pfd, 1, INFTIM) == -1) {
-/* $OpenBSD: http.c,v 1.85 2024/04/23 10:27:46 tb Exp $ */
+/* $OpenBSD: http.c,v 1.86 2024/08/20 13:31:49 claudio Exp $ */
/*
* Copyright (c) 2020 Nils Fisher <nils_fisher@hotmail.com>
* Copyright (c) 2020 Claudio Jeker <claudio@openbsd.org>
memset(&pfds, 0, sizeof(pfds));
pfds[0].fd = fd;
pfds[0].events = POLLIN;
- if (msgq.queued)
+ if (msgbuf_queuelen(&msgq) > 0)
pfds[0].events |= POLLOUT;
i = 1;
-/* $OpenBSD: main.c,v 1.263 2024/08/15 09:22:12 claudio Exp $ */
+/* $OpenBSD: main.c,v 1.264 2024/08/20 13:31:49 claudio Exp $ */
/*
* Copyright (c) 2021 Claudio Jeker <claudio@openbsd.org>
* Copyright (c) 2019 Kristaps Dzonsons <kristaps@bsd.lv>
for (i = 0; i < NPFD; i++) {
pfd[i].events = POLLIN;
- if (queues[i]->queued)
+ if (msgbuf_queuelen(queues[i]) > 0)
pfd[i].events |= POLLOUT;
}
-/* $OpenBSD: parser.c,v 1.141 2024/06/12 10:03:09 tb Exp $ */
+/* $OpenBSD: parser.c,v 1.142 2024/08/20 13:31:49 claudio Exp $ */
/*
* Copyright (c) 2019 Claudio Jeker <claudio@openbsd.org>
* Copyright (c) 2019 Kristaps Dzonsons <kristaps@bsd.lv>
for (;;) {
pfd.events = POLLIN;
- if (msgq.queued)
+ if (msgbuf_queuelen(&msgq) > 0)
pfd.events |= POLLOUT;
if (poll(&pfd, 1, INFTIM) == -1) {
-/* $OpenBSD: rrdp.c,v 1.33 2024/02/16 11:46:57 tb Exp $ */
+/* $OpenBSD: rrdp.c,v 1.34 2024/08/20 13:31:49 claudio Exp $ */
/*
* Copyright (c) 2020 Nils Fisher <nils_fisher@hotmail.com>
* Copyright (c) 2021 Claudio Jeker <claudio@openbsd.org>
*/
pfds[0].fd = fd;
pfds[0].events = POLLIN;
- if (msgq.queued)
+ if (msgbuf_queuelen(&msgq) > 0)
pfds[0].events |= POLLOUT;
if (poll(pfds, i, INFTIM) == -1) {
-/* $OpenBSD: rsync.c,v 1.50 2024/03/22 03:38:12 job Exp $ */
+/* $OpenBSD: rsync.c,v 1.51 2024/08/20 13:31:49 claudio Exp $ */
/*
* Copyright (c) 2019 Kristaps Dzonsons <kristaps@bsd.lv>
*
pfd.events = 0;
pfd.events |= POLLIN;
- if (msgq.queued)
+ if (msgbuf_queuelen(&msgq) > 0)
pfd.events |= POLLOUT;
if (npending > 0 && nprocs < MAX_RSYNC_REQUESTS) {