diff options
| author | Egor Tensin <Egor.Tensin@gmail.com> | 2023-06-11 12:47:21 +0200 |
|---|---|---|
| committer | Egor Tensin <Egor.Tensin@gmail.com> | 2023-06-11 12:58:07 +0200 |
| commit | 04547fe158fe05f97ccf584332319da3e6b344d8 (patch) | |
| tree | 904a8716d3261c53c199a967fbc651b33430db2b /src/server.c | |
| parent | worker_queue: fix worker_queue_add_last (diff) | |
| download | cimple-04547fe158fe05f97ccf584332319da3e6b344d8.tar.gz cimple-04547fe158fe05f97ccf584332319da3e6b344d8.zip | |
msg: rework some APIs
Diffstat (limited to 'src/server.c')
| -rw-r--r-- | src/server.c | 12 |
1 files changed, 1 insertions, 11 deletions
diff --git a/src/server.c b/src/server.c index ff5b9e1..a5319e0 100644 --- a/src/server.c +++ b/src/server.c @@ -154,17 +154,7 @@ static int server_assign_run(struct server *server) const char *argv[] = {CMD_RUN, run_get_url(run), run_get_rev(run), NULL}; - struct msg *request = NULL; - - ret = msg_from_argv(&request, argv); - if (ret < 0) { - worker_queue_add_first(&server->worker_queue, worker); - run_queue_add_first(&server->run_queue, run); - return ret; - } - - ret = msg_communicate(worker_get_fd(worker), request, NULL); - msg_free(request); + ret = msg_talk_argv(worker_get_fd(worker), argv, NULL); if (ret < 0) { /* Failed to communicate with the worker, requeue the run * and forget about the worker. */ |