aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/src/worker.c
diff options
context:
space:
mode:
authorEgor Tensin <Egor.Tensin@gmail.com>2023-04-29 10:04:56 +0200
committerEgor Tensin <Egor.Tensin@gmail.com>2023-04-29 10:04:56 +0200
commit7855893959b44d12f9e333278e325e49f47c5a9f (patch)
tree3e24dab57e32780a1600c534a635f5a942e23cac /src/worker.c
parentmake struct server opaque (diff)
downloadcimple-7855893959b44d12f9e333278e325e49f47c5a9f.tar.gz
cimple-7855893959b44d12f9e333278e325e49f47c5a9f.zip
make struct worker opaque
Diffstat (limited to '')
-rw-r--r--src/worker.c24
1 files changed, 22 insertions, 2 deletions
diff --git a/src/worker.c b/src/worker.c
index 7487e62..474be1c 100644
--- a/src/worker.c
+++ b/src/worker.c
@@ -20,13 +20,29 @@
#include <string.h>
#include <unistd.h>
-int worker_create(struct worker *worker, const struct settings *settings)
+struct worker {
+ int fd;
+
+ pthread_mutex_t task_mtx;
+ pthread_t task;
+ int task_active;
+};
+
+int worker_create(struct worker **_worker, const struct settings *settings)
{
+ struct worker *worker;
int ret = 0;
+ *_worker = malloc(sizeof(struct worker));
+ if (!*_worker) {
+ log_errno("malloc");
+ return -1;
+ }
+ worker = *_worker;
+
ret = libgit_init();
if (ret < 0)
- return ret;
+ goto free;
ret = net_connect(settings->host, settings->port);
if (ret < 0)
@@ -38,6 +54,9 @@ int worker_create(struct worker *worker, const struct settings *settings)
git_shutdown:
libgit_shutdown();
+free:
+ free(worker);
+
return ret;
}
@@ -47,6 +66,7 @@ void worker_destroy(struct worker *worker)
log_errno_if(close(worker->fd), "close");
libgit_shutdown();
+ free(worker);
}
static int msg_send_new_worker(const struct worker *worker)