mirror of
https://github.com/signalwire/freeswitch.git
synced 2025-08-13 09:36:46 +00:00
step towards building on windows again.
git-svn-id: http://svn.openzap.org/svn/openzap/trunk@27 a93c3328-9c30-0410-af19-c9cd2b2d52af
This commit is contained in:
Michael Jerris
@@ -36,6 +36,19 @@
|
||||
|
||||
#define _XOPEN_SOURCE 500
|
||||
|
||||
#ifndef HAVE_STRINGS_H
|
||||
#define HAVE_STRINGS_H 1
|
||||
#endif
|
||||
#ifndef HAVE_SYS_SOCKET_H
|
||||
#define HAVE_SYS_SOCKET_H 1
|
||||
#endif
|
||||
|
||||
#ifndef __WINDOWS__
|
||||
#if defined(WIN32) || defined(WIN64) || defined(_MSC_VER) || defined(_WIN32)
|
||||
#define __WINDOWS__
|
||||
#endif
|
||||
#endif
|
||||
|
||||
#ifdef _MSC_VER
|
||||
#if (_MSC_VER >= 1400) /* VC8+ */
|
||||
#ifndef _CRT_SECURE_NO_DEPRECATE
|
||||
@@ -51,12 +64,17 @@
|
||||
#ifndef snprintf
|
||||
#define snprintf _snprintf
|
||||
#endif
|
||||
#undef HAVE_STRINGS_H
|
||||
#undef HAVE_SYS_SOCKET_H
|
||||
/* disable warning for zero length array in a struct */
|
||||
/* this will cause errors on c99 and ansi compliant compilers and will need to be fixed in the wanpipe header files */
|
||||
#pragma warning(disable:4706)
|
||||
#endif
|
||||
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
#ifndef _MSC_VER
|
||||
#ifdef HAVE_STRINGS_H
|
||||
#include <strings.h>
|
||||
#endif
|
||||
#include <assert.h>
|
||||
|
||||
363
libs/freetdm/src/include/zap_wanpipe_windows.h
Normal file
363
libs/freetdm/src/include/zap_wanpipe_windows.h
Normal file
@@ -0,0 +1,363 @@
|
||||
/*****************************************************************************
|
||||
* win_api_common.h Windows Sangoma API Code Library
|
||||
*
|
||||
* Author(s): David Rokhvarg <davidr@sangoma.com>
|
||||
*
|
||||
* Copyright: (c) 1984-2006 Sangoma Technologies Inc.
|
||||
*
|
||||
* ============================================================================
|
||||
*/
|
||||
|
||||
#ifndef _WIN_API_COMMON_H
|
||||
#define _WIN_API_COMMON_H
|
||||
|
||||
#define DEV_NAME_LEN 100
|
||||
char device_name[DEV_NAME_LEN];
|
||||
|
||||
/* IOCTL management structures and variables*/
|
||||
wan_udp_hdr_t wan_udp;
|
||||
|
||||
static wan_cmd_api_t api_cmd;
|
||||
static api_tx_hdr_t *tx_hdr = (api_tx_hdr_t *)api_cmd.data;
|
||||
|
||||
/* keeps the LAST (and single) event received */
|
||||
static wp_tdm_api_rx_hdr_t last_tdm_api_event_buffer;
|
||||
|
||||
static
|
||||
int
|
||||
tdmv_api_ioctl(
|
||||
HANDLE fd,
|
||||
wanpipe_tdm_api_cmd_t *tdm_api_cmd
|
||||
)
|
||||
{
|
||||
DWORD ln;
|
||||
unsigned char id = 0;
|
||||
int err = 0;
|
||||
|
||||
wan_udp.wan_udphdr_request_reply = 0x01;
|
||||
wan_udp.wan_udphdr_id = id;
|
||||
wan_udp.wan_udphdr_return_code = WAN_UDP_TIMEOUT_CMD;
|
||||
|
||||
wan_udp.wan_udphdr_command = WAN_TDMV_API_IOCTL;
|
||||
wan_udp.wan_udphdr_data_len = sizeof(wanpipe_tdm_api_cmd_t);
|
||||
|
||||
//copy data from caller's buffer to driver's buffer
|
||||
memcpy( wan_udp.wan_udphdr_data,
|
||||
(void*)tdm_api_cmd,
|
||||
sizeof(wanpipe_tdm_api_cmd_t));
|
||||
|
||||
if(DeviceIoControl(
|
||||
fd,
|
||||
IoctlManagementCommand,
|
||||
(LPVOID)&wan_udp,
|
||||
sizeof(wan_udp_hdr_t),
|
||||
(LPVOID)&wan_udp,
|
||||
sizeof(wan_udp_hdr_t),
|
||||
(LPDWORD)(&ln),
|
||||
(LPOVERLAPPED)NULL
|
||||
) == FALSE){
|
||||
//actual ioctl failed
|
||||
err = 1;
|
||||
return err;
|
||||
}else{
|
||||
err = 0;
|
||||
}
|
||||
|
||||
if(wan_udp.wan_udphdr_return_code != WAN_CMD_OK){
|
||||
//ioctl ok, but command failed
|
||||
return 2;
|
||||
}
|
||||
|
||||
//copy data from driver's buffer to caller's buffer
|
||||
memcpy( (void*)tdm_api_cmd,
|
||||
wan_udp.wan_udphdr_data,
|
||||
sizeof(wanpipe_tdm_api_cmd_t));
|
||||
return 0;
|
||||
}
|
||||
|
||||
static
|
||||
int
|
||||
wanpipe_api_ioctl(
|
||||
HANDLE fd,
|
||||
wan_cmd_api_t *api_cmd
|
||||
)
|
||||
{
|
||||
DWORD ln;
|
||||
unsigned char id = 0;
|
||||
int err = 0;
|
||||
|
||||
wan_udp.wan_udphdr_request_reply = 0x01;
|
||||
wan_udp.wan_udphdr_id = id;
|
||||
wan_udp.wan_udphdr_return_code = WAN_UDP_TIMEOUT_CMD;
|
||||
|
||||
wan_udp.wan_udphdr_command = SIOC_WANPIPE_API;
|
||||
wan_udp.wan_udphdr_data_len = sizeof(wan_cmd_api_t);
|
||||
|
||||
//copy data from caller's buffer to driver's buffer
|
||||
memcpy( wan_udp.wan_udphdr_data,
|
||||
(void*)api_cmd,
|
||||
sizeof(wan_cmd_api_t));
|
||||
|
||||
if(DeviceIoControl(
|
||||
fd,
|
||||
IoctlManagementCommand,
|
||||
(LPVOID)&wan_udp,
|
||||
sizeof(wan_udp_hdr_t),
|
||||
(LPVOID)&wan_udp,
|
||||
sizeof(wan_udp_hdr_t),
|
||||
(LPDWORD)(&ln),
|
||||
(LPOVERLAPPED)NULL
|
||||
) == FALSE){
|
||||
err = 1;
|
||||
return err;
|
||||
}else{
|
||||
err = 0;
|
||||
}
|
||||
|
||||
if(wan_udp.wan_udphdr_return_code != WAN_CMD_OK){
|
||||
return 2;
|
||||
}
|
||||
|
||||
//copy data from driver's buffer to caller's buffer
|
||||
memcpy( (void*)api_cmd,
|
||||
wan_udp.wan_udphdr_data,
|
||||
sizeof(wan_cmd_api_t));
|
||||
return 0;
|
||||
}
|
||||
|
||||
// Blocking read command. If used after DoApiPollCommand(),
|
||||
// it will return immediatly, without blocking.
|
||||
static
|
||||
USHORT
|
||||
DoReadCommand(
|
||||
HANDLE drv,
|
||||
RX_DATA_STRUCT * pRx
|
||||
)
|
||||
{
|
||||
DWORD ln;
|
||||
|
||||
if (DeviceIoControl(
|
||||
drv,
|
||||
IoctlReadCommand,
|
||||
(LPVOID)NULL,
|
||||
0L,
|
||||
(LPVOID)pRx,
|
||||
sizeof(RX_DATA_STRUCT),
|
||||
(LPDWORD)(&ln),
|
||||
(LPOVERLAPPED)NULL
|
||||
) == FALSE){
|
||||
//check messages log
|
||||
return 1;
|
||||
}else{
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
// Blocking write command. If used after DoApiPollCommand(),
|
||||
// it will return immediatly, without blocking.
|
||||
static
|
||||
UCHAR
|
||||
DoWriteCommand(
|
||||
HANDLE drv,
|
||||
TX_DATA_STRUCT * pTx
|
||||
)
|
||||
{
|
||||
DWORD ln;
|
||||
|
||||
if(DeviceIoControl(
|
||||
drv,
|
||||
IoctlWriteCommand,
|
||||
(LPVOID)pTx,
|
||||
(ULONG)sizeof(TX_DATA_STRUCT),
|
||||
(LPVOID)pTx,
|
||||
sizeof(TX_DATA_STRUCT),
|
||||
(LPDWORD)(&ln),
|
||||
(LPOVERLAPPED)NULL
|
||||
) == FALSE){
|
||||
return 1;
|
||||
}else{
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
// Blocking API Poll command.
|
||||
static
|
||||
USHORT
|
||||
DoApiPollCommand(
|
||||
HANDLE drv,
|
||||
API_POLL_STRUCT *api_poll_ptr
|
||||
)
|
||||
{
|
||||
DWORD ln;
|
||||
|
||||
if (DeviceIoControl(
|
||||
drv,
|
||||
IoctlApiPoll,
|
||||
(LPVOID)NULL,
|
||||
0L,
|
||||
(LPVOID)api_poll_ptr,
|
||||
sizeof(API_POLL_STRUCT),
|
||||
(LPDWORD)(&ln),
|
||||
(LPOVERLAPPED)NULL
|
||||
) == FALSE){
|
||||
return 1;
|
||||
}else{
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
static
|
||||
int
|
||||
DoManagementCommand(
|
||||
HANDLE drv,
|
||||
wan_udp_hdr_t* wan_udp
|
||||
)
|
||||
{
|
||||
DWORD ln;
|
||||
static unsigned char id = 0;
|
||||
|
||||
wan_udp->wan_udphdr_request_reply = 0x01;
|
||||
wan_udp->wan_udphdr_id = id++;
|
||||
wan_udp->wan_udphdr_return_code = WAN_UDP_TIMEOUT_CMD;
|
||||
|
||||
if(DeviceIoControl(
|
||||
drv,
|
||||
IoctlManagementCommand,
|
||||
(LPVOID)wan_udp,
|
||||
sizeof(wan_udp_hdr_t),
|
||||
(LPVOID)wan_udp,
|
||||
sizeof(wan_udp_hdr_t),
|
||||
(LPDWORD)(&ln),
|
||||
(LPOVERLAPPED)NULL
|
||||
) == FALSE){
|
||||
return 1;
|
||||
}else{
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
///////////////////////////////////////////////////////////////////////////
|
||||
//
|
||||
//structures and definitions used for queueing data
|
||||
//
|
||||
typedef struct
|
||||
{
|
||||
void* previous;
|
||||
TX_RX_DATA_STRUCT tx_rx_data;
|
||||
}api_queue_element_t;
|
||||
|
||||
#define API_Q_MUTEX_TIMEOUT 1000//1 second
|
||||
#define API_Q_MAX_SIZE 100//optimal length. for short data may need longer queue
|
||||
|
||||
enum API_Q_STATUS{
|
||||
API_Q_SUCCESS=0,
|
||||
API_Q_GEN_FAILURE,
|
||||
API_Q_MEM_ALLOC_FAILURE,
|
||||
API_Q_FULL,
|
||||
API_Q_EMPTY
|
||||
};
|
||||
|
||||
typedef struct
|
||||
{
|
||||
//number of nodes in the list
|
||||
USHORT size;
|
||||
//insert at tail
|
||||
api_queue_element_t * tail;
|
||||
//remove from head
|
||||
api_queue_element_t * head;
|
||||
//mutex for synchronizing access to the queue
|
||||
HANDLE api_queue_mutex;
|
||||
}api_queue_t;
|
||||
|
||||
|
||||
static __inline int api_enqueue( api_queue_t* api_queue,
|
||||
unsigned char * buffer,
|
||||
unsigned short length)
|
||||
{
|
||||
api_queue_element_t *element;
|
||||
DWORD mresult;
|
||||
|
||||
mresult = WaitForSingleObject(api_queue->api_queue_mutex, API_Q_MUTEX_TIMEOUT);
|
||||
if (mresult != WAIT_OBJECT_0) {
|
||||
return API_Q_GEN_FAILURE;
|
||||
}
|
||||
|
||||
if(api_queue->size == API_Q_MAX_SIZE){
|
||||
ReleaseMutex(api_queue->api_queue_mutex);
|
||||
return API_Q_FULL;
|
||||
}
|
||||
|
||||
element = malloc(sizeof(api_queue_element_t));
|
||||
if(element == NULL){
|
||||
ReleaseMutex(api_queue->api_queue_mutex);
|
||||
return API_Q_MEM_ALLOC_FAILURE;
|
||||
}
|
||||
|
||||
//now copy everything in to the element
|
||||
memcpy(element->tx_rx_data.data, buffer, length);
|
||||
|
||||
element->tx_rx_data.api_header.data_length = length;
|
||||
element->tx_rx_data.api_header.operation_status = SANG_STATUS_TX_TIMEOUT;
|
||||
|
||||
//insert element at the tail of the queue
|
||||
element->previous = NULL;
|
||||
|
||||
if(api_queue->size == 0){
|
||||
//special case of a previously empty queue
|
||||
api_queue->head = element;
|
||||
api_queue->tail = element;
|
||||
}else{
|
||||
api_queue->tail->previous = element;
|
||||
api_queue->tail = element;
|
||||
}
|
||||
api_queue->size++;
|
||||
ReleaseMutex(api_queue->api_queue_mutex);
|
||||
return API_Q_SUCCESS;
|
||||
}
|
||||
|
||||
static __inline int api_dequeue( api_queue_t* api_queue,
|
||||
TX_RX_DATA_STRUCT* destination)
|
||||
{
|
||||
api_queue_element_t *element;
|
||||
DWORD mresult;
|
||||
|
||||
mresult = WaitForSingleObject(api_queue->api_queue_mutex, API_Q_MUTEX_TIMEOUT);
|
||||
if (mresult != WAIT_OBJECT_0) {
|
||||
return API_Q_GEN_FAILURE;
|
||||
}
|
||||
|
||||
if(api_queue->size == 0){
|
||||
//tx queue is empty
|
||||
ReleaseMutex(api_queue->api_queue_mutex);
|
||||
return API_Q_EMPTY;
|
||||
}
|
||||
|
||||
//remove from the head of the queue
|
||||
element = api_queue->head;
|
||||
api_queue->head = element->previous;
|
||||
|
||||
//now copy everything in to the user buffer
|
||||
memcpy(destination, &element->tx_rx_data, sizeof(TX_DATA_STRUCT));
|
||||
|
||||
free(element);
|
||||
api_queue->size--;
|
||||
if(api_queue->size == 0){
|
||||
api_queue->head = NULL;
|
||||
api_queue->tail = NULL;
|
||||
}
|
||||
ReleaseMutex(api_queue->api_queue_mutex);
|
||||
return API_Q_SUCCESS;
|
||||
}
|
||||
|
||||
//remove all elements from the queue
|
||||
static __inline void empty_api_queue(api_queue_t* api_queue)
|
||||
{
|
||||
TX_DATA_STRUCT tx_rx_data;
|
||||
|
||||
while(api_dequeue(api_queue, &tx_rx_data) == 0){
|
||||
;
|
||||
}
|
||||
}
|
||||
|
||||
///////////////////////////////////////////////////////////////////////////
|
||||
#endif /* _WIN_API_COMMON_H */
|
||||
Reference in New Issue
Block a user