From d1cd99244f96bd95bbd67cc737248df346dec08b Mon Sep 17 00:00:00 2001 From: egor-tensin Date: Thu, 25 Apr 2024 03:50:51 +0000 Subject: =?UTF-8?q?Deploying=20to=20gh-pages=20from=20@=20egor-tensin/cimp?= =?UTF-8?q?le@8e652dd2cb69928ea1596aa3e59845fef6854e2c=20=F0=9F=9A=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...rotocol.c.4964764a2e677a55c2f4207a995c3ce7.html | 2054 ++++++++++++++++++++ 1 file changed, 2054 insertions(+) create mode 100644 coverage/index.protocol.c.4964764a2e677a55c2f4207a995c3ce7.html (limited to 'coverage/index.protocol.c.4964764a2e677a55c2f4207a995c3ce7.html') diff --git a/coverage/index.protocol.c.4964764a2e677a55c2f4207a995c3ce7.html b/coverage/index.protocol.c.4964764a2e677a55c2f4207a995c3ce7.html new file mode 100644 index 0000000..e07baf3 --- /dev/null +++ b/coverage/index.protocol.c.4964764a2e677a55c2f4207a995c3ce7.html @@ -0,0 +1,2054 @@ + + + + + + GCC Code Coverage Report + + + + + +

GCC Code Coverage Report

+ +
+ +
+
+ + + + + + + + + + + + + +
Directory:src/
File:src/protocol.c
Date:2024-04-25 03:45:42
+
+
+ + + + + + + + + + + + + + + + + + + +
ExecTotalCoverage
Lines:9013168.7%
Branches:244850.0%
+
+
+ +
+ +
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
LineBranchExecSource
1 + /*
2 + * Copyright (c) 2023 Egor Tensin <egor@tensin.name>
3 + * This file is part of the "cimple" project.
4 + * For details, see https://github.com/egor-tensin/cimple.
5 + * Distributed under the MIT License.
6 + */
7 +
8 + #include "protocol.h"
9 + #include "base64.h"
10 + #include "compiler.h"
11 + #include "const.h"
12 + #include "json.h"
13 + #include "json_rpc.h"
14 + #include "process.h"
15 + #include "run_queue.h"
16 +
17 + #include <stddef.h>
18 + #include <stdint.h>
19 + #include <stdlib.h>
20 +
21 + static const char *const run_key_id = "id";
22 + static const char *const run_key_url = "url";
23 + static const char *const run_key_rev = "rev";
24 +
25 + 9180int request_create_queue_run(struct jsonrpc_request **request, const struct run *run)
26 + {
27 + 9180 int ret = 0;
28 +
29 + 9180 ret = jsonrpc_request_create(request, jsonrpc_generate_request_id(), CMD_QUEUE_RUN, NULL);
30 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
31 + ✗ return ret;
32 + 9180 ret = jsonrpc_request_set_param_string(*request, run_key_url, run_get_repo_url(run));
33 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
34 + ✗ goto free_request;
35 + 9180 ret = jsonrpc_request_set_param_string(*request, run_key_rev, run_get_repo_rev(run));
36 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
37 + ✗ goto free_request;
38 +
39 + 9180 return ret;
40 +
41 + ✗free_request:
42 + ✗ jsonrpc_request_destroy(*request);
43 +
44 + ✗ return ret;
45 + }
46 +
47 + 9180int request_parse_queue_run(const struct jsonrpc_request *request, struct run **run)
48 + {
49 + 9180 int ret = 0;
50 +
51 + 9180 const char *url = NULL;
52 + 9180 ret = jsonrpc_request_get_param_string(request, run_key_url, &url);
53 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
54 + ✗ return ret;
55 + 9180 const char *rev = NULL;
56 + 9180 ret = jsonrpc_request_get_param_string(request, run_key_rev, &rev);
57 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
58 + ✗ return ret;
59 +
60 + 9180 return run_queued(run, url, rev);
61 + }
62 +
63 + 9234int request_create_new_worker(struct jsonrpc_request **request)
64 + {
65 + 9234 return jsonrpc_notification_create(request, CMD_NEW_WORKER, NULL);
66 + }
67 +
68 + ✗int request_parse_new_worker(UNUSED const struct jsonrpc_request *request)
69 + {
70 + ✗ return 0;
71 + }
72 +
73 + 9180int request_create_start_run(struct jsonrpc_request **request, const struct run *run)
74 + {
75 + 9180 int ret = 0;
76 +
77 + 9180 ret = jsonrpc_notification_create(request, CMD_START_RUN, NULL);
78 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
79 + ✗ return ret;
80 + 9180 ret = jsonrpc_request_set_param_int(*request, run_key_id, run_get_id(run));
81 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
82 + ✗ goto free_request;
83 + 9180 ret = jsonrpc_request_set_param_string(*request, run_key_url, run_get_repo_url(run));
84 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
85 + ✗ goto free_request;
86 + 9180 ret = jsonrpc_request_set_param_string(*request, run_key_rev, run_get_repo_rev(run));
87 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
88 + ✗ goto free_request;
89 +
90 + 9180 return ret;
91 +
92 + ✗free_request:
93 + ✗ jsonrpc_request_destroy(*request);
94 +
95 + ✗ return ret;
96 + }
97 +
98 + 9180int request_parse_start_run(const struct jsonrpc_request *request, struct run **run)
99 + {
100 + 9180 int ret = 0;
101 +
102 + 9180 int64_t id = 0;
103 + 9180 ret = jsonrpc_request_get_param_int(request, run_key_id, &id);
104 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
105 + ✗ return ret;
106 + 9180 const char *url = NULL;
107 + 9180 ret = jsonrpc_request_get_param_string(request, run_key_url, &url);
108 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
109 + ✗ return ret;
110 + 9180 const char *rev = NULL;
111 + 9180 ret = jsonrpc_request_get_param_string(request, run_key_rev, &rev);
112 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
113 + ✗ return ret;
114 +
115 + 9180 return run_created(run, (int)id, url, rev);
116 + }
117 +
118 + static const char *const finished_key_run_id = "run_id";
119 + static const char *const finished_key_ec = "exit_code";
120 + static const char *const finished_key_data = "output";
121 +
122 + 9180int request_create_finished_run(struct jsonrpc_request **request, int run_id,
123 + const struct proc_output *output)
124 + {
125 + 9180 int ret = 0;
126 +
127 + 9180 ret = jsonrpc_notification_create(request, CMD_FINISHED_RUN, NULL);
128 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
129 + ✗ return ret;
130 + 9180 ret = jsonrpc_request_set_param_int(*request, finished_key_run_id, run_id);
131 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
132 + ✗ goto free_request;
133 + 9180 ret = jsonrpc_request_set_param_int(*request, finished_key_ec, output->ec);
134 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
135 + ✗ goto free_request;
136 +
137 + 9180 char *b64data = NULL;
138 + 9180 ret = base64_encode(output->data, output->data_size, &b64data);
139 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
140 + ✗ goto free_request;
141 +
142 + 9180 ret = jsonrpc_request_set_param_string(*request, finished_key_data, b64data);
143 + 9180 free(b64data);
144 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
145 + ✗ goto free_request;
146 +
147 + 9180 return ret;
148 +
149 + ✗free_request:
150 + ✗ jsonrpc_request_destroy(*request);
151 +
152 + ✗ return ret;
153 + }
154 +
155 + 9180int request_parse_finished_run(const struct jsonrpc_request *request, int *_run_id,
156 + struct proc_output **_output)
157 + {
158 + 9180 int ret = 0;
159 +
160 + 9180 struct proc_output *output = NULL;
161 + 9180 ret = proc_output_create(&output);
162 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
163 + ✗ return ret;
164 +
165 + 9180 int64_t run_id = 0;
166 + 9180 ret = jsonrpc_request_get_param_int(request, finished_key_run_id, &run_id);
167 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
168 + ✗ goto free_output;
169 +
170 + 9180 int64_t ec = -1;
171 + 9180 ret = jsonrpc_request_get_param_int(request, finished_key_ec, &ec);
172 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
173 + ✗ goto free_output;
174 + 9180 output->ec = (int)ec;
175 +
176 + 9180 const char *b64data = NULL;
177 + 9180 ret = jsonrpc_request_get_param_string(request, finished_key_data, &b64data);
178 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
179 + ✗ goto free_output;
180 +
181 + 9180 ret = base64_decode(b64data, &output->data, &output->data_size);
182 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 9180 times.
+
+
+ 		9180 if (ret < 0)
183 + ✗ goto free_output;
184 +
185 + 9180 *_run_id = (int)run_id;
186 + 9180 *_output = output;
187 + 9180 return ret;
188 +
189 + ✗free_output:
190 + ✗ proc_output_destroy(output);
191 +
192 + ✗ return ret;
193 + }
194 +
195 + 26int request_create_get_runs(struct jsonrpc_request **request)
196 + {
197 + 26 return jsonrpc_request_create(request, jsonrpc_generate_request_id(), CMD_GET_RUNS, NULL);
198 + }
199 +
200 + 26int request_parse_get_runs(UNUSED const struct jsonrpc_request *request)
201 + {
202 + 26 return 0;
203 + }
204 +
205 + 26int response_create_get_runs(struct jsonrpc_response **response,
206 + const struct jsonrpc_request *request, const struct run_queue *runs)
207 + {
208 + 26 struct json_object *runs_json = NULL;
209 + 26 int ret = 0;
210 +
211 + 26 ret = run_queue_to_json(runs, &runs_json);
212 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 26 times.
+
+
+ 		26 if (ret < 0)
213 + ✗ return ret;
214 +
215 + 26 ret = jsonrpc_response_create(response, request, runs_json);
216 +
+ 1/2 +
+
✗ Branch 0 not taken.
+
✓ Branch 1 taken 26 times.
+
+
+ 		26 if (ret < 0)
217 + ✗ goto free_json;
218 +
219 + 26 return ret;
220 +
221 + ✗free_json:
222 + ✗ libjson_free(runs_json);
223 +
224 + ✗ return ret;
225 + }
226 +
+
+ +
+ + + + -- cgit v1.2.3