#endif
} tor_mutex_t;
-
tor_mutex_t *tor_mutex_new(void);
tor_mutex_t *tor_mutex_new_nonrecursive(void);
void tor_mutex_init(tor_mutex_t *m);
void alert_sockets_close(alert_sockets_t *socks);
#endif
+
add_n_work_items(tp, n_to_send);
}
- if (shutting_down == 0 && n_received+n_successful_cancel == n_sent && n_sent >= opt_n_items) {
+ if (shutting_down == 0 &&
+ n_received+n_successful_cancel == n_sent &&
+ n_sent >= opt_n_items) {
shutting_down = 1;
- threadpool_queue_for_all(tp, NULL, workqueue_do_shutdown, shutdown_reply, NULL);
+ threadpool_queue_for_all(tp, NULL,
+ workqueue_do_shutdown, shutdown_reply, NULL);
}
}
return 0;
}
}
+