aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/src/worker_queue.c
diff options
context:
space:
mode:
authorEgor Tensin <egor@tensin.name>2026-06-12 17:20:08 +0200
committerEgor Tensin <egor@tensin.name>2026-06-12 17:20:08 +0200
commit1160cdb21e0b667269299853cb47a4aa88948dc3 (patch)
treeb6828fc587bf0f868d9eb7a54518a46a9afc1a32 /src/worker_queue.c
parentdependabot: fix a typo (diff)
downloadcimple-1160cdb21e0b667269299853cb47a4aa88948dc3.tar.gz
cimple-1160cdb21e0b667269299853cb47a4aa88948dc3.zip
unify my .clang-format files
Diffstat (limited to 'src/worker_queue.c')
-rw-r--r--src/worker_queue.c36
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;
}