diff options
author | Nick Mathewson <nickm@torproject.org> | 2018-10-22 08:49:55 -0400 |
---|---|---|
committer | Nick Mathewson <nickm@torproject.org> | 2018-10-22 08:49:55 -0400 |
commit | afc22ec5396e677c8cc3f7f14ecec7dc02a75b63 (patch) | |
tree | 11d45adb6cf3795fed55518a574b5fb75bf50971 /src | |
parent | 7aa9fc1637aeb876c0eebceec3dcdcbcba603302 (diff) | |
parent | a56451af4269235df45416a37a5e37be6e63c827 (diff) | |
download | tor-afc22ec5396e677c8cc3f7f14ecec7dc02a75b63.tar.gz tor-afc22ec5396e677c8cc3f7f14ecec7dc02a75b63.zip |
Merge remote-tracking branch 'tor-github/pr/421'
Diffstat (limited to 'src')
-rw-r--r-- | src/lib/evloop/workqueue.c | 6 | ||||
-rw-r--r-- | src/lib/evloop/workqueue.h | 1 |
2 files changed, 3 insertions, 4 deletions
diff --git a/src/lib/evloop/workqueue.c b/src/lib/evloop/workqueue.c index 931f65e710..5471f87b04 100644 --- a/src/lib/evloop/workqueue.c +++ b/src/lib/evloop/workqueue.c @@ -15,7 +15,7 @@ * * The main thread informs the worker threads of pending work by using a * condition variable. The workers inform the main process of completed work - * by using an alert_sockets_t object, as implemented in compat_threads.c. + * by using an alert_sockets_t object, as implemented in net/alertsock.c. * * The main thread can also queue an "update" that will be handled by all the * workers. This is useful for updating state that all the workers share. @@ -622,8 +622,8 @@ reply_event_cb(evutil_socket_t sock, short events, void *arg) tp->reply_cb(tp); } -/** Register the threadpool <b>tp</b>'s reply queue with the libevent - * mainloop of <b>base</b>. If <b>tp</b> is provided, it is run after +/** Register the threadpool <b>tp</b>'s reply queue with Tor's global + * libevent mainloop. If <b>cb</b> is provided, it is run after * each time there is work to process from the reply queue. Return 0 on * success, -1 on failure. */ diff --git a/src/lib/evloop/workqueue.h b/src/lib/evloop/workqueue.h index da292d1f05..10d5d47464 100644 --- a/src/lib/evloop/workqueue.h +++ b/src/lib/evloop/workqueue.h @@ -63,7 +63,6 @@ replyqueue_t *threadpool_get_replyqueue(threadpool_t *tp); replyqueue_t *replyqueue_new(uint32_t alertsocks_flags); void replyqueue_process(replyqueue_t *queue); -struct event_base; int threadpool_register_reply_event(threadpool_t *tp, void (*cb)(threadpool_t *tp)); |