endpoint_manager.h

Go to the documentation of this file.

// -------------------------------------------------------------------------------------------
// Copyright Amazon.com Inc. or its affiliates. All Rights Reserved.
// This file is part of the AWS CDI-SDK, licensed under the BSD 2-Clause "Simplified" License.
// License details at: https://github.com/aws/aws-cdi-sdk/blob/mainline/LICENSE
// -------------------------------------------------------------------------------------------
 
#ifndef ENDPOINT_MANAGER_H__
#define ENDPOINT_MANAGER_H__
 
// The configuration.h file must be included first since it can have defines which affect subsequent files.
#include "configuration.h"
 
#include "cdi_core_api.h"
#include "cdi_os_api.h"
#include "private.h"
#include "protocol.h"
 
//*********************************************************************************************************************
//***************************************** START OF DEFINITIONS AND TYPES ********************************************
//*********************************************************************************************************************
 
typedef struct EndpointManagerGlobalState* EndpointManagerGlobalHandle;
 
typedef struct EndpointManagerState* EndpointManagerHandle;
 
typedef enum {
    kEndpointStateIdle,       
    kEndpointStateReset,      
    kEndpointStateStart,      
    kEndpointStateShutdown,   
} EndpointManagerCommand;
 
typedef struct CdiConnectionState CdiConnectionState;
typedef struct AdapterEndpointState AdapterEndpointState;
 
//*********************************************************************************************************************
//******************************************* START OF PUBLIC FUNCTIONS ***********************************************
//*********************************************************************************************************************
 
CdiReturnStatus EndpointManagerCreate(CdiConnectionHandle handle, CdiCoreStatsCallback stats_cb_ptr,
                                      CdiUserCbParameter stats_user_cb_param,
                                      const CdiStatsConfigData* stats_config_ptr,
                                      EndpointManagerHandle* ret_handle_ptr);
 
void EndpointManagerDestroy(EndpointManagerHandle handle);
 
EndpointManagerHandle EndpointManagerConnectionToEndpointManager(CdiConnectionHandle handle);
 
void EndpointManagerRemoteEndpointInfoSet(CdiEndpointHandle handle, const struct sockaddr_in* remote_address_ptr,
                                          const char* stream_name_str);
 
const char* EndpointManagerEndpointStreamNameGet(CdiEndpointHandle handle);
 
const char* EndpointManagerEndpointRemoteIpGet(CdiEndpointHandle handle);
 
int EndpointManagerEndpointRemotePortGet(CdiEndpointHandle handle);
 
const struct sockaddr_in* EndpointManagerEndpointRemoteAddressGet(CdiEndpointHandle handle);
 
CdiReturnStatus EndpointManagerTxCreateEndpoint(EndpointManagerHandle handle, bool is_multi_stream,
                                                const char* dest_ip_addr_str, int dest_port,
                                                const char* stream_name_str,
                                                CdiEndpointHandle* ret_endpoint_handle_ptr);
 
CdiReturnStatus EndpointManagerRxCreateEndpoint(EndpointManagerHandle handle, int dest_port,
                                                const struct sockaddr_in* source_address_ptr,
                                                const char* stream_name_str,
                                                CdiEndpointHandle* ret_endpoint_handle_ptr);
 
CdiReturnStatus EndpointManagerProtocolVersionSet(CdiEndpointHandle handle,
                                                  const CdiProtocolVersionNumber* remote_version_ptr);
 
bool EndpointManagerIsEndpoint(EndpointManagerHandle handle, CdiEndpointHandle endpoint_handle);
 
CdiEndpointHandle EndpointManagerGetFirstEndpoint(EndpointManagerHandle handle);
 
CdiEndpointHandle EndpointManagerGetNextEndpoint(CdiEndpointHandle handle);
 
int EndpointManagerEndpointGetCount(EndpointManagerHandle handle);
 
AdapterEndpointHandle EndpointManagerEndpointToAdapterEndpoint(CdiEndpointHandle handle);
 
CdiSignalType EndpointManagerThreadRegister(EndpointManagerHandle handle, const char* thread_name_str);
 
void EndpointManagerThreadWait(EndpointManagerHandle handle);
 
bool EndpointManagerPoll(CdiEndpointHandle* handle_ptr);
 
bool EndpointManagerPollThreadExit(EndpointManagerHandle handle);
 
CdiSignalType EndpointManagerGetNotificationSignal(EndpointManagerHandle handle);
 
void EndpointManagerQueueEndpointReset(CdiEndpointHandle handle);
 
void EndpointManagerQueueEndpointStart(CdiEndpointHandle handle);
 
void EndpointManagerEndpointDestroy(CdiEndpointHandle handle);
 
void EndpointManagerShutdownConnection(EndpointManagerHandle handle);
 
bool EndpointManagerIsConnectionShuttingDown(EndpointManagerHandle handle);
 
void EndpointManagerConnectionStateChange(CdiEndpointHandle handle, CdiConnectionStatus status_code,
                                          const char* error_msg_str);
 
#endif // ENDPOINT_MANAGER_H__