From 04547fe158fe05f97ccf584332319da3e6b344d8 Mon Sep 17 00:00:00 2001 From: Egor Tensin Date: Sun, 11 Jun 2023 12:47:21 +0200 Subject: msg: rework some APIs --- src/server.c | 12 +----------- 1 file changed, 1 insertion(+), 11 deletions(-) (limited to 'src/server.c') 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. */ -- cgit v1.3