/*
 * Copyright (c) 2007 Wayne Meissner. All rights reserved.
 *
 * For licensing, see LICENSE.SPECS
 */

#ifdef _WIN32
#include <windows.h>
#include "PipeHelper.h"

int pipeHelperCreatePipe(FD_TYPE pipefd[2])
{
    char name[ MAX_PATH ];
    static int pipe_idx = 0;
    sprintf( name, "\\\\.\\Pipe\\pipeHelper-%u-%i",
             (unsigned int)GetCurrentProcessId(), pipe_idx++ );

    pipefd[0] = CreateNamedPipe( name, PIPE_ACCESS_INBOUND | FILE_FLAG_OVERLAPPED,
                         PIPE_TYPE_BYTE | PIPE_WAIT,
                         1,             // Number of pipes
                         5,         // Out buffer size
                         5,         // In buffer size
                         60 * 1000,    // Timeout in ms
                         NULL );
    if(pipefd[0] == INVALID_HANDLE_VALUE)
        return -1;

    pipefd[1] = CreateFile( name, GENERIC_WRITE, 0, NULL,
                        OPEN_EXISTING,
                        FILE_ATTRIBUTE_NORMAL,
                        NULL);

    if(pipefd[1] == INVALID_HANDLE_VALUE) {
        CloseHandle( pipefd[0] );
        return -1;
    }
    return 0;
}

char pipeHelperReadChar(FD_TYPE fd, int timeout)
{
    char d;
    OVERLAPPED ovl;
    ZeroMemory(&ovl, sizeof(ovl));
    ovl.hEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
    if( ReadFile(fd, &d, 1, NULL, &ovl) == 0) {
        DWORD recvd = 0;;
        DWORD res = WaitForSingleObject(ovl.hEvent, timeout * 1000);
        if( res != WAIT_OBJECT_0 ) {
            CloseHandle(ovl.hEvent);
            return 0;
        }
        if( GetOverlappedResult(fd, &ovl, &recvd, FALSE) == 0 ) {
            CloseHandle(ovl.hEvent);
            return 0;
        }
    }
    CloseHandle(ovl.hEvent);
    return d;
}

int pipeHelperWriteChar(FD_TYPE fd, char c)
{
    DWORD written;
    return WriteFile(fd, &c, 1, &written, NULL) == 0 ? 0 : 1;
}

void pipeHelperClosePipe(FD_TYPE fd) {
    CloseHandle(fd);
}

#endif