diff options
Diffstat (limited to 'mmss/queue.c')
| -rw-r--r-- | mmss/queue.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/mmss/queue.c b/mmss/queue.c index 3adf188..cf1e10a 100644 --- a/mmss/queue.c +++ b/mmss/queue.c @@ -39,7 +39,7 @@ struct mmss_queue_entry { }; -void mmss_queue_put(mmss_context_t *ctx, mmss_queue_t *queue, void *data, uint64_t timeout) { +void mmss_queue_put(mmss_t *mmss, mmss_queue_t *queue, void *data, uint64_t timeout) { while (*queue && timeout > (*queue)->timeout) queue = &(*queue)->next; @@ -52,10 +52,10 @@ void mmss_queue_put(mmss_context_t *ctx, mmss_queue_t *queue, void *data, uint64 *queue = entry; } -void* mmss_queue_get(mmss_context_t *ctx, mmss_queue_t *queue) { +void* mmss_queue_get(mmss_t *mmss, mmss_queue_t *queue) { mmss_queue_entry_t *entry = *queue; - if (!entry || entry->timeout > ctx->now) + if (!entry || entry->timeout > mmss->now) return NULL; *queue = entry->next; @@ -65,11 +65,11 @@ void* mmss_queue_get(mmss_context_t *ctx, mmss_queue_t *queue) { return data; } -int mmss_queue_timeout(const mmss_context_t *ctx, const mmss_queue_t *const queue) { +int mmss_queue_timeout(const mmss_t *mmss, const mmss_queue_t *const queue) { if (!*queue) return -1; - int diff = (*queue)->timeout - ctx->now; + int diff = (*queue)->timeout - mmss->now; if (diff < 0) return 0; |