summaryrefslogtreecommitdiffstats
path: root/src/task.c
diff options
context:
space:
mode:
authorMatthias Schiffer <mschiffer@universe-factory.net>2012-03-06 21:29:34 +0100
committerMatthias Schiffer <mschiffer@universe-factory.net>2012-03-06 21:29:34 +0100
commit1d18f972554c8bad0f08b3ff6727c87586e97094 (patch)
treeae3fc39553ecd87ed85b22860640d2859e9aa092 /src/task.c
parentd4686dd79799c09faee49e1645f9b3c39ce1e993 (diff)
downloadfastd-1d18f972554c8bad0f08b3ff6727c87586e97094.tar
fastd-1d18f972554c8bad0f08b3ff6727c87586e97094.zip
Reorganized type definitions
Diffstat (limited to 'src/task.c')
-rw-r--r--src/task.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/task.c b/src/task.c
index b565f1b..04b8cb1 100644
--- a/src/task.c
+++ b/src/task.c
@@ -30,7 +30,7 @@
fastd_task* fastd_task_get(fastd_context *ctx) {
- return fastd_queue_get(&ctx->task_queue);
+ return fastd_queue_get(ctx, &ctx->task_queue);
}
static void fastd_task_put_send_type(fastd_context *ctx, fastd_peer *peer, uint8_t packet_type, fastd_buffer buffer) {
@@ -41,7 +41,7 @@ static void fastd_task_put_send_type(fastd_context *ctx, fastd_peer *peer, uint8
task->packet_type = packet_type;
task->buffer = buffer;
- fastd_queue_put(&ctx->task_queue, task, 0);
+ fastd_queue_put(ctx, &ctx->task_queue, task, 0);
}
void fastd_task_put_send_handshake(fastd_context *ctx, fastd_peer *peer, fastd_buffer buffer) {
@@ -59,7 +59,7 @@ void fastd_task_put_handle_recv(fastd_context *ctx, fastd_peer *peer, fastd_buff
task->peer = peer;
task->buffer = buffer;
- fastd_queue_put(&ctx->task_queue, task, 0);
+ fastd_queue_put(ctx, &ctx->task_queue, task, 0);
}
void fastd_task_schedule_handshake(fastd_context *ctx, fastd_peer *peer, int timeout) {
@@ -68,7 +68,7 @@ void fastd_task_schedule_handshake(fastd_context *ctx, fastd_peer *peer, int tim
task->type = TASK_HANDSHAKE;
task->peer = peer;
- fastd_queue_put(&ctx->task_queue, task, timeout);
+ fastd_queue_put(ctx, &ctx->task_queue, task, timeout);
}
static bool delete_task(void *data, void *extra) {
@@ -97,5 +97,5 @@ static bool delete_task(void *data, void *extra) {
}
void fastd_task_delete_peer(fastd_context *ctx, fastd_peer *peer) {
- fastd_queue_filter(&ctx->task_queue, delete_task, peer);
+ fastd_queue_filter(ctx, &ctx->task_queue, delete_task, peer);
}