diff options
| -rw-r--r-- | server/red_worker.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/server/red_worker.c b/server/red_worker.c index 2efb311..d8a081e 100644 --- a/server/red_worker.c +++ b/server/red_worker.c @@ -4966,12 +4966,12 @@ static int red_process_cursor(RedWorker *worker, uint32_t max_pipe_size, int *ri if (worker->repoll_cursor_ring < CMD_RING_POLL_RETRIES) { worker->repoll_cursor_ring++; worker->event_timeout = MIN(worker->event_timeout, CMD_RING_POLL_TIMEOUT); - break; + return n; } if (worker->repoll_cursor_ring > CMD_RING_POLL_RETRIES || worker->qxl->st->qif->req_cursor_notification(worker->qxl)) { worker->repoll_cursor_ring++; - break; + return n; } continue; } @@ -5028,12 +5028,12 @@ static int red_process_commands(RedWorker *worker, uint32_t max_pipe_size, int * if (worker->repoll_cmd_ring < CMD_RING_POLL_RETRIES) { worker->repoll_cmd_ring++; worker->event_timeout = MIN(worker->event_timeout, CMD_RING_POLL_TIMEOUT); - break; + return n; } if (worker->repoll_cmd_ring > CMD_RING_POLL_RETRIES || worker->qxl->st->qif->req_cmd_notification(worker->qxl)) { worker->repoll_cmd_ring++; - break; + return n; } continue; } |