diff options
Diffstat (limited to 'ot_mutex.h')
| -rw-r--r-- | ot_mutex.h | 19 |
1 files changed, 10 insertions, 9 deletions
| @@ -10,6 +10,7 @@ | |||
| 10 | #include "trackerlogic.h" | 10 | #include "trackerlogic.h" |
| 11 | 11 | ||
| 12 | void mutex_init(void); | 12 | void mutex_init(void); |
| 13 | void mutex_workqueue_wakeall(void); | ||
| 13 | void mutex_deinit(void); | 14 | void mutex_deinit(void); |
| 14 | 15 | ||
| 15 | ot_vector *mutex_bucket_lock(int bucket); | 16 | ot_vector *mutex_bucket_lock(int bucket); |
| @@ -29,7 +30,6 @@ typedef enum { | |||
| 29 | TASK_STATS_TPB = 0x0006, | 30 | TASK_STATS_TPB = 0x0006, |
| 30 | TASK_STATS_HTTPERRORS = 0x0007, | 31 | TASK_STATS_HTTPERRORS = 0x0007, |
| 31 | TASK_STATS_VERSION = 0x0008, | 32 | TASK_STATS_VERSION = 0x0008, |
| 32 | TASK_STATS_BUSY_NETWORKS = 0x0009, | ||
| 33 | TASK_STATS_RENEW = 0x000a, | 33 | TASK_STATS_RENEW = 0x000a, |
| 34 | TASK_STATS_SYNCS = 0x000b, | 34 | TASK_STATS_SYNCS = 0x000b, |
| 35 | TASK_STATS_COMPLETED = 0x000c, | 35 | TASK_STATS_COMPLETED = 0x000c, |
| @@ -59,7 +59,8 @@ typedef enum { | |||
| 59 | 59 | ||
| 60 | TASK_FLAG_GZIP = 0x1000, | 60 | TASK_FLAG_GZIP = 0x1000, |
| 61 | TASK_FLAG_BZIP2 = 0x2000, | 61 | TASK_FLAG_BZIP2 = 0x2000, |
| 62 | TASK_FLAG_CHUNKED = 0x4000, | 62 | TASK_FLAG_ZSTD = 0x4000, |
| 63 | TASK_FLAG_CHUNKED = 0x8000, | ||
| 63 | 64 | ||
| 64 | TASK_TASK_MASK = 0x0fff, | 65 | TASK_TASK_MASK = 0x0fff, |
| 65 | TASK_CLASS_MASK = 0x0f00, | 66 | TASK_CLASS_MASK = 0x0f00, |
| @@ -68,12 +69,12 @@ typedef enum { | |||
| 68 | 69 | ||
| 69 | typedef unsigned long ot_taskid; | 70 | typedef unsigned long ot_taskid; |
| 70 | 71 | ||
| 71 | int mutex_workqueue_pushtask(int64 sock, ot_tasktype tasktype); | 72 | int mutex_workqueue_pushtask(int64_t sock, ot_tasktype tasktype); |
| 72 | void mutex_workqueue_canceltask(int64 sock); | 73 | void mutex_workqueue_canceltask(int64_t sock); |
| 73 | void mutex_workqueue_pushsuccess(ot_taskid taskid); | 74 | void mutex_workqueue_pushsuccess(ot_taskid taskid); |
| 74 | ot_taskid mutex_workqueue_poptask(ot_tasktype *tasktype); | 75 | ot_taskid mutex_workqueue_poptask(ot_tasktype *tasktype); |
| 75 | int mutex_workqueue_pushresult(ot_taskid taskid, int iovec_entries, struct iovec *iovector); | 76 | int mutex_workqueue_pushresult(ot_taskid taskid, size_t iovec_entries, struct iovec *iovector); |
| 76 | int mutex_workqueue_pushchunked(ot_taskid taskid, struct iovec *iovec); | 77 | int mutex_workqueue_pushchunked(ot_taskid taskid, struct iovec *iovec); |
| 77 | int64 mutex_workqueue_popresult(int *iovec_entries, struct iovec **iovector, int *is_partial); | 78 | int64_t mutex_workqueue_popresult(size_t *iovec_entries, struct iovec **iovector, int *is_partial); |
| 78 | 79 | ||
| 79 | #endif | 80 | #endif |
