ConnectionListener.h

Go to the documentation of this file.

/*******************************************
Connection Listener internal include file
*******************************************/
#ifndef __KINESIS_VIDEO_WEBRTC_CONNECTION_LISTENER__
#define __KINESIS_VIDEO_WEBRTC_CONNECTION_LISTENER__
 
#pragma once
 
#ifdef __cplusplus
extern "C" {
#endif
 
#define CONNECTION_LISTENER_SOCKET_WAIT_FOR_DATA_TIMEOUT     (200 * HUNDREDS_OF_NANOS_IN_A_MILLISECOND)
#define CONNECTION_LISTENER_SHUTDOWN_TIMEOUT                 (1000 * HUNDREDS_OF_NANOS_IN_A_MILLISECOND)
#define CONNECTION_LISTENER_DEFAULT_MAX_LISTENING_CONNECTION 64
#define CONNECTION_LISTENER_KICK_SOCKET_LISTEN               0
#define CONNECTION_LISTENER_KICK_SOCKET_WRITE                1
 
typedef struct {
    volatile ATOMIC_BOOL terminate;
    PSocketConnection sockets[CONNECTION_LISTENER_DEFAULT_MAX_LISTENING_CONNECTION];
    UINT64 socketCount;
    MUTEX lock;
    TID receiveDataRoutine;
    PBYTE pBuffer;
    UINT64 bufferLen;
#ifndef _WIN32
    INT32 kickSocket[2];
#endif
} ConnectionListener, *PConnectionListener;
 
STATUS createConnectionListener(PConnectionListener*);
 
STATUS freeConnectionListener(PConnectionListener*);
 
STATUS connectionListenerAddConnection(PConnectionListener, PSocketConnection);
 
STATUS connectionListenerRemoveConnection(PConnectionListener, PSocketConnection);
 
STATUS connectionListenerRemoveAllConnection(PConnectionListener);
 
STATUS connectionListenerStart(PConnectionListener);
 
// internal functionalities
PVOID connectionListenerReceiveDataRoutine(PVOID arg);
 
#ifdef __cplusplus
}
#endif
#endif /* __KINESIS_VIDEO_WEBRTC_CONNECTION_LISTENER__ */