summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMarc-André Lureau <marcandre.lureau@gmail.com>2013-10-03 22:05:55 +0200
committerFrediano Ziglio <fziglio@redhat.com>2015-10-05 14:45:16 +0100
commitf2ea57335e9d1b37e0747c3b4a860aca0828124e (patch)
treefb558c77b2288e456aa00bc1ae857bc7e83c24d2
parent5e80266cb9dbe19b9e372a1559edc246f27cc6e6 (diff)
worker: make it clear it returns from process when no cmd
Acked-by: Frediano Ziglio <fziglio@redhat.com>
-rw-r--r--server/red_worker.c8
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;
}