7ea33eac02
libevent-1.1a. svn merge -r10917:11006 https://svn.open-mpi.org/svn/ompi/tmp/libevent-update This commit was SVN r11022. The following SVN revisions from the original message are invalid or inconsistent and therefore were not cross-referenced: r10917 r11006
84 строки
1.9 KiB
C
84 строки
1.9 KiB
C
#include "opal_config.h"
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <windows.h>
|
|
#include <sys/timeb.h>
|
|
#include <time.h>
|
|
|
|
/****************************************************************************
|
|
*
|
|
* Function: gettimeofday(struct timeval *, struct timezone *)
|
|
*
|
|
* Purpose: Get current time of day.
|
|
*
|
|
* Arguments: tv => Place to store the curent time of day.
|
|
* tz => Ignored.
|
|
*
|
|
* Returns: 0 => Success.
|
|
*
|
|
****************************************************************************/
|
|
|
|
int gettimeofday(struct timeval *tv, struct timezone *tz) {
|
|
struct _timeb tb;
|
|
|
|
if(tv == NULL)
|
|
return -1;
|
|
|
|
_ftime(&tb);
|
|
tv->tv_sec = tb.time;
|
|
tv->tv_usec = ((int) tb.millitm) * 1000;
|
|
return 0;
|
|
}
|
|
|
|
int
|
|
win_read(int fd, void *buf, unsigned int length)
|
|
{
|
|
DWORD dwBytesRead;
|
|
int res = ReadFile((HANDLE) fd, buf, length, &dwBytesRead, NULL);
|
|
if (res == 0) {
|
|
DWORD error = GetLastError();
|
|
if (error == ERROR_NO_DATA)
|
|
return (0);
|
|
return (-1);
|
|
} else
|
|
return (dwBytesRead);
|
|
}
|
|
|
|
int
|
|
win_write(int fd, void *buf, unsigned int length)
|
|
{
|
|
DWORD dwBytesWritten;
|
|
int res = WriteFile((HANDLE) fd, buf, length, &dwBytesWritten, NULL);
|
|
if (res == 0) {
|
|
DWORD error = GetLastError();
|
|
if (error == ERROR_NO_DATA)
|
|
return (0);
|
|
return (-1);
|
|
} else
|
|
return (dwBytesWritten);
|
|
}
|
|
|
|
int
|
|
socketpair(int d, int type, int protocol, int *sv)
|
|
{
|
|
static int count;
|
|
char buf[64];
|
|
HANDLE fd;
|
|
DWORD dwMode;
|
|
sprintf(buf, "\\\\.\\pipe\\levent-%d", count++);
|
|
/* Create a duplex pipe which will behave like a socket pair */
|
|
fd = CreateNamedPipe(buf, PIPE_ACCESS_DUPLEX, PIPE_TYPE_BYTE | PIPE_NOWAIT,
|
|
PIPE_UNLIMITED_INSTANCES, 4096, 4096, 0, NULL);
|
|
if (fd == INVALID_HANDLE_VALUE)
|
|
return (-1);
|
|
sv[0] = (int)fd;
|
|
|
|
fd = CreateFile(buf, GENERIC_READ|GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
|
|
if (fd == INVALID_HANDLE_VALUE)
|
|
return (-1);
|
|
dwMode = PIPE_NOWAIT;
|
|
SetNamedPipeHandleState(fd, &dwMode, NULL, NULL);
|
|
sv[1] = (int)fd;
|
|
|
|
return (0);
|
|
} |