diff options
Diffstat (limited to 'src/worker.c')
| -rw-r--r-- | src/worker.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/worker.c b/src/worker.c index a6ccc89..5a0804f 100644 --- a/src/worker.c +++ b/src/worker.c @@ -82,14 +82,14 @@ static int worker_set_stopping(UNUSED struct event_loop *loop, UNUSED int fd, UN return 0; } -static int worker_handle_cmd_start(const struct jsonrpc_request *request, - UNUSED struct jsonrpc_response **response, void *_ctx) +static int worker_handle_cmd_start_run(const struct jsonrpc_request *request, + UNUSED struct jsonrpc_response **response, void *_ctx) { struct cmd_conn_ctx *ctx = (struct cmd_conn_ctx *)_ctx; struct worker *worker = (struct worker *)ctx->arg; int ret = 0; - ret = start_request_parse(request, &worker->run); + ret = request_parse_start_run(request, &worker->run); if (ret < 0) return ret; @@ -97,7 +97,7 @@ static int worker_handle_cmd_start(const struct jsonrpc_request *request, } static struct cmd_desc commands[] = { - {CMD_START, worker_handle_cmd_start}, + {CMD_START_RUN, worker_handle_cmd_start_run}, }; static const size_t numof_commands = sizeof(commands) / sizeof(commands[0]); @@ -194,7 +194,7 @@ static int worker_do_run(struct worker *worker) struct jsonrpc_request *finished_request = NULL; - ret = finished_request_create(&finished_request, run_get_id(worker->run), result); + ret = request_create_finished_run(&finished_request, run_get_id(worker->run), result); if (ret < 0) goto free_output; @@ -231,7 +231,7 @@ static int worker_get_run(struct worker *worker) fd = ret; struct jsonrpc_request *new_worker_request = NULL; - ret = new_worker_request_create(&new_worker_request); + ret = request_create_new_worker(&new_worker_request); if (ret < 0) goto close; |