1 files changed, 99 insertions, 0 deletions
diff --git a/ktalkd/ktalkd/threads.cpp b/ktalkd/ktalkd/threads.cpp
new file mode 100644
index 00000000..09d5bb4c
--- /dev/null
+++ b/ktalkd/ktalkd/threads.cpp
@@ -0,0 +1,99 @@
+/*
+ * Copyright (c) 1983 Regents of the University of California, (c) 1998 David Faure.
+ * All rights reserved.
+ *
+ *  Redistribution and use in source and binary forms, with or
+ *    without modification, are permitted provided that the following
+ *    conditions are met:
+ *
+ *    - Redistributions of source code must retain the above
+ *      copyright notice, this list of conditions and the following
+ *      disclaimer.
+ *
+ *    - Redistributions in binary form must reproduce the above
+ *      copyright notice, this list of conditions and the following
+ *      disclaimer in the documentation and/or other materials
+ *      provided with the distribution.
+ *
+ *  THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY
+ *    EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
+ *    THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
+ *    PARTICULAR PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR
+ *    BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
+ *    EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED
+ *    TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ *    DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ *    ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ *    LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
+ *    IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
+ *    THE POSSIBILITY OF SUCH DAMAGE.
+ *
+ * (BSD License, from kdelibs/doc/common/bsd-license.html)
+ */
+
+#include <stdlib.h>
+#include <string.h>
+#include <syslog.h>
+#include <sys/types.h>
+#include <sys/wait.h>
+#include <errno.h>
+#include "includ.h"
+#include "proto.h"
+
+static int nb_child_to_wait=0;
+
+#undef DEBUG_THREADS
+
+/** Register a new process (by just increasing the number of children */
+void new_process()
+{
+	nb_child_to_wait++;
+#ifdef DEBUG_THREADS
+	debug("New Child. Nb child to wait : %d",nb_child_to_wait);
+#endif
+}
+
+/** Wait for a given process - not registered - and see if others exited */
+int wait_process(int pid)
+{
+    int val, status;
+    do {
+        val = wait(&status);
+        if (val == -1) {
+            if (errno == EINTR)
+                continue;
+            /* shouldn't happen */
+            syslog(LOG_WARNING, "announce: wait: %s", strerror(errno));
+            return 1;
+        }
+        if (val != pid) {
+            nb_child_to_wait--;
+#ifdef DEBUG_THREADS
+            debug("Child exited. Nb child to wait : %d",nb_child_to_wait);
+#endif
+        }
+    } while (val != pid);
+    return status;
+}
+
+/** Wait for children (if any) to exit. Return 1 if no more child to wait */
+int ack_process()
+{
+   if (nb_child_to_wait>0)
+   {
+        int pid;
+        do {
+            pid = waitpid(-1,0,WNOHANG);
+            if (pid==-1)
+                syslog(LOG_ERR,"Timeout. Error waiting for child.");
+            if ((pid!=0) & (nb_child_to_wait>0)) {
+                nb_child_to_wait--;
+#ifdef DEBUG_THREADS
+                debug("Child exited as expected. Nb child to wait : %d",nb_child_to_wait);
+#endif
+            }
+        } while ((pid>0) && (nb_child_to_wait>0));
+	return 0;
+   } else return 1; /* ok for exiting */
+}
+