Change to wait for all outstanding iothreads before calling fork(). This should prevent a whole host of threading/fork interactions, but may also compromise performance...we'll see.

1 files changed, 4 insertions, 3 deletions

diff --git a/iothread.h b/iothread.h
index 7619501a..fe0f5300 100644
--- a/iothread.h
+++ b/iothread.h
@@ -22,11 +22,12 @@ int iothread_perform_base(int (*handler)(void *), void (*completionCallback)(voi
 */
 int iothread_port(void);
 
-/**
- Services one iothread competion callback.
-*/
+/** Services one iothread competion callback. */
 void iothread_service_completion(void);
 
+/** Cancels all outstanding requests and waits for all iothreads to terminate. */
+void iothread_drain_all(void);
+
 /** Helper template */
 template<typename T>
 int iothread_perform(int (*handler)(T *), void (*completionCallback)(T *, int), T *context) {