diff options
| author | Egor Tensin <Egor.Tensin@gmail.com> | 2023-05-12 22:21:08 +0200 |
|---|---|---|
| committer | Egor Tensin <Egor.Tensin@gmail.com> | 2023-05-12 22:21:08 +0200 |
| commit | 514b10fae7245d10112e7221acedf8016f309b6e (patch) | |
| tree | 3aa5b891ad02896a49752984ac3d494017343146 /src/server.c | |
| parent | .build/ -> build/ (diff) | |
| download | cimple-514b10fae7245d10112e7221acedf8016f309b6e.tar.gz cimple-514b10fae7245d10112e7221acedf8016f309b6e.zip | |
ci_queue: rename a couple of functions
Diffstat (limited to 'src/server.c')
| -rw-r--r-- | src/server.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/server.c b/src/server.c index 51ee27f..22a9a86 100644 --- a/src/server.c +++ b/src/server.c @@ -163,7 +163,7 @@ static int worker_dequeue_run(struct server *server, struct ci_queue_entry **ci_ goto unlock; } - *ci_run = ci_queue_pop(&server->ci_queue); + *ci_run = ci_queue_remove_first(&server->ci_queue); log("Removed a CI run for repository %s from the queue\n", ci_queue_entry_get_url(*ci_run)); goto unlock; @@ -183,7 +183,7 @@ static int worker_requeue_run(struct server *server, struct ci_queue_entry *ci_r return ret; } - ci_queue_push_head(&server->ci_queue, ci_run); + ci_queue_add_first(&server->ci_queue, ci_run); log("Requeued a CI run for repository %s\n", ci_queue_entry_get_url(ci_run)); ret = pthread_cond_signal(&server->server_cv); @@ -260,7 +260,7 @@ static int msg_ci_run_queue(struct server *server, const char *url, const char * if (ret < 0) goto unlock; - ci_queue_push(&server->ci_queue, entry); + ci_queue_add_last(&server->ci_queue, entry); log("Added a new CI run for repository %s to the queue\n", url); ret = pthread_cond_signal(&server->server_cv); |