move additions to own repo, so that patch contains only modifications

plugins/dns/thread.c

@@ -0,0 +1,111 @@
+#include <stdlib.h>
+
+#define USE_PTHREAD
+
+#ifdef WIN32
+
+#include <windows.h>
+#define pthread_t DWORD
+#define pipe(a) _pipe(a,4096,_O_BINARY)
+
+#else
+#ifdef USE_PTHREAD
+
+#include <pthread.h>
+
+#else
+
+#include <sys/types.h>
+#include <sys/wait.h>
+#include <signal.h>
+#define pthread_t int
+
+#endif
+#endif
+
+
+typedef struct
+{
+	pthread_t threadid;
+	int pipe_fd[2];
+	void *userdata;
+} thread;
+
+thread *
+thread_new (void)
+{
+	thread *th;
+
+	th = calloc (1, sizeof (*th));
+	if (!th)
+		return NULL;
+
+	if (pipe (th->pipe_fd) == -1)
+	{
+		free (th);
+		return NULL;
+	}
+
+#ifdef __EMX__ /* os/2 */
+	setmode (pipe_fd[0], O_BINARY);
+	setmode (pipe_fd[1], O_BINARY);
+#endif
+
+	return th;
+}
+
+int
+thread_start (thread *th, void *(*start_routine)(void *), void *arg)
+{
+	pthread_t id;
+
+#ifdef WIN32
+	CloseHandle (CreateThread (NULL, 0,
+										(LPTHREAD_START_ROUTINE)start_routine,
+										arg, 0, (DWORD *)&id));
+#else
+#ifdef USE_PTHREAD
+	if (pthread_create (&id, NULL, start_routine, arg) != 0)
+		return 0;
+#else
+	switch (id = fork ())
+	{
+	case -1:
+		return 0;
+	case 0:
+		/* this is the child */
+		setuid (getuid ());
+		start_routine (arg);
+		_exit (0);
+	}
+#endif
+#endif
+
+	th->threadid = id;
+
+	return 1;
+}
+
+/*void
+thread_kill (thread *th)
+{
+#ifdef WIN32
+	PostThreadMessage (th->threadid, WM_QUIT, 0, 0);
+#else
+#ifdef USE_PTHREAD
+	pthread_cancel (th->threadid);
+	pthread_join (th->threadid, (void *)&th);
+#else
+	kill (th->threadid, SIGKILL);
+	waitpid (th->threadid, NULL, 0);
+#endif
+#endif
+}
+
+void
+thread_free (thread *th)
+{
+	close (th->pipe_fd[0]);
+	close (th->pipe_fd[1]);
+	free (th);
+}*/