efl/legacy/evil/src/bin/test_pipe.c

101 lines
1.7 KiB
C

#include <stdlib.h>
#include <stdio.h>
# define WIN32_LEAN_AND_MEAN
# include <winsock2.h>
# undef WIN32_LEAN_AND_MEAN
#include "Evil.h"
#define FDREAD 0
#define FDWRITE 1
typedef struct
{
int val;
int fd_write;
} data;
DWORD WINAPI
thread (void *param)
{
data *d;
void *buf[1];
Sleep (2 * 1000);
d = (data *)param;
buf[0] = d;
send(d->fd_write, (char *)buf, sizeof(buf), 0);
return 0;
}
int
main (int argc, char *argv[])
{
int sockets[2];
int ret;
fd_set rfds;
struct timeval t;
data *d;
DWORD thread_id;
HANDLE h;
if (!evil_sockets_init())
return EXIT_FAILURE;
FD_ZERO(&rfds);
t.tv_sec = 5;
t.tv_usec = 0;
if (pipe(sockets) < 0)
{
printf ("can not create sockets\n");
evil_sockets_shutdown();
return EXIT_FAILURE;
}
FD_SET(sockets[FDREAD], &rfds);
d = (data *)malloc(sizeof (data));
d->val = 14;
d->fd_write = sockets[FDWRITE];
printf (" pointer sent........: %p\n", d);
h = CreateThread(NULL, 0, thread, d, 0, &thread_id);
ret = select(sockets[FDREAD] + 1, &rfds, NULL, NULL, &t);
if (ret < 0) return -1;
if (ret == 0) {
printf ("temps expire\n");
}
if (ret > 0)
{
data *d;
int len;
int j = 0;
void *buf[1];
while ((len = recv(sockets[FDREAD], (char *)buf, sizeof(buf), 0)) > 0)
{
if (len == sizeof(buf))
{
d = buf[0];
printf (" pointer received....: %p\n", d);
j = d->val;
printf (" value (should be 14) : %d\n", j);
}
}
}
CloseHandle (h);
evil_sockets_shutdown();
return EXIT_SUCCESS;
}