globus_i_xio_win32.h

/*
 * Copyright 1999-2014 University of Chicago
 * 
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * 
 * http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#ifndef GLOBUS_I_XIO_WIN32_H_
#define GLOBUS_I_XIO_WIN32_H_

#include "globus_i_xio_system_common.h"
#include <windows.h>
#include <process.h>
#include <winsock2.h>

typedef struct globus_l_xio_win32_event_entry_s *
    globus_i_xio_win32_event_entry_t;
    
typedef
globus_bool_t
(*globus_i_xio_win32_event_cb_t)(
    void *                              user_arg);

globus_result_t
globus_i_xio_win32_event_register(
    globus_i_xio_win32_event_entry_t *  entry_handle,
    HANDLE                              event_handle,
    globus_i_xio_win32_event_cb_t       callback,
    void *                              user_arg);

void
globus_i_xio_win32_event_unregister(
    globus_i_xio_win32_event_entry_t    entry_handle);

void
globus_i_xio_win32_event_lock(
    globus_i_xio_win32_event_entry_t    entry_handle);

void
globus_i_xio_win32_event_unlock(
    globus_i_xio_win32_event_entry_t    entry_handle);

void
globus_i_xio_win32_event_post(
    globus_i_xio_win32_event_entry_t    entry_handle);

int
globus_i_xio_win32_complete_activate(void);

int
globus_i_xio_win32_complete_deactivate(void);

int
globus_i_xio_win32_file_activate(void);

int
globus_i_xio_win32_file_deactivate(void);

globus_result_t
globus_i_xio_win32_complete(
    globus_callback_func_t              callback,
    void *                              user_arg);

int
globus_i_xio_win32_mode_activate(void);

globus_bool_t
globus_i_xio_win32_mode_is_overlapped(
    HANDLE                              handle);

typedef CRITICAL_SECTION win32_mutex_t;

#define win32_mutex_init(x, y) InitializeCriticalSection(x)
#define win32_mutex_destroy(x) DeleteCriticalSection(x)
#define win32_mutex_lock(x) EnterCriticalSection(x)
#define win32_mutex_unlock(x) LeaveCriticalSection(x)

#define GlobusXIOSystemDebugSysError(message, err)                          \
    do                                                                      \
    {                                                                       \
        if(GlobusDebugTrue(                                                 \
            GLOBUS_XIO_SYSTEM, GLOBUS_I_XIO_SYSTEM_DEBUG_INFO))             \
        {                                                                   \
            char *                      msg = NULL;                         \
            int                         err_ = err;                         \
                                                                            \
            FormatMessage(                                                  \
                FORMAT_MESSAGE_ALLOCATE_BUFFER|FORMAT_MESSAGE_FROM_SYSTEM,  \
                NULL,                                                       \
                err_,                                                       \
                0,                                                          \
                (LPTSTR)&msg,                                               \
                0,                                                          \
                NULL);                                                      \
                                                                            \
            GlobusDebugMyPrintf(                                            \
                GLOBUS_XIO_SYSTEM,                                          \
                ("[%s] %s: %d:%s", _xio_name, message, err_, msg));         \
                                                                            \
            if(msg)                                                         \
            {                                                               \
                LocalFree(msg);                                             \
            }                                                               \
        }                                                                   \
    } while(0)

#endif