aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/src/protocol.c
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/protocol.c71
1 files changed, 32 insertions, 39 deletions
diff --git a/src/protocol.c b/src/protocol.c
index 0fa06f1..e650c49 100644
--- a/src/protocol.c
+++ b/src/protocol.c
@@ -6,6 +6,7 @@
*/
#include "protocol.h"
+
#include "base64.h"
#include "compiler.h"
#include "const.h"
@@ -18,12 +19,11 @@
#include <stdint.h>
#include <stdlib.h>
-static const char *const run_key_id = "id";
-static const char *const run_key_url = "url";
-static const char *const run_key_rev = "rev";
+static const char* const run_key_id = "id";
+static const char* const run_key_url = "url";
+static const char* const run_key_rev = "rev";
-int request_create_queue_run(struct jsonrpc_request **request, const struct run *run)
-{
+int request_create_queue_run(struct jsonrpc_request** request, const struct run* run) {
int ret = 0;
ret = jsonrpc_request_create(request, jsonrpc_generate_request_id(), CMD_QUEUE_RUN, NULL);
@@ -44,15 +44,14 @@ free_request:
return ret;
}
-int request_parse_queue_run(const struct jsonrpc_request *request, struct run **run)
-{
+int request_parse_queue_run(const struct jsonrpc_request* request, struct run** run) {
int ret = 0;
- const char *url = NULL;
+ const char* url = NULL;
ret = jsonrpc_request_get_param_string(request, run_key_url, &url);
if (ret < 0)
return ret;
- const char *rev = NULL;
+ const char* rev = NULL;
ret = jsonrpc_request_get_param_string(request, run_key_rev, &rev);
if (ret < 0)
return ret;
@@ -60,18 +59,15 @@ int request_parse_queue_run(const struct jsonrpc_request *request, struct run **
return run_queued(run, url, rev);
}
-int request_create_new_worker(struct jsonrpc_request **request)
-{
+int request_create_new_worker(struct jsonrpc_request** request) {
return jsonrpc_notification_create(request, CMD_NEW_WORKER, NULL);
}
-int request_parse_new_worker(UNUSED const struct jsonrpc_request *request)
-{
+int request_parse_new_worker(UNUSED const struct jsonrpc_request* request) {
return 0;
}
-int request_create_start_run(struct jsonrpc_request **request, const struct run *run)
-{
+int request_create_start_run(struct jsonrpc_request** request, const struct run* run) {
int ret = 0;
ret = jsonrpc_notification_create(request, CMD_START_RUN, NULL);
@@ -95,19 +91,18 @@ free_request:
return ret;
}
-int request_parse_start_run(const struct jsonrpc_request *request, struct run **run)
-{
+int request_parse_start_run(const struct jsonrpc_request* request, struct run** run) {
int ret = 0;
int64_t id = 0;
ret = jsonrpc_request_get_param_int(request, run_key_id, &id);
if (ret < 0)
return ret;
- const char *url = NULL;
+ const char* url = NULL;
ret = jsonrpc_request_get_param_string(request, run_key_url, &url);
if (ret < 0)
return ret;
- const char *rev = NULL;
+ const char* rev = NULL;
ret = jsonrpc_request_get_param_string(request, run_key_rev, &rev);
if (ret < 0)
return ret;
@@ -115,13 +110,13 @@ int request_parse_start_run(const struct jsonrpc_request *request, struct run **
return run_created(run, (int)id, url, rev);
}
-static const char *const finished_key_run_id = "run_id";
-static const char *const finished_key_ec = "exit_code";
-static const char *const finished_key_data = "output";
+static const char* const finished_key_run_id = "run_id";
+static const char* const finished_key_ec = "exit_code";
+static const char* const finished_key_data = "output";
-int request_create_finished_run(struct jsonrpc_request **request, int run_id,
- const struct process_output *output)
-{
+int request_create_finished_run(struct jsonrpc_request** request,
+ int run_id,
+ const struct process_output* output) {
int ret = 0;
ret = jsonrpc_notification_create(request, CMD_FINISHED_RUN, NULL);
@@ -134,7 +129,7 @@ int request_create_finished_run(struct jsonrpc_request **request, int run_id,
if (ret < 0)
goto free_request;
- char *b64data = NULL;
+ char* b64data = NULL;
ret = base64_encode(output->data, output->data_size, &b64data);
if (ret < 0)
goto free_request;
@@ -152,12 +147,12 @@ free_request:
return ret;
}
-int request_parse_finished_run(const struct jsonrpc_request *request, int *_run_id,
- struct process_output **_output)
-{
+int request_parse_finished_run(const struct jsonrpc_request* request,
+ int* _run_id,
+ struct process_output** _output) {
int ret = 0;
- struct process_output *output = NULL;
+ struct process_output* output = NULL;
ret = process_output_create(&output);
if (ret < 0)
return ret;
@@ -173,7 +168,7 @@ int request_parse_finished_run(const struct jsonrpc_request *request, int *_run_
goto free_output;
output->ec = (int)ec;
- const char *b64data = NULL;
+ const char* b64data = NULL;
ret = jsonrpc_request_get_param_string(request, finished_key_data, &b64data);
if (ret < 0)
goto free_output;
@@ -192,20 +187,18 @@ free_output:
return ret;
}
-int request_create_get_runs(struct jsonrpc_request **request)
-{
+int request_create_get_runs(struct jsonrpc_request** request) {
return jsonrpc_request_create(request, jsonrpc_generate_request_id(), CMD_GET_RUNS, NULL);
}
-int request_parse_get_runs(UNUSED const struct jsonrpc_request *request)
-{
+int request_parse_get_runs(UNUSED const struct jsonrpc_request* request) {
return 0;
}
-int response_create_get_runs(struct jsonrpc_response **response,
- const struct jsonrpc_request *request, const struct run_queue *runs)
-{
- struct json_object *runs_json = NULL;
+int response_create_get_runs(struct jsonrpc_response** response,
+ const struct jsonrpc_request* request,
+ const struct run_queue* runs) {
+ struct json_object* runs_json = NULL;
int ret = 0;
ret = run_queue_to_json(runs, &runs_json);
generated by cgit v1.3 (git 2.53.0) at 2026-10-25 06:53:21 +0000