9 #ifndef TOR_WORKQUEUE_H
10 #define TOR_WORKQUEUE_H
41 void (*reply_fn)(
void *),
47 void (*reply_fn)(
void *),
51 void *(*dup_fn)(
void *),
53 void (*free_fn)(
void *),
58 void *(*new_thread_state_fn)(
void*),
59 void (*free_thread_state_fn)(
void*),
Integer definitions used throughout Tor.
threadpool_t * threadpool_new(int n_threads, replyqueue_t *replyqueue, void *(*new_thread_state_fn)(void *), void(*free_thread_state_fn)(void *), void *arg)
void * workqueue_entry_cancel(workqueue_entry_t *pending_work)
replyqueue_t * threadpool_get_replyqueue(threadpool_t *tp)
void replyqueue_process(replyqueue_t *queue)
replyqueue_t * replyqueue_new(uint32_t alertsocks_flags)
workqueue_entry_t * threadpool_queue_work_priority(threadpool_t *pool, workqueue_priority_t prio, workqueue_reply_t(*fn)(void *, void *), void(*reply_fn)(void *), void *arg)
int threadpool_register_reply_event(threadpool_t *tp, void(*cb)(threadpool_t *tp))
int threadpool_queue_update(threadpool_t *pool, void *(*dup_fn)(void *), workqueue_reply_t(*fn)(void *, void *), void(*free_fn)(void *), void *arg)
workqueue_entry_t * threadpool_queue_work(threadpool_t *pool, workqueue_reply_t(*fn)(void *, void *), void(*reply_fn)(void *), void *arg)