}
#ifdef __WINDOWS__
-#if 0
-static int wanpipe_api_ioctl(sng_fd_t 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;
-}
-#endif
// Blocking read command. If used after DoApiPollCommand(),
// it will return immediatly, without blocking.
static
}
}
-// Blocking API Poll command.
-static
-USHORT
-DoApiPollCommand(
- sng_fd_t 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(
- sng_fd_t 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
- sng_fd_t 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
#if defined(__WINDOWS__)
int tdmv_api_wait_socket(sng_fd_t fd, int timeout, int flags)
{
#if defined(__WINDOWS__)
+ DWORD ln;
API_POLL_STRUCT api_poll;
memset(&api_poll, 0x00, sizeof(API_POLL_STRUCT));
api_poll.user_flags_bitmap = flags;
api_poll.timeout = timeout;
- if(DoApiPollCommand(fd, &api_poll)) {
+ if (!DeviceIoControl(
+ fd,
+ IoctlApiPoll,
+ (LPVOID)NULL,
+ 0L,
+ (LPVOID)&api_poll,
+ sizeof(API_POLL_STRUCT),
+ (LPDWORD)(&ln),
+ (LPOVERLAPPED)NULL)) {
return -1;
}
projects / thirdparty / freeswitch.git / commitdiff
