112 lines
1.5 KiB
C
112 lines
1.5 KiB
C
|
#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);
|
||
|
|
}*/
|