diff options
| author | 2024-01-01 11:23:22 -0500 | |
|---|---|---|
| committer | 2024-01-01 11:23:22 -0500 | |
| commit | 130a0edc0405e53b45f8b2f8da0b94356480a644 (patch) | |
| tree | 76cda2f7e0098bdcb6c54dc152bf3e95467fd44e /src/cache/handlers | |
| parent | 099126fdca625c5f6c219c5a1a7ecbc0e145988f (diff) | |
| download | camu-130a0edc0405e53b45f8b2f8da0b94356480a644.tar.gz camu-130a0edc0405e53b45f8b2f8da0b94356480a644.tar.bz2 camu-130a0edc0405e53b45f8b2f8da0b94356480a644.zip | |
wip
Signed-off-by: Andrew Opalach <andrew@akon.city>
Diffstat (limited to 'src/cache/handlers')
| -rw-r--r-- | src/cache/handlers/http.c | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/cache/handlers/http.c b/src/cache/handlers/http.c index 1daf231..dd3c8ac 100644 --- a/src/cache/handlers/http.c +++ b/src/cache/handlers/http.c @@ -80,12 +80,11 @@ static size_t http_callback(void *userdata, u8 op, u8 *buf, s64 int0) static void signal_callback(void *userdata) { struct cch_handler_http *http = (struct cch_handler_http *)userdata; + u32 size; + s32 index; do { - u32 size; - camu_queue_size(http->queue, size); + camu_queue_try_pop(http->queue, size, index); if (size == 0) break; - s32 index; - camu_queue_pop(http->queue, index); if (index == -1) { aki_event_loop_break(&http->loop); break; |