aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/src/client.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/client.c')
-rw-r--r--src/client.c122
1 files changed, 61 insertions, 61 deletions
diff --git a/src/client.c b/src/client.c
index d703baa..493dec2 100644
--- a/src/client.c
+++ b/src/client.c
@@ -20,98 +20,98 @@
#include <string.h>
struct client {
- int dummy;
+ int dummy;
};
int client_create(struct client** _client) {
- int ret = 0;
+ int ret = 0;
- struct client* client = malloc(sizeof(struct client));
- if (!client) {
- log_errno("malloc");
- return -1;
- }
+ struct client* client = malloc(sizeof(struct client));
+ if (!client) {
+ log_errno("malloc");
+ return -1;
+ }
- *_client = client;
- return ret;
+ *_client = client;
+ return ret;
}
void client_destroy(struct client* client) {
- free(client);
+ free(client);
}
static int make_request(struct jsonrpc_request** request, int argc, const char** argv) {
- if (argc < 1) {
- exit_with_usage_err("no action specified");
- return -1;
- }
+ if (argc < 1) {
+ exit_with_usage_err("no action specified");
+ return -1;
+ }
- if (!strcmp(argv[0], CMD_QUEUE_RUN)) {
- if (argc != 3)
- return -1;
+ if (!strcmp(argv[0], CMD_QUEUE_RUN)) {
+ if (argc != 3)
+ return -1;
- struct run* run = NULL;
- int ret = run_queued(&run, argv[1], argv[2]);
- if (ret < 0)
- return ret;
+ struct run* run = NULL;
+ int ret = run_queued(&run, argv[1], argv[2]);
+ if (ret < 0)
+ return ret;
- ret = request_create_queue_run(request, run);
- run_destroy(run);
- return ret;
- } else if (!strcmp(argv[0], CMD_GET_RUNS)) {
- if (argc != 1)
- return -1;
- return request_create_get_runs(request);
- }
+ ret = request_create_queue_run(request, run);
+ run_destroy(run);
+ return ret;
+ } else if (!strcmp(argv[0], CMD_GET_RUNS)) {
+ if (argc != 1)
+ return -1;
+ return request_create_get_runs(request);
+ }
- return -1;
+ return -1;
}
int client_main(UNUSED const struct client* client,
const struct settings* settings,
int argc,
const char** argv) {
- int ret = 0;
+ int ret = 0;
- struct jsonrpc_request* request = NULL;
- ret = make_request(&request, argc, argv);
- if (ret < 0) {
- exit_with_usage_err("invalid request");
- return ret;
- }
+ struct jsonrpc_request* request = NULL;
+ ret = make_request(&request, argc, argv);
+ if (ret < 0) {
+ exit_with_usage_err("invalid request");
+ return ret;
+ }
- ret = net_connect(settings->host, settings->port);
- if (ret < 0)
- goto free_request;
- int fd = ret;
+ ret = net_connect(settings->host, settings->port);
+ if (ret < 0)
+ goto free_request;
+ int fd = ret;
- ret = jsonrpc_request_send(request, fd);
- if (ret < 0)
- goto close;
+ ret = jsonrpc_request_send(request, fd);
+ if (ret < 0)
+ goto close;
- struct jsonrpc_response* response = NULL;
- ret = jsonrpc_response_recv(&response, fd);
- if (ret < 0)
- goto close;
+ struct jsonrpc_response* response = NULL;
+ ret = jsonrpc_response_recv(&response, fd);
+ if (ret < 0)
+ goto close;
- const char* response_str = jsonrpc_response_to_string(response);
- if (response_str) {
- if (jsonrpc_response_is_error(response))
- ret = -1;
- printf("%s", response_str);
- } else {
- log_err("no response\n");
- }
- goto free_response;
+ const char* response_str = jsonrpc_response_to_string(response);
+ if (response_str) {
+ if (jsonrpc_response_is_error(response))
+ ret = -1;
+ printf("%s", response_str);
+ } else {
+ log_err("no response\n");
+ }
+ goto free_response;
free_response:
- jsonrpc_response_destroy(response);
+ jsonrpc_response_destroy(response);
close:
- net_close(fd);
+ net_close(fd);
free_request:
- jsonrpc_request_destroy(request);
+ jsonrpc_request_destroy(request);
- return ret;
+ return ret;
}