aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/src/worker_queue.c
diff options
context:
space:
mode:
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;
}