diff options
| author | Egor Tensin <egor@tensin.name> | 2026-06-12 17:20:08 +0200 |
|---|---|---|
| committer | Egor Tensin <egor@tensin.name> | 2026-06-12 17:20:08 +0200 |
| commit | 1160cdb21e0b667269299853cb47a4aa88948dc3 (patch) | |
| tree | b6828fc587bf0f868d9eb7a54518a46a9afc1a32 /src/worker_queue.c | |
| parent | dependabot: fix a typo (diff) | |
| download | cimple-1160cdb21e0b667269299853cb47a4aa88948dc3.tar.gz cimple-1160cdb21e0b667269299853cb47a4aa88948dc3.zip | |
unify my .clang-format files
Diffstat (limited to 'src/worker_queue.c')
| -rw-r--r-- | src/worker_queue.c | 36 |
1 files changed, 14 insertions, 22 deletions
diff --git a/src/worker_queue.c b/src/worker_queue.c index 1db396e..84f9c50 100644 --- a/src/worker_queue.c +++ b/src/worker_queue.c @@ -6,6 +6,7 @@ */ #include "worker_queue.h" + #include "log.h" #include "net.h" @@ -17,9 +18,8 @@ struct worker { SIMPLEQ_ENTRY(worker) entries; }; -int worker_create(struct worker **_entry, int fd) -{ - struct worker *entry = malloc(sizeof(struct worker)); +int worker_create(struct worker** _entry, int fd) { + struct worker* entry = malloc(sizeof(struct worker)); if (!entry) { log_errno("malloc"); return -1; @@ -31,51 +31,43 @@ int worker_create(struct worker **_entry, int fd) return 0; } -void worker_destroy(struct worker *entry) -{ +void worker_destroy(struct worker* entry) { net_close(entry->fd); free(entry); } -int worker_get_fd(const struct worker *entry) -{ +int worker_get_fd(const struct worker* entry) { return entry->fd; } -void worker_queue_create(struct worker_queue *queue) -{ +void worker_queue_create(struct worker_queue* queue) { SIMPLEQ_INIT(queue); } -void worker_queue_destroy(struct worker_queue *queue) -{ - struct worker *entry1 = SIMPLEQ_FIRST(queue); +void worker_queue_destroy(struct worker_queue* queue) { + struct worker* entry1 = SIMPLEQ_FIRST(queue); while (entry1) { - struct worker *entry2 = SIMPLEQ_NEXT(entry1, entries); + struct worker* entry2 = SIMPLEQ_NEXT(entry1, entries); worker_destroy(entry1); entry1 = entry2; } SIMPLEQ_INIT(queue); } -int worker_queue_is_empty(const struct worker_queue *queue) -{ +int worker_queue_is_empty(const struct worker_queue* queue) { return SIMPLEQ_EMPTY(queue); } -void worker_queue_add_first(struct worker_queue *queue, struct worker *entry) -{ +void worker_queue_add_first(struct worker_queue* queue, struct worker* entry) { SIMPLEQ_INSERT_HEAD(queue, entry, entries); } -void worker_queue_add_last(struct worker_queue *queue, struct worker *entry) -{ +void worker_queue_add_last(struct worker_queue* queue, struct worker* entry) { SIMPLEQ_INSERT_TAIL(queue, entry, entries); } -struct worker *worker_queue_remove_first(struct worker_queue *queue) -{ - struct worker *entry = SIMPLEQ_FIRST(queue); +struct worker* worker_queue_remove_first(struct worker_queue* queue) { + struct worker* entry = SIMPLEQ_FIRST(queue); SIMPLEQ_REMOVE_HEAD(queue, entries); return entry; } |
