diff options
| author | Egor Tensin <Egor.Tensin@gmail.com> | 2023-11-12 01:10:07 +0100 |
|---|---|---|
| committer | Egor Tensin <Egor.Tensin@gmail.com> | 2023-11-12 01:10:07 +0100 |
| commit | df73d93b10e8e6014f61b1554be5b8553f34852a (patch) | |
| tree | c12c7742f366b4702ef707fc4eb1f5e5e66b0521 /src | |
| parent | refactoring (diff) | |
| download | cimple-df73d93b10e8e6014f61b1554be5b8553f34852a.tar.gz cimple-df73d93b10e8e6014f61b1554be5b8553f34852a.zip | |
json_rpc: add a routine to generate request IDs
Diffstat (limited to 'src')
| -rw-r--r-- | src/json_rpc.c | 8 | ||||
| -rw-r--r-- | src/json_rpc.h | 2 | ||||
| -rw-r--r-- | src/protocol.c | 2 |
3 files changed, 11 insertions, 1 deletions
diff --git a/src/json_rpc.c b/src/json_rpc.c index 7630f64..31794ec 100644 --- a/src/json_rpc.c +++ b/src/json_rpc.c @@ -11,6 +11,7 @@ #include <json-c/json_object.h> +#include <stdatomic.h> #include <stdint.h> #include <stdlib.h> #include <string.h> @@ -52,6 +53,13 @@ static int jsonrpc_set_version(struct json_object *obj) return json_set_string_const_key(obj, jsonrpc_key_version, jsonrpc_value_version); } +static _Atomic int jsonrpc_id_counter = 1; + +int jsonrpc_generate_request_id(void) +{ + return jsonrpc_id_counter++; +} + static int jsonrpc_check_id_type(struct json_object *id) { if (!json_object_is_type(id, json_type_string) && !json_object_is_type(id, json_type_int)) { diff --git a/src/json_rpc.h b/src/json_rpc.h index f3c67a9..090caca 100644 --- a/src/json_rpc.h +++ b/src/json_rpc.h @@ -16,6 +16,8 @@ struct jsonrpc_request; +int jsonrpc_generate_request_id(void); + int jsonrpc_request_create(struct jsonrpc_request **, int id, const char *method, struct json_object *params); void jsonrpc_request_destroy(struct jsonrpc_request *); diff --git a/src/protocol.c b/src/protocol.c index 977ed6e..8aac63d 100644 --- a/src/protocol.c +++ b/src/protocol.c @@ -25,7 +25,7 @@ int request_create_queue_run(struct jsonrpc_request **request, const struct run { int ret = 0; - ret = jsonrpc_request_create(request, 1, CMD_QUEUE_RUN, NULL); + ret = jsonrpc_request_create(request, jsonrpc_generate_request_id(), CMD_QUEUE_RUN, NULL); if (ret < 0) return ret; ret = jsonrpc_request_set_param_string(*request, run_key_url, run_get_url(run)); |