aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/src/worker.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/worker.c')
-rw-r--r--src/worker.c12
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;