Include.h

Go to the documentation of this file.

/*
 * Main public include file
 */
#ifndef __KINESIS_VIDEO_WEBRTC_CLIENT_INCLUDE__
#define __KINESIS_VIDEO_WEBRTC_CLIENT_INCLUDE__
 
#pragma once
 
#ifdef __cplusplus
extern "C" {
#endif
 
// Public headers
#if defined(__clang__)
#pragma clang diagnostic push
#pragma clang diagnostic ignored "-Wgnu-zero-variadic-macro-arguments"
#endif
#include <com/amazonaws/kinesis/video/client/Include.h>
#include <com/amazonaws/kinesis/video/common/Include.h>
#include <com/amazonaws/kinesis/video/webrtcclient/NullableDefs.h>
#include <com/amazonaws/kinesis/video/webrtcclient/Stats.h>
#if defined(__clang__)
#pragma clang diagnostic pop
#endif
 
/* TODO: Potentially move these call to PIC instead. Moving to PIC in the future would not cause any backward compatibility issues */
 
#ifdef INCREASE_PRECISION_TIMING_LOGS
 
#define PROFILE_CALL(f, msg)                                                                                                                         \
    do {                                                                                                                                             \
        startTimeInMacro = GETTIME();                                                                                                                \
        f;                                                                                                                                           \
        UINT64 __dt = GETTIME() - startTimeInMacro;                                                                                                  \
        DLOGP("[%s] Time taken: %" PRIu64 ".%02" PRIu64 " ms", (msg), __dt / HUNDREDS_OF_NANOS_IN_A_MILLISECOND,                                     \
              (__dt % HUNDREDS_OF_NANOS_IN_A_MILLISECOND) / (HUNDREDS_OF_NANOS_IN_A_MILLISECOND / 100));                                             \
    } while (FALSE)
 
#define PROFILE_CALL_WITH_T_OBJ(f, t, msg)                                                                                                           \
    do {                                                                                                                                             \
        startTimeInMacro = GETTIME();                                                                                                                \
        f;                                                                                                                                           \
        UINT64 __dt = GETTIME() - startTimeInMacro;                                                                                                  \
        t = __dt / HUNDREDS_OF_NANOS_IN_A_MILLISECOND;                                                                                               \
        DLOGP("[%s] Time taken: %" PRIu64 ".%02" PRIu64 " ms", (msg), __dt / HUNDREDS_OF_NANOS_IN_A_MILLISECOND,                                     \
              (__dt % HUNDREDS_OF_NANOS_IN_A_MILLISECOND) / (HUNDREDS_OF_NANOS_IN_A_MILLISECOND / 100));                                             \
    } while (FALSE)
 
#define PROFILE_WITH_START_TIME(t, msg)                                                                                                              \
    do {                                                                                                                                             \
        UINT64 __dt = GETTIME() - (t);                                                                                                               \
        DLOGP("[%s] Time taken: %" PRIu64 ".%02" PRIu64 " ms", msg, __dt / HUNDREDS_OF_NANOS_IN_A_MILLISECOND,                                       \
              (__dt % HUNDREDS_OF_NANOS_IN_A_MILLISECOND) / (HUNDREDS_OF_NANOS_IN_A_MILLISECOND / 100));                                             \
    } while (FALSE)
 
#define PROFILE_CALL_WITH_START_END_T_OBJ(f, s, e, d, msg)                                                                                           \
    do {                                                                                                                                             \
        UINT64 __s = GETTIME();                                                                                                                      \
        f;                                                                                                                                           \
        UINT64 __e = GETTIME();                                                                                                                      \
        UINT64 __dt = __e - __s;                                                                                                                     \
        s = __s / HUNDREDS_OF_NANOS_IN_A_MILLISECOND;                                                                                                \
        e = __e / HUNDREDS_OF_NANOS_IN_A_MILLISECOND;                                                                                                \
        d = ((e) - (s));                                                                                                                             \
        DLOGP("[%s] Time taken: %" PRIu64 ".%02" PRIu64 " ms", (msg), __dt / HUNDREDS_OF_NANOS_IN_A_MILLISECOND,                                     \
              (__dt % HUNDREDS_OF_NANOS_IN_A_MILLISECOND) / (HUNDREDS_OF_NANOS_IN_A_MILLISECOND / 100));                                             \
    } while (FALSE)
 
#define PROFILE_WITH_START_END_TIME_OBJ(t1, t2, d, msg)                                                                                              \
    do {                                                                                                                                             \
        UINT64 __dt = GETTIME() - (t1);                                                                                                              \
        t1 = (t1 / HUNDREDS_OF_NANOS_IN_A_MILLISECOND);                                                                                              \
        t2 = (GETTIME() / HUNDREDS_OF_NANOS_IN_A_MILLISECOND);                                                                                       \
        d = ((t2) - (t1));                                                                                                                           \
        DLOGP("[%s] Time taken: %" PRIu64 ".%02" PRIu64 " ms", (msg), __dt / HUNDREDS_OF_NANOS_IN_A_MILLISECOND,                                     \
              (__dt % HUNDREDS_OF_NANOS_IN_A_MILLISECOND) / (HUNDREDS_OF_NANOS_IN_A_MILLISECOND / 100));                                             \
    } while (FALSE)
 
#define PROFILE_WITH_START_TIME_OBJ(t1, t2, msg)                                                                                                     \
    do {                                                                                                                                             \
        UINT64 __dt = GETTIME() - (t1);                                                                                                              \
        t2 = __dt / HUNDREDS_OF_NANOS_IN_A_MILLISECOND;                                                                                              \
        DLOGP("[%s] Time taken: %" PRIu64 ".%02" PRIu64 " ms", (msg), __dt / HUNDREDS_OF_NANOS_IN_A_MILLISECOND,                                     \
              (__dt % HUNDREDS_OF_NANOS_IN_A_MILLISECOND) / (HUNDREDS_OF_NANOS_IN_A_MILLISECOND / 100));                                             \
    } while (FALSE)
 
#else // INCREASE_PRECISION_TIMING_LOGS
 
#define PROFILE_CALL(f, msg)                                                                                                                         \
    do {                                                                                                                                             \
        startTimeInMacro = GETTIME();                                                                                                                \
        f;                                                                                                                                           \
        DLOGP("[%s] Time taken: %" PRIu64 " ms", (msg), (GETTIME() - startTimeInMacro) / HUNDREDS_OF_NANOS_IN_A_MILLISECOND);                        \
    } while (FALSE)
 
#define PROFILE_CALL_WITH_T_OBJ(f, t, msg)                                                                                                           \
    do {                                                                                                                                             \
        startTimeInMacro = GETTIME();                                                                                                                \
        f;                                                                                                                                           \
        t = (GETTIME() - startTimeInMacro) / HUNDREDS_OF_NANOS_IN_A_MILLISECOND;                                                                     \
        DLOGP("[%s] Time taken: %" PRIu64 " ms", (msg), (t));                                                                                        \
    } while (FALSE)
 
#define PROFILE_WITH_START_TIME(t, msg)                                                                                                              \
    do {                                                                                                                                             \
        DLOGP("[%s] Time taken: %" PRIu64 " ms", msg, (GETTIME() - (t)) / HUNDREDS_OF_NANOS_IN_A_MILLISECOND);                                       \
    } while (FALSE)
 
#define PROFILE_CALL_WITH_START_END_T_OBJ(f, s, e, d, msg)                                                                                           \
    do {                                                                                                                                             \
        s = GETTIME() / HUNDREDS_OF_NANOS_IN_A_MILLISECOND;                                                                                          \
        f;                                                                                                                                           \
        e = GETTIME() / HUNDREDS_OF_NANOS_IN_A_MILLISECOND;                                                                                          \
        d = ((e) - (s));                                                                                                                             \
        DLOGP("[%s] Time taken: %" PRIu64 " ms", (msg), (d));                                                                                        \
    } while (FALSE)
 
#define PROFILE_WITH_START_END_TIME_OBJ(t1, t2, d, msg)                                                                                              \
    do {                                                                                                                                             \
        t1 = (t1 / HUNDREDS_OF_NANOS_IN_A_MILLISECOND);                                                                                              \
        t2 = (GETTIME() / HUNDREDS_OF_NANOS_IN_A_MILLISECOND);                                                                                       \
        d = ((t2) - (t1));                                                                                                                           \
        DLOGP("[%s] Time taken: %" PRIu64 " ms", (msg), (d));                                                                                        \
    } while (FALSE)
 
#define PROFILE_WITH_START_TIME_OBJ(t1, t2, msg)                                                                                                     \
    do {                                                                                                                                             \
        t2 = (GETTIME() - (t1)) / HUNDREDS_OF_NANOS_IN_A_MILLISECOND;                                                                                \
        DLOGP("[%s] Time taken: %" PRIu64 " ms", (msg), t2);                                                                                         \
    } while (FALSE)
 
#endif // INCREASE_PRECISION_TIMING_LOGS
 
#define STATUS_WEBRTC_BASE 0x55000000
 
 
#define STATUS_SESSION_DESCRIPTION_INIT_NOT_OBJECT                 STATUS_WEBRTC_BASE + 0x00000001
#define STATUS_SESSION_DESCRIPTION_INIT_MISSING_SDP_OR_TYPE_MEMBER STATUS_WEBRTC_BASE + 0x00000002
#define STATUS_SESSION_DESCRIPTION_INIT_INVALID_TYPE               STATUS_WEBRTC_BASE + 0x00000003
#define STATUS_SESSION_DESCRIPTION_INIT_MISSING_SDP                STATUS_WEBRTC_BASE + 0x00000004
#define STATUS_SESSION_DESCRIPTION_INIT_MISSING_TYPE               STATUS_WEBRTC_BASE + 0x00000005
#define STATUS_SESSION_DESCRIPTION_INIT_MAX_SDP_LEN_EXCEEDED       STATUS_WEBRTC_BASE + 0x00000006
#define STATUS_SESSION_DESCRIPTION_INVALID_SESSION_DESCRIPTION     STATUS_WEBRTC_BASE + 0x00000007
#define STATUS_SESSION_DESCRIPTION_MISSING_ICE_VALUES              STATUS_WEBRTC_BASE + 0x00000008
#define STATUS_SESSION_DESCRIPTION_MISSING_CERTIFICATE_FINGERPRINT STATUS_WEBRTC_BASE + 0x00000009
#define STATUS_SESSION_DESCRIPTION_MAX_MEDIA_COUNT                 STATUS_WEBRTC_BASE + 0x0000000A
#define STATUS_SESSION_DESCRIPTION_CODEC_NOT_MAPPED_TO_RTX         STATUS_WEBRTC_BASE + 0x0000000B
 
#define STATUS_SDP_BASE                         STATUS_WEBRTC_BASE + 0x01000000
#define STATUS_SDP_MISSING_ITEMS                STATUS_SDP_BASE + 0x00000001
#define STATUS_SDP_ATTRIBUTES_ERROR             STATUS_SDP_BASE + 0x00000002
#define STATUS_SDP_BANDWIDTH_ERROR              STATUS_SDP_BASE + 0x00000003
#define STATUS_SDP_CONNECTION_INFORMATION_ERROR STATUS_SDP_BASE + 0x00000004
#define STATUS_SDP_EMAIL_ADDRESS_ERROR          STATUS_SDP_BASE + 0x00000005
#define STATUS_SDP_ENCYRPTION_KEY_ERROR         STATUS_SDP_BASE + 0x00000006
#define STATUS_SDP_INFORMATION_ERROR            STATUS_SDP_BASE + 0x00000007
#define STATUS_SDP_MEDIA_NAME_ERROR             STATUS_SDP_BASE + 0x00000008
#define STATUS_SDP_ORIGIN_ERROR                 STATUS_SDP_BASE + 0x00000009
#define STATUS_SDP_PHONE_NUMBER_ERROR           STATUS_SDP_BASE + 0x0000000A
#define STATUS_SDP_TIME_DECRYPTION_ERROR        STATUS_SDP_BASE + 0x0000000B
#define STATUS_SDP_TIMEZONE_ERROR               STATUS_SDP_BASE + 0x0000000C
#define STATUS_SDP_URI_ERROR                    STATUS_SDP_BASE + 0x0000000D
#define STATUS_SDP_VERSION_ERROR                STATUS_SDP_BASE + 0x0000000E
#define STATUS_SDP_ATTRIBUTE_MAX_EXCEEDED       STATUS_SDP_BASE + 0x0000000F
 
#define STATUS_STUN_BASE                                           STATUS_SDP_BASE + 0x01000000
#define STATUS_STUN_MESSAGE_INTEGRITY_NOT_LAST                     STATUS_STUN_BASE + 0x00000001
#define STATUS_STUN_MESSAGE_INTEGRITY_SIZE_ALIGNMENT               STATUS_STUN_BASE + 0x00000002
#define STATUS_STUN_FINGERPRINT_NOT_LAST                           STATUS_STUN_BASE + 0x00000003
#define STATUS_STUN_MAGIC_COOKIE_MISMATCH                          STATUS_STUN_BASE + 0x00000004
#define STATUS_STUN_INVALID_ADDRESS_ATTRIBUTE_LENGTH               STATUS_STUN_BASE + 0x00000005
#define STATUS_STUN_INVALID_USERNAME_ATTRIBUTE_LENGTH              STATUS_STUN_BASE + 0x00000006
#define STATUS_STUN_INVALID_MESSAGE_INTEGRITY_ATTRIBUTE_LENGTH     STATUS_STUN_BASE + 0x00000007
#define STATUS_STUN_INVALID_FINGERPRINT_ATTRIBUTE_LENGTH           STATUS_STUN_BASE + 0x00000008
#define STATUS_STUN_MULTIPLE_MESSAGE_INTEGRITY_ATTRIBUTES          STATUS_STUN_BASE + 0x00000009
#define STATUS_STUN_MULTIPLE_FINGERPRINT_ATTRIBUTES                STATUS_STUN_BASE + 0x0000000A
#define STATUS_STUN_ATTRIBUTES_AFTER_FINGERPRINT_MESSAGE_INTEGRITY STATUS_STUN_BASE + 0x0000000B
#define STATUS_STUN_MESSAGE_INTEGRITY_AFTER_FINGERPRINT            STATUS_STUN_BASE + 0x0000000C
#define STATUS_STUN_MAX_ATTRIBUTE_COUNT                            STATUS_STUN_BASE + 0x0000000D
#define STATUS_STUN_MESSAGE_INTEGRITY_MISMATCH                     STATUS_STUN_BASE + 0x0000000E
#define STATUS_STUN_FINGERPRINT_MISMATCH                           STATUS_STUN_BASE + 0x0000000F
#define STATUS_STUN_INVALID_PRIORITY_ATTRIBUTE_LENGTH              STATUS_STUN_BASE + 0x00000010
#define STATUS_STUN_INVALID_USE_CANDIDATE_ATTRIBUTE_LENGTH         STATUS_STUN_BASE + 0x00000011
#define STATUS_STUN_INVALID_LIFETIME_ATTRIBUTE_LENGTH              STATUS_STUN_BASE + 0x00000012
#define STATUS_STUN_INVALID_REQUESTED_TRANSPORT_ATTRIBUTE_LENGTH   STATUS_STUN_BASE + 0x00000013
#define STATUS_STUN_INVALID_REALM_ATTRIBUTE_LENGTH                 STATUS_STUN_BASE + 0x00000014
#define STATUS_STUN_INVALID_NONCE_ATTRIBUTE_LENGTH                 STATUS_STUN_BASE + 0x00000015
#define STATUS_STUN_INVALID_ERROR_CODE_ATTRIBUTE_LENGTH            STATUS_STUN_BASE + 0x00000016
#define STATUS_STUN_INVALID_ICE_CONTROL_ATTRIBUTE_LENGTH           STATUS_STUN_BASE + 0x00000017
#define STATUS_STUN_INVALID_CHANNEL_NUMBER_ATTRIBUTE_LENGTH        STATUS_STUN_BASE + 0x00000018
#define STATUS_STUN_INVALID_CHANGE_REQUEST_ATTRIBUTE_LENGTH        STATUS_STUN_BASE + 0x00000019
#define STATUS_STUN_ATTRIBUTE_LENGTH_EXCEEDED_BUFFER_SIZE          STATUS_STUN_BASE + 0x0000001A
 
#define STATUS_NETWORKING_BASE                     STATUS_STUN_BASE + 0x01000000
#define STATUS_GET_LOCAL_IP_ADDRESSES_FAILED       STATUS_NETWORKING_BASE + 0x00000016
#define STATUS_CREATE_UDP_SOCKET_FAILED            STATUS_NETWORKING_BASE + 0x00000017
#define STATUS_BINDING_SOCKET_FAILED               STATUS_NETWORKING_BASE + 0x00000018
#define STATUS_GET_PORT_NUMBER_FAILED              STATUS_NETWORKING_BASE + 0x00000019
#define STATUS_SEND_DATA_FAILED                    STATUS_NETWORKING_BASE + 0x0000001a
#define STATUS_RESOLVE_HOSTNAME_FAILED             STATUS_NETWORKING_BASE + 0x0000001b
#define STATUS_HOSTNAME_NOT_FOUND                  STATUS_NETWORKING_BASE + 0x0000001c
#define STATUS_SOCKET_CONNECT_FAILED               STATUS_NETWORKING_BASE + 0x0000001d
#define STATUS_CREATE_SSL_FAILED                   STATUS_NETWORKING_BASE + 0x0000001e
#define STATUS_SSL_CONNECTION_FAILED               STATUS_NETWORKING_BASE + 0x0000001f
#define STATUS_SECURE_SOCKET_READ_FAILED           STATUS_NETWORKING_BASE + 0x00000020
#define STATUS_SOCKET_CONNECTION_NOT_READY_TO_SEND STATUS_NETWORKING_BASE + 0x00000021
#define STATUS_SOCKET_CONNECTION_CLOSED_ALREADY    STATUS_NETWORKING_BASE + 0x00000022
#define STATUS_SOCKET_SET_SEND_BUFFER_SIZE_FAILED  STATUS_NETWORKING_BASE + 0x00000023
#define STATUS_GET_SOCKET_FLAG_FAILED              STATUS_NETWORKING_BASE + 0x00000024
#define STATUS_SET_SOCKET_FLAG_FAILED              STATUS_NETWORKING_BASE + 0x00000025
#define STATUS_CLOSE_SOCKET_FAILED                 STATUS_NETWORKING_BASE + 0x00000026
#define STATUS_CREATE_SOCKET_PAIR_FAILED           STATUS_NETWORKING_BASE + 0x00000027
#define STATUS_SOCKET_WRITE_FAILED                 STATUS_NETWORKING_BASE + 0X00000028
#define STATUS_INVALID_ADDRESS_LENGTH              STATUS_NETWORKING_BASE + 0X00000029
 
 
#define STATUS_DTLS_BASE                                  STATUS_NETWORKING_BASE + 0x01000000
#define STATUS_CERTIFICATE_GENERATION_FAILED              STATUS_DTLS_BASE + 0x00000001
#define STATUS_SSL_CTX_CREATION_FAILED                    STATUS_DTLS_BASE + 0x00000002
#define STATUS_SSL_REMOTE_CERTIFICATE_VERIFICATION_FAILED STATUS_DTLS_BASE + 0x00000003
#define STATUS_SSL_PACKET_BEFORE_DTLS_READY               STATUS_DTLS_BASE + 0x00000004
#define STATUS_SSL_UNKNOWN_SRTP_PROFILE                   STATUS_DTLS_BASE + 0x00000005
#define STATUS_SSL_INVALID_CERTIFICATE_BITS               STATUS_DTLS_BASE + 0x00000006
#define STATUS_DTLS_SESSION_ALREADY_FREED                 STATUS_DTLS_BASE + 0x00000007
 
#define STATUS_ICE_BASE                                                    STATUS_DTLS_BASE + 0x01000000
#define STATUS_ICE_AGENT_NO_SELECTED_CANDIDATE_AVAILABLE                   STATUS_ICE_BASE + 0x00000001
#define STATUS_ICE_CANDIDATE_STRING_MISSING_PORT                           STATUS_ICE_BASE + 0x00000002
#define STATUS_ICE_CANDIDATE_STRING_MISSING_IP                             STATUS_ICE_BASE + 0x00000003
#define STATUS_ICE_CANDIDATE_STRING_INVALID_IP                             STATUS_ICE_BASE + 0x00000004
#define STATUS_ICE_CANDIDATE_STRING_IS_TCP                                 STATUS_ICE_BASE + 0x00000005
#define STATUS_ICE_FAILED_TO_COMPUTE_MD5_FOR_LONG_TERM_CREDENTIAL          STATUS_ICE_BASE + 0x00000006
#define STATUS_ICE_URL_INVALID_PREFIX                                      STATUS_ICE_BASE + 0x00000007
#define STATUS_ICE_URL_TURN_MISSING_USERNAME                               STATUS_ICE_BASE + 0x00000008
#define STATUS_ICE_URL_TURN_MISSING_CREDENTIAL                             STATUS_ICE_BASE + 0x00000009
#define STATUS_ICE_AGENT_STATE_CHANGE_FAILED                               STATUS_ICE_BASE + 0x0000000a
#define STATUS_ICE_NO_LOCAL_CANDIDATE_AVAILABLE_AFTER_GATHERING_TIMEOUT    STATUS_ICE_BASE + 0x0000000b
#define STATUS_ICE_AGENT_TERMINATED_ALREADY                                STATUS_ICE_BASE + 0x0000000c
#define STATUS_ICE_NO_CONNECTED_CANDIDATE_PAIR                             STATUS_ICE_BASE + 0x0000000d
#define STATUS_ICE_CANDIDATE_PAIR_LIST_EMPTY                               STATUS_ICE_BASE + 0x0000000e
#define STATUS_ICE_NOMINATED_CANDIDATE_NOT_CONNECTED                       STATUS_ICE_BASE + 0x00000010
#define STATUS_ICE_CANDIDATE_INIT_MALFORMED                                STATUS_ICE_BASE + 0x00000011
#define STATUS_ICE_CANDIDATE_MISSING_CANDIDATE                             STATUS_ICE_BASE + 0x00000012
#define STATUS_ICE_FAILED_TO_NOMINATE_CANDIDATE_PAIR                       STATUS_ICE_BASE + 0x00000013
#define STATUS_ICE_MAX_REMOTE_CANDIDATE_COUNT_EXCEEDED                     STATUS_ICE_BASE + 0x00000014
#define STATUS_ICE_URL_MALFORMED                                           STATUS_ICE_BASE + 0x00000015
#define STATUS_ICE_URL_STUNS_IP_LITERAL_NOT_ALLOWED                        STATUS_ICE_BASE + 0x00000016
#define STATUS_ICE_INVALID_STATE                                           STATUS_ICE_BASE + 0x0000001c
#define STATUS_ICE_NO_LOCAL_HOST_CANDIDATE_AVAILABLE                       STATUS_ICE_BASE + 0x0000001d
#define STATUS_ICE_NO_NOMINATED_VALID_CANDIDATE_PAIR_AVAILABLE             STATUS_ICE_BASE + 0x0000001e
#define STATUS_TURN_CONNECTION_NO_HOST_INTERFACE_FOUND                     STATUS_ICE_BASE + 0x0000001f
#define STATUS_TURN_CONNECTION_STATE_TRANSITION_TIMEOUT                    STATUS_ICE_BASE + 0x00000020
#define STATUS_TURN_CONNECTION_FAILED_TO_CREATE_PERMISSION                 STATUS_ICE_BASE + 0x00000021
#define STATUS_TURN_CONNECTION_FAILED_TO_BIND_CHANNEL                      STATUS_ICE_BASE + 0x00000022
#define STATUS_TURN_NEW_DATA_CHANNEL_MSG_HEADER_BEFORE_PREVIOUS_MSG_FINISH STATUS_ICE_BASE + 0x00000023
#define STATUS_TURN_MISSING_CHANNEL_DATA_HEADER                            STATUS_ICE_BASE + 0x00000024
#define STATUS_ICE_FAILED_TO_RECOVER_FROM_DISCONNECTION                    STATUS_ICE_BASE + 0x00000025
#define STATUS_ICE_NO_AVAILABLE_ICE_CANDIDATE_PAIR                         STATUS_ICE_BASE + 0x00000026
#define STATUS_TURN_CONNECTION_PEER_NOT_USABLE                             STATUS_ICE_BASE + 0x00000027
#define STATUS_ICE_SERVER_INDEX_INVALID                                    STATUS_ICE_BASE + 0x00000028
#define STATUS_ICE_CANDIDATE_STRING_MISSING_TYPE                           STATUS_ICE_BASE + 0x00000029
#define STATUS_TURN_CONNECTION_ALLOCATION_FAILED                           STATUS_ICE_BASE + 0x0000002a
#define STATUS_TURN_INVALID_STATE                                          STATUS_ICE_BASE + 0x0000002b
#define STATUS_TURN_CONNECTION_GET_CREDENTIALS_FAILED                      STATUS_ICE_BASE + 0x0000002c
#define STATUS_FAILED_TO_INIT_RELAY_CANDIDATES                             STATUS_ICE_BASE + 0x0000002d
#define STATUS_TURN_CONNECTION_CREDENTIALS_REJECTED                        STATUS_ICE_BASE + 0x0000002e
 
 
#define STATUS_SRTP_BASE                             STATUS_ICE_BASE + 0x01000000
#define STATUS_SRTP_DECRYPT_FAILED                   STATUS_SRTP_BASE + 0x00000001
#define STATUS_SRTP_ENCRYPT_FAILED                   STATUS_SRTP_BASE + 0x00000002
#define STATUS_SRTP_TRANSMIT_SESSION_CREATION_FAILED STATUS_SRTP_BASE + 0x00000003
#define STATUS_SRTP_RECEIVE_SESSION_CREATION_FAILED  STATUS_SRTP_BASE + 0x00000004
#define STATUS_SRTP_INIT_FAILED                      STATUS_SRTP_BASE + 0x00000005
#define STATUS_SRTP_NOT_READY_YET                    STATUS_SRTP_BASE + 0x00000006
 
#define STATUS_RTP_BASE                   STATUS_SRTP_BASE + 0x01000000
#define STATUS_RTP_INPUT_PACKET_TOO_SMALL STATUS_RTP_BASE + 0x00000001
#define STATUS_RTP_INPUT_MTU_TOO_SMALL    STATUS_RTP_BASE + 0x00000002
#define STATUS_RTP_INVALID_NALU           STATUS_RTP_BASE + 0x00000003
#define STATUS_RTP_INVALID_EXTENSION_LEN  STATUS_RTP_BASE + 0x00000004
 
#define STATUS_SIGNALING_BASE                                      STATUS_RTP_BASE + 0x01000000
#define STATUS_SIGNALING_INVALID_READY_STATE                       STATUS_SIGNALING_BASE + 0x00000001
#define STATUS_SIGNALING_GET_TOKEN_CALL_FAILED                     STATUS_SIGNALING_BASE + 0x00000002
#define STATUS_SIGNALING_DESCRIBE_CALL_FAILED                      STATUS_SIGNALING_BASE + 0x00000003
#define STATUS_SIGNALING_CREATE_CALL_FAILED                        STATUS_SIGNALING_BASE + 0x00000004
#define STATUS_SIGNALING_GET_ENDPOINT_CALL_FAILED                  STATUS_SIGNALING_BASE + 0x00000005
#define STATUS_SIGNALING_GET_ICE_CONFIG_CALL_FAILED                STATUS_SIGNALING_BASE + 0x00000006
#define STATUS_SIGNALING_READY_CALLBACK_FAILED                     STATUS_SIGNALING_BASE + 0x00000007
#define STATUS_SIGNALING_CONNECT_CALL_FAILED                       STATUS_SIGNALING_BASE + 0x00000008
#define STATUS_SIGNALING_CONNECTED_CALLBACK_FAILED                 STATUS_SIGNALING_BASE + 0x00000009
#define STATUS_SIGNALING_INVALID_CHANNEL_INFO_VERSION              STATUS_SIGNALING_BASE + 0x0000000A
#define STATUS_SIGNALING_INVALID_SIGNALING_CALLBACKS_VERSION       STATUS_SIGNALING_BASE + 0x0000000B
#define STATUS_SIGNALING_INVALID_CHANNEL_NAME_LENGTH               STATUS_SIGNALING_BASE + 0x0000000C
#define STATUS_SIGNALING_INVALID_CHANNEL_ARN_LENGTH                STATUS_SIGNALING_BASE + 0x0000000D
#define STATUS_SIGNALING_INVALID_REGION_LENGTH                     STATUS_SIGNALING_BASE + 0x0000000E
#define STATUS_SIGNALING_INVALID_CPL_LENGTH                        STATUS_SIGNALING_BASE + 0x0000000F
#define STATUS_SIGNALING_INVALID_CERTIFICATE_PATH_LENGTH           STATUS_SIGNALING_BASE + 0x00000010
#define STATUS_SIGNALING_INVALID_AGENT_POSTFIX_LENGTH              STATUS_SIGNALING_BASE + 0x00000011
#define STATUS_SIGNALING_INVALID_AGENT_LENGTH                      STATUS_SIGNALING_BASE + 0x00000012
#define STATUS_SIGNALING_INVALID_KMS_KEY_LENGTH                    STATUS_SIGNALING_BASE + 0x00000013
#define STATUS_SIGNALING_LWS_CREATE_CONTEXT_FAILED                 STATUS_SIGNALING_BASE + 0x00000014
#define STATUS_SIGNALING_LWS_CLIENT_CONNECT_FAILED                 STATUS_SIGNALING_BASE + 0x00000015
#define STATUS_SIGNALING_CHANNEL_BEING_DELETED                     STATUS_SIGNALING_BASE + 0x00000016
#define STATUS_SIGNALING_INVALID_CLIENT_INFO_VERSION               STATUS_SIGNALING_BASE + 0x00000017
#define STATUS_SIGNALING_INVALID_CLIENT_INFO_CLIENT_LENGTH         STATUS_SIGNALING_BASE + 0x00000018
#define STATUS_SIGNALING_MAX_ICE_CONFIG_COUNT                      STATUS_SIGNALING_BASE + 0x00000019
#define STATUS_SIGNALING_MAX_ICE_URI_COUNT                         STATUS_SIGNALING_BASE + 0x0000001A
#define STATUS_SIGNALING_MAX_ICE_URI_LEN                           STATUS_SIGNALING_BASE + 0x0000001B
#define STATUS_SIGNALING_NO_CONFIG_SPECIFIED                       STATUS_SIGNALING_BASE + 0x0000001C
#define STATUS_SIGNALING_INVALID_ICE_CONFIG_INFO_VERSION           STATUS_SIGNALING_BASE + 0x0000001D
#define STATUS_SIGNALING_NO_CONFIG_URI_SPECIFIED                   STATUS_SIGNALING_BASE + 0x0000001E
#define STATUS_SIGNALING_NO_ARN_RETURNED_ON_CREATE                 STATUS_SIGNALING_BASE + 0x0000001F
#define STATUS_SIGNALING_MISSING_ENDPOINTS_IN_GET_ENDPOINT         STATUS_SIGNALING_BASE + 0x00000020
#define STATUS_SIGNALING_INVALID_MESSAGE_TYPE                      STATUS_SIGNALING_BASE + 0x00000021
#define STATUS_SIGNALING_INVALID_SIGNALING_MESSAGE_VERSION         STATUS_SIGNALING_BASE + 0x00000022
#define STATUS_SIGNALING_NO_PEER_CLIENT_ID_IN_MESSAGE              STATUS_SIGNALING_BASE + 0x00000023
#define STATUS_SIGNALING_MESSAGE_DELIVERY_FAILED                   STATUS_SIGNALING_BASE + 0x00000024
#define STATUS_SIGNALING_MAX_MESSAGE_LEN_AFTER_ENCODING            STATUS_SIGNALING_BASE + 0x00000025
#define STATUS_SIGNALING_RECEIVE_BINARY_DATA_NOT_SUPPORTED         STATUS_SIGNALING_BASE + 0x00000026
#define STATUS_SIGNALING_RECEIVE_EMPTY_DATA_NOT_SUPPORTED          STATUS_SIGNALING_BASE + 0x00000027
#define STATUS_SIGNALING_RECEIVED_MESSAGE_LARGER_THAN_MAX_DATA_LEN STATUS_SIGNALING_BASE + 0x00000028
#define STATUS_SIGNALING_INVALID_PAYLOAD_LEN_IN_MESSAGE            STATUS_SIGNALING_BASE + 0x00000029
#define STATUS_SIGNALING_NO_PAYLOAD_IN_MESSAGE                     STATUS_SIGNALING_BASE + 0x0000002A
#define STATUS_SIGNALING_DUPLICATE_MESSAGE_BEING_SENT              STATUS_SIGNALING_BASE + 0x0000002B
#define STATUS_SIGNALING_ICE_TTL_LESS_THAN_GRACE_PERIOD            STATUS_SIGNALING_BASE + 0x0000002C
#define STATUS_SIGNALING_DISCONNECTED_CALLBACK_FAILED              STATUS_SIGNALING_BASE + 0x0000002D
#define STATUS_SIGNALING_INVALID_MESSAGE_TTL_VALUE                 STATUS_SIGNALING_BASE + 0x0000002E
#define STATUS_SIGNALING_ICE_CONFIG_REFRESH_FAILED                 STATUS_SIGNALING_BASE + 0x0000002F
#define STATUS_SIGNALING_RECONNECT_FAILED                          STATUS_SIGNALING_BASE + 0x00000030
#define STATUS_SIGNALING_DELETE_CALL_FAILED                        STATUS_SIGNALING_BASE + 0x00000031
#define STATUS_SIGNALING_INVALID_METRICS_VERSION                   STATUS_SIGNALING_BASE + 0x00000032
#define STATUS_SIGNALING_INVALID_CLIENT_INFO_CACHE_FILE_PATH_LEN   STATUS_SIGNALING_BASE + 0x00000033
#define STATUS_SIGNALING_LWS_CALL_FAILED                           STATUS_SIGNALING_BASE + 0x00000034
#define STATUS_SIGNALING_INVALID_STREAM_ARN_LENGTH                 STATUS_SIGNALING_BASE + 0x00000035
#define STATUS_SIGNALING_MISMATCH_MEDIA_STORAGE_CONFIG             STATUS_SIGNALING_BASE + 0x00000036
#define STATUS_SIGNALING_UPDATE_MEDIA_STORAGE_CONFIG               STATUS_SIGNALING_BASE + 0x00000037
#define STATUS_SIGNALING_MEDIA_STORAGE_DISABLED                    STATUS_SIGNALING_BASE + 0x00000038
#define STATUS_SIGNALING_INVALID_CHANNEL_ARN                       STATUS_SIGNALING_BASE + 0x00000039
#define STATUS_SIGNALING_JOIN_SESSION_CALL_FAILED                  STATUS_SIGNALING_BASE + 0x0000004a
#define STATUS_SIGNALING_JOIN_SESSION_CONNECTED_FAILED             STATUS_SIGNALING_BASE + 0x0000004b
#define STATUS_SIGNALING_DESCRIBE_MEDIA_CALL_FAILED                STATUS_SIGNALING_BASE + 0x0000004c
 
 
#define STATUS_PEERCONNECTION_BASE                                     STATUS_SIGNALING_BASE + 0x01000000
#define STATUS_PEERCONNECTION_CREATE_ANSWER_WITHOUT_REMOTE_DESCRIPTION STATUS_PEERCONNECTION_BASE + 0x00000001
#define STATUS_PEERCONNECTION_CODEC_INVALID                            STATUS_PEERCONNECTION_BASE + 0x00000002
#define STATUS_PEERCONNECTION_CODEC_MAX_EXCEEDED                       STATUS_PEERCONNECTION_BASE + 0x00000003
#define STATUS_PEERCONNECTION_EARLY_DNS_RESOLUTION_FAILED              STATUS_PEERCONNECTION_BASE + 0x00000004
 
#define STATUS_SCTP_BASE                 STATUS_PEERCONNECTION_BASE + 0x01000000
#define STATUS_SCTP_SESSION_SETUP_FAILED STATUS_SCTP_BASE + 0x00000001
#define STATUS_SCTP_INVALID_DCEP_PACKET  STATUS_SCTP_BASE + 0x00000002
#define STATUS_SCTP_SENDV_FAILED         STATUS_SCTP_BASE + 0x00000003
 
#define STATUS_RTCP_BASE                         STATUS_SCTP_BASE + 0x01000000
#define STATUS_RTCP_INPUT_PACKET_TOO_SMALL       STATUS_RTCP_BASE + 0x00000001
#define STATUS_RTCP_INPUT_PACKET_INVALID_VERSION STATUS_RTCP_BASE + 0x00000002
#define STATUS_RTCP_INPUT_PACKET_LEN_MISMATCH    STATUS_RTCP_BASE + 0x00000003
#define STATUS_RTCP_INPUT_NACK_LIST_INVALID      STATUS_RTCP_BASE + 0x00000004
#define STATUS_RTCP_INPUT_SSRC_INVALID           STATUS_RTCP_BASE + 0x00000005
#define STATUS_RTCP_INPUT_PARTIAL_PACKET         STATUS_RTCP_BASE + 0x00000006
#define STATUS_RTCP_INPUT_REMB_TOO_SMALL         STATUS_RTCP_BASE + 0x00000007
#define STATUS_RTCP_INPUT_REMB_INVALID           STATUS_RTCP_BASE + 0x00000008
 
#define STATUS_ROLLING_BUFFER_BASE         STATUS_RTCP_BASE + 0x01000000
#define STATUS_ROLLING_BUFFER_NOT_IN_RANGE STATUS_ROLLING_BUFFER_BASE + 0x00000001
 
#define MAX_CHANNEL_NAME_LEN 256
 
#define MAX_SIGNALING_CLIENT_ID_LEN 256
 
#define MAX_ICE_CONFIG_USER_NAME_LEN 256
 
#define MAX_ICE_CONFIG_USER_NAME_BUFFER_LEN (MAX_ICE_CONFIG_USER_NAME_LEN + 1)
 
#define MAX_ICE_CONFIG_CREDENTIAL_LEN 256
 
#define MAX_ICE_CONFIG_CREDENTIAL_BUFFER_LEN (MAX_ICE_CONFIG_CREDENTIAL_LEN + 1)
 
#define MAX_SIGNALING_ENDPOINT_URI_LEN 512
 
#define MAX_CONTROL_PLANE_URI_CHAR_LEN 256
 
#define MAX_CORRELATION_ID_LEN 256
 
#define MAX_ERROR_TYPE_STRING_LEN 256
 
#define MAX_STATUS_CODE_STRING_LEN 8
 
#define MAX_MESSAGE_DESCRIPTION_LEN 1024
 
#ifdef KVS_SIGNALING_MESSAGE_LEN
#define MAX_SESSION_DESCRIPTION_INIT_SDP_LEN ((KVS_SIGNALING_MESSAGE_LEN - 1024) * 3 / 4)
#else
#define MAX_SESSION_DESCRIPTION_INIT_SDP_LEN 25000
#endif
 
#define MAX_MEDIA_STREAM_ID_LEN 255
 
#define MAX_RTCCONFIGURATION_CERTIFICATES 3
 
#define MAX_MEDIA_STREAM_TRACK_ID_LEN 255
 
#define MAX_ICE_CANDIDATE_INIT_CANDIDATE_LEN 255
 
#define MAX_DATA_CHANNEL_NAME_LEN 255
 
#define MAX_DATA_CHANNEL_PROTOCOL_LEN 255
 
#ifdef KVS_SIGNALING_MESSAGE_LEN
#define MAX_SIGNALING_MESSAGE_LEN KVS_SIGNALING_MESSAGE_LEN
#else
#define MAX_SIGNALING_MESSAGE_LEN 18750
#endif
 
#define PEER_CONNECTION_CURRENT_VERSION 0
 
#define CHANNEL_INFO_CURRENT_VERSION 1
 
#define SIGNALING_CLIENT_INFO_CURRENT_VERSION 2
 
#define SIGNALING_CLIENT_CALLBACKS_CURRENT_VERSION 0
 
#define SIGNALING_CLIENT_CURRENT_VERSION 1
 
#define SIGNALING_CHANNEL_DESCRIPTION_CURRENT_VERSION 0
 
#define SIGNALING_ICE_CONFIG_INFO_CURRENT_VERSION 0
 
#define SIGNALING_MESSAGE_CURRENT_VERSION 0
 
#define RTC_ICE_METRICS_CURRENT_VERSION 0
 
#define RTC_STREAM_METRICS_CURRENT_VERSION 0
 
#define SIGNALING_CLIENT_METRICS_CURRENT_VERSION 1
 
#define PEER_CONNECTION_METRICS_CURRENT_VERSION 0
 
#define ICE_AGENT_METRICS_CURRENT_VERSION 0
 
 
#define MAX_ICE_CONFIG_URI_COUNT 4
 
#define MAX_ICE_CONFIG_COUNT 5
 
#define MAX_ICE_SERVERS_COUNT (MAX_ICE_CONFIG_COUNT * MAX_ICE_CONFIG_URI_COUNT + 1)
 
#define SIGNALING_CREATE_TIMEOUT (10 * HUNDREDS_OF_NANOS_IN_A_SECOND)
 
#define SIGNALING_CONNECT_STATE_TIMEOUT (15 * HUNDREDS_OF_NANOS_IN_A_SECOND)
 
#define SIGNALING_DISCONNECT_STATE_TIMEOUT (15 * HUNDREDS_OF_NANOS_IN_A_SECOND)
 
#define SIGNALING_REFRESH_ICE_CONFIG_STATE_TIMEOUT (20 * HUNDREDS_OF_NANOS_IN_A_SECOND)
 
#define SIGNALING_CONNECT_TIMEOUT (5 * HUNDREDS_OF_NANOS_IN_A_SECOND)
 
#define THREADPOOL_MIN_THREADS 3
 
#define THREADPOOL_MAX_THREADS 10
 
#define WEBRTC_THREADPOOL_MIN_THREADS_ENV_VAR (PCHAR) "AWS_KVS_WEBRTC_THREADPOOL_MIN_THREADS"
 
#define WEBRTC_THREADPOOL_MAX_THREADS_ENV_VAR (PCHAR) "AWS_KVS_WEBRTC_THREADPOOL_MAX_THREADS"
 
#define USE_DUAL_STACK_ENDPOINTS_ENV_VAR ((PCHAR) "KVS_DUALSTACK_ENDPOINTS")
 
#define DISABLE_IPV4_TURN_ENV_VAR ((PCHAR) "KVS_DISABLE_IPV4_TURN")
#define DISABLE_IPV6_TURN_ENV_VAR ((PCHAR) "KVS_DISABLE_IPV6_TURN")
 
#ifdef _WIN32
#define SIGNALING_SEND_TIMEOUT (15 * HUNDREDS_OF_NANOS_IN_A_SECOND)
#else
#define SIGNALING_SEND_TIMEOUT (5 * HUNDREDS_OF_NANOS_IN_A_SECOND)
#endif
#define SIGNALING_DELETE_TIMEOUT (5 * HUNDREDS_OF_NANOS_IN_A_SECOND)
 
#define SIGNALING_DEFAULT_MESSAGE_TTL_VALUE (60 * HUNDREDS_OF_NANOS_IN_A_SECOND)
 
#define SIGNALING_JOIN_STORAGE_SESSION_WAIT_TIMEOUT (6 * HUNDREDS_OF_NANOS_IN_A_SECOND)
 
#define DEFAULT_JITTER_BUFFER_MAX_LATENCY (2000L * HUNDREDS_OF_NANOS_IN_A_MILLISECOND)
#define SIGNALING_VALID_NAME_CHARS "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz_.-"
 
#define MAX_RTP_SEQUENCE_NUM ((UINT32) MAX_UINT16)
 
#define MAX_RTP_TIMESTAMP ((UINT32) MAX_UINT32)
 
#define KINESIS_VIDEO_STUN_URL_POSTFIX              "amazonaws.com"
#define KINESIS_VIDEO_STUN_URL_POSTFIX_CN           "amazonaws.com.cn"
#define KINESIS_VIDEO_STUN_URL_PREFIX               "stun."
#define KINESIS_VIDEO_STUN_URL_PREFIX_LENGTH        5
#define KINESIS_VIDEO_STUN_URL                      "stun:stun.kinesisvideo.%s.%s:443"
#define KINESIS_VIDEO_STUNS_URL                     "stuns:stun.kinesisvideo-fips.%s.%s:443"
#define KINESIS_VIDEO_STUN_URL_WITHOUT_PORT         "stun.kinesisvideo.%s.%s"
#define KINESIS_VIDEO_STUNS_URL_WITHOUT_PORT        "stun.kinesisvideo-fips.%s.%s"
#define KINESIS_VIDEO_DUALSTACK_STUN_URL_POSTFIX    "api.aws"
#define KINESIS_VIDEO_DUALSTACK_STUN_URL_POSTFIX_CN "api.amazonwebservices.com.cn"
 
#define SIGNALING_DEFAULT_SSL_PORT DEFAULT_SSL_PORT_NUMBER
 
#define SIGNALING_DEFAULT_NON_SSL_PORT DEFAULT_NON_SSL_PORT_NUMBER
 
/* CHK_LOG_ERR_NV has been replaced with CHK_LOG_ERR. */
#define CHK_LOG_ERR_NV(condition) DLOGE("CHK_LOG_ERR_NV has been replaced with CHK_LOG_ERR");
 
#define SIGNALING_STATES_DEFAULT_RETRY_COUNT 1
 
#define SIGNALING_DEFAULT_API_CALL_CACHE_TTL (10 * HUNDREDS_OF_NANOS_IN_AN_HOUR)
 
#define SIGNALING_API_CALL_CACHE_TTL_SENTINEL_VALUE 0
 
#define CREATE_SIGNALING_CLIENT_RETRY_ATTEMPTS_SENTINEL_VALUE -1
 
typedef UINT64 SIGNALING_CLIENT_HANDLE;
typedef SIGNALING_CLIENT_HANDLE* PSIGNALING_CLIENT_HANDLE;
 
#ifndef INVALID_SIGNALING_CLIENT_HANDLE_VALUE
#define INVALID_SIGNALING_CLIENT_HANDLE_VALUE ((SIGNALING_CLIENT_HANDLE) INVALID_PIC_HANDLE_VALUE)
#endif
 
#ifndef IS_VALID_SIGNALING_CLIENT_HANDLE
#define IS_VALID_SIGNALING_CLIENT_HANDLE(h) ((h) != INVALID_SIGNALING_CLIENT_HANDLE_VALUE)
#endif
 
 
typedef enum {
    RTC_PEER_CONNECTION_STATE_NONE = 0,         
    RTC_PEER_CONNECTION_STATE_NEW = 1,          
    RTC_PEER_CONNECTION_STATE_CONNECTING = 2,   
    RTC_PEER_CONNECTION_STATE_CONNECTED = 3,    
    RTC_PEER_CONNECTION_STATE_DISCONNECTED = 4, 
    RTC_PEER_CONNECTION_STATE_FAILED = 5,       
    RTC_PEER_CONNECTION_STATE_CLOSED = 6,       
    RTC_PEER_CONNECTION_TOTAL_STATE_COUNT = 7,  
} RTC_PEER_CONNECTION_STATE;
 
typedef enum {
    SDP_TYPE_OFFER = 1,  
    SDP_TYPE_ANSWER = 2, 
} SDP_TYPE;
 
typedef enum {
    MEDIA_STREAM_TRACK_KIND_AUDIO = 1, 
    MEDIA_STREAM_TRACK_KIND_VIDEO = 2, 
} MEDIA_STREAM_TRACK_KIND;
 
typedef enum {
    RTC_CODEC_H264_PROFILE_42E01F_LEVEL_ASYMMETRY_ALLOWED_PACKETIZATION_MODE = 1, 
    RTC_CODEC_OPUS = 2,                                                           
    RTC_CODEC_VP8 = 3,                                                            
    RTC_CODEC_MULAW = 4,                                                          
    RTC_CODEC_ALAW = 5,                                                           
    RTC_CODEC_UNKNOWN = 6,
    RTC_CODEC_H265 = 7, 
    // RTC_CODEC_MAX **MUST** be the last enum in the list **ALWAYS** and not assigned a value
    RTC_CODEC_MAX 
} RTC_CODEC;
 
typedef enum {
    ICE_TRANSPORT_POLICY_RELAY = 1, 
 
    ICE_TRANSPORT_POLICY_ALL = 2, 
} ICE_TRANSPORT_POLICY;
 
typedef enum {
    RTC_RTP_TRANSCEIVER_DIRECTION_UNINITIALIZED = 0, 
    RTC_RTP_TRANSCEIVER_DIRECTION_SENDRECV = 1,      
    RTC_RTP_TRANSCEIVER_DIRECTION_SENDONLY = 2,      
    RTC_RTP_TRANSCEIVER_DIRECTION_RECVONLY = 3,      
    RTC_RTP_TRANSCEIVER_DIRECTION_INACTIVE = 4,      
    RTC_RTP_TRANSCEIVER_DIRECTION_MAX,               
} RTC_RTP_TRANSCEIVER_DIRECTION;
 
typedef enum {
    SIGNALING_CHANNEL_STATUS_CREATING, 
    SIGNALING_CHANNEL_STATUS_ACTIVE,   
    SIGNALING_CHANNEL_STATUS_UPDATING, 
    SIGNALING_CHANNEL_STATUS_DELETING, 
} SIGNALING_CHANNEL_STATUS;
 
typedef enum {
    SIGNALING_MESSAGE_TYPE_OFFER,                
    SIGNALING_MESSAGE_TYPE_ANSWER,               
    SIGNALING_MESSAGE_TYPE_ICE_CANDIDATE,        
    SIGNALING_MESSAGE_TYPE_GO_AWAY,              
    SIGNALING_MESSAGE_TYPE_RECONNECT_ICE_SERVER, 
    SIGNALING_MESSAGE_TYPE_STATUS_RESPONSE,      
    SIGNALING_MESSAGE_TYPE_UNKNOWN,              
} SIGNALING_MESSAGE_TYPE;
 
typedef enum {
    SIGNALING_CLIENT_STATE_UNKNOWN,         
    SIGNALING_CLIENT_STATE_NEW,             
    SIGNALING_CLIENT_STATE_GET_CREDENTIALS, 
    SIGNALING_CLIENT_STATE_DESCRIBE,        
    SIGNALING_CLIENT_STATE_CREATE,          
    SIGNALING_CLIENT_STATE_GET_ENDPOINT,    
    SIGNALING_CLIENT_STATE_GET_ICE_CONFIG,  
    SIGNALING_CLIENT_STATE_READY,           
    SIGNALING_CLIENT_STATE_CONNECTING,      
    SIGNALING_CLIENT_STATE_CONNECTED,       
    SIGNALING_CLIENT_STATE_DISCONNECTED,    
    SIGNALING_CLIENT_STATE_DELETE,          
    SIGNALING_CLIENT_STATE_DELETED, 
    SIGNALING_CLIENT_STATE_DESCRIBE_MEDIA,
    SIGNALING_CLIENT_STATE_JOIN_SESSION,
    SIGNALING_CLIENT_STATE_JOIN_SESSION_WAITING,
    SIGNALING_CLIENT_STATE_JOIN_SESSION_CONNECTED,
    SIGNALING_CLIENT_STATE_MAX_VALUE, 
} SIGNALING_CLIENT_STATE,
    *PSIGNALING_CLIENT_STATE;
 
typedef enum {
    SIGNALING_CHANNEL_TYPE_UNKNOWN,       
    SIGNALING_CHANNEL_TYPE_SINGLE_MASTER, 
} SIGNALING_CHANNEL_TYPE;
 
typedef enum {
    SIGNALING_CHANNEL_ROLE_TYPE_UNKNOWN, 
    SIGNALING_CHANNEL_ROLE_TYPE_MASTER,  
    SIGNALING_CHANNEL_ROLE_TYPE_VIEWER,  
} SIGNALING_CHANNEL_ROLE_TYPE;
 
typedef enum {
    NAT_BEHAVIOR_NONE,                 
    NAT_BEHAVIOR_NOT_BEHIND_ANY_NAT,   
    NAT_BEHAVIOR_NO_UDP_CONNECTIVITY,  
    NAT_BEHAVIOR_ENDPOINT_INDEPENDENT, 
    NAT_BEHAVIOR_ADDRESS_DEPENDENT,    
    NAT_BEHAVIOR_PORT_DEPENDENT,       
} NAT_BEHAVIOR;
 
typedef enum {
    SIGNALING_API_CALL_CACHE_TYPE_NONE, 
 
    SIGNALING_API_CALL_CACHE_TYPE_DESCRIBE_GETENDPOINT,       
    SIGNALING_API_CALL_CACHE_TYPE_FILE,                       
    SIGNALING_API_CALL_CACHE_TYPE_FILE_EXCEPT_DESCRIBE_MEDIA, 
} SIGNALING_API_CALL_CACHE_TYPE;
 
 
typedef VOID (*RtcOnFrame)(UINT64, PFrame);
 
typedef VOID (*RtcOnBandwidthEstimation)(UINT64, DOUBLE);
 
typedef VOID (*RtcOnSenderBandwidthEstimation)(UINT64, UINT32, UINT32, UINT32, UINT32, UINT64);
 
typedef struct {
    UINT16 twccSeqNum; 
    UINT64 sendTime;   
    UINT64 recvTime;   
    UINT32 packetSize; 
} TwccFeedback, *PTwccFeedback;
 
typedef struct {
    DOUBLE delayTrend; 
} TwccCongestionState, *PTwccCongestionState;
 
typedef struct {
    UINT64 txBytes;                      
    UINT64 rxBytes;                      
    UINT64 txPackets;                    
    UINT64 rxPackets;                    
    UINT64 duration;                     
    TwccCongestionState congestionState; 
} CongestionCtx, *PCongestionCtx;
 
typedef STATUS (*RtcOnTwccFeedbackReceived)(UINT64, PTwccFeedback, UINT32, PTwccCongestionState);
 
typedef STATUS (*RtcOnPeerCongestionFeedback)(UINT64, PCongestionCtx);
 
typedef VOID (*RtcOnPictureLoss)(UINT64);
 
typedef struct __RtcDataChannel {
    CHAR name[MAX_DATA_CHANNEL_NAME_LEN + 1]; 
    UINT32 id;                                
} RtcDataChannel, *PRtcDataChannel;
 
typedef VOID (*RtcOnMessage)(UINT64, PRtcDataChannel, BOOL, PBYTE, UINT32);
 
typedef VOID (*RtcOnOpen)(UINT64, PRtcDataChannel);
 
typedef VOID (*RtcOnDataChannel)(UINT64, PRtcDataChannel);
 
typedef VOID (*RtcOnIceCandidate)(UINT64, PCHAR);
 
typedef BOOL (*IceSetInterfaceFilterFunc)(UINT64, PCHAR);
 
typedef VOID (*RtcOnConnectionStateChange)(UINT64, RTC_PEER_CONNECTION_STATE);
 
typedef struct {
    UINT32 version; 
} RtcPeerConnection, *PRtcPeerConnection;
 
typedef struct {
    RTC_CODEC codec;                            
    CHAR trackId[MAX_MEDIA_STREAM_ID_LEN + 1];  
    CHAR streamId[MAX_MEDIA_STREAM_ID_LEN + 1]; 
    MEDIA_STREAM_TRACK_KIND kind;               
} RtcMediaStreamTrack, *PRtcMediaStreamTrack;
 
typedef struct {
    RtcMediaStreamTrack track; 
} RtcRtpReceiver, *PRtcRtpReceiver;
 
typedef struct {
    RTC_RTP_TRANSCEIVER_DIRECTION direction; 
    RtcRtpReceiver receiver;                 
} RtcRtpTransceiver, *PRtcRtpTransceiver;
 
typedef struct {
    CHAR urls[MAX_ICE_CONFIG_URI_LEN + 1];                 
    CHAR username[MAX_ICE_CONFIG_USER_NAME_BUFFER_LEN];    
    CHAR credential[MAX_ICE_CONFIG_CREDENTIAL_BUFFER_LEN]; 
} RtcIceServer, *PRtcIceServer;
 
typedef struct {
    // The certificate bits and the size
    PBYTE pCertificate;     
    UINT32 certificateSize; 
 
    // The private key bits and the size in bytes
    PBYTE pPrivateKey;     
    UINT32 privateKeySize; 
} RtcCertificate, *PRtcCertificate;
 
typedef struct {
    UINT16 maximumTransmissionUnit; 
 
    UINT32 iceLocalCandidateGatheringTimeout; 
 
    UINT32 iceConnectionCheckTimeout; 
 
    UINT32 iceCandidateNominationTimeout; 
 
    UINT32 iceConnectionCheckPollingInterval; 
 
    INT32 generatedCertificateBits; 
 
    BOOL generateRSACertificate; 
 
    UINT32 sendBufSize; 
 
    UINT64 filterCustomData; 
 
    IceSetInterfaceFilterFunc iceSetInterfaceFilterFunc; 
 
    BOOL disableSenderSideBandwidthEstimation; 
#ifdef ENABLE_STATS_CALCULATION_CONTROL
    BOOL enableIceStats; 
#endif
} KvsRtcConfiguration, *PKvsRtcConfiguration;
 
typedef struct {
    ICE_TRANSPORT_POLICY iceTransportPolicy;        
    RtcIceServer iceServers[MAX_ICE_SERVERS_COUNT]; 
    KvsRtcConfiguration kvsRtcConfiguration;        
 
    RtcCertificate
        certificates[MAX_RTCCONFIGURATION_CERTIFICATES]; 
} RtcConfiguration, *PRtcConfiguration;
 
typedef struct {
    SDP_TYPE type;                                      
    BOOL useTrickleIce;                                 
    CHAR sdp[MAX_SESSION_DESCRIPTION_INIT_SDP_LEN + 1]; 
} RtcSessionDescriptionInit, *PRtcSessionDescriptionInit;
 
typedef struct {
    CHAR candidate[MAX_ICE_CANDIDATE_INIT_CANDIDATE_LEN + 1]; 
} RtcIceCandidateInit, *PRtcIceCandidateInit;
 
typedef struct {
    UINT32 version; 
 
    SIGNALING_MESSAGE_TYPE messageType; 
 
    CHAR correlationId[MAX_CORRELATION_ID_LEN + 1]; 
 
    CHAR peerClientId[MAX_SIGNALING_CLIENT_ID_LEN + 1]; 
 
    UINT32 payloadLen; 
 
    CHAR payload[MAX_SIGNALING_MESSAGE_LEN + 1]; 
} SignalingMessage, *PSignalingMessage;
 
typedef struct {
    SignalingMessage signalingMessage; 
 
    SERVICE_CALL_RESULT statusCode; 
 
    CHAR errorType[MAX_ERROR_TYPE_STRING_LEN + 1]; 
 
    CHAR description[MAX_MESSAGE_DESCRIPTION_LEN + 1]; 
} ReceivedSignalingMessage, *PReceivedSignalingMessage;
 
typedef struct {
    UINT32 version;                                            
    CHAR clientId[MAX_SIGNALING_CLIENT_ID_LEN + 1];            
    UINT32 loggingLevel;                                       
    PCHAR cacheFilePath;                                       
    KvsRetryStrategyCallbacks signalingRetryStrategyCallbacks; 
    INT32 signalingClientCreationMaxRetryAttempts;             
    UINT32 stateMachineRetryCountReadOnly;  
    UINT32 signalingMessagesMinimumThreads; 
    UINT32 signalingMessagesMaximumThreads; 
} SignalingClientInfo, *PSignalingClientInfo;
 
typedef struct {
    UINT32 version; 
 
    PCHAR pChannelName; 
 
    PCHAR pChannelArn;       
    PCHAR pStorageStreamArn; 
 
    PCHAR pRegion; 
 
    PCHAR pControlPlaneUrl; 
 
    PCHAR pCertPath; 
 
    PCHAR pUserAgentPostfix; 
 
    PCHAR pCustomUserAgent; 
 
    PCHAR pUserAgent; 
 
    PCHAR pKmsKeyId; 
 
    SIGNALING_CHANNEL_TYPE channelType; 
 
    SIGNALING_CHANNEL_ROLE_TYPE channelRoleType; 
 
    BOOL reserved; 
 
    UINT64 cachingPeriod; 
 
    BOOL retry; 
 
    BOOL reconnect; 
 
    UINT64 messageTtl; 
 
    UINT32 tagCount; 
 
    PTag pTags; 
 
    /* --- V1 members --- */
 
    SIGNALING_API_CALL_CACHE_TYPE cachingPolicy; 
 
    BOOL asyncIceServerConfig; 
 
    BOOL useMediaStorage; 
 
} ChannelInfo, *PChannelInfo;
 
typedef struct {
    UINT32 version;                                                     
    UINT64 ttl;                                                         
    UINT32 uriCount;                                                    
    CHAR uris[MAX_ICE_CONFIG_URI_COUNT][MAX_ICE_CONFIG_URI_BUFFER_LEN]; 
    CHAR userName[MAX_ICE_CONFIG_USER_NAME_BUFFER_LEN];                 
    CHAR password[MAX_ICE_CONFIG_CREDENTIAL_BUFFER_LEN];                
} IceConfigInfo, *PIceConfigInfo;
 
typedef struct {
    BOOL storageStatus;                     
    CHAR storageStreamArn[MAX_ARN_LEN + 1]; 
} MediaStorageConfig, *PMediaStorageConfig;
typedef STATUS (*SignalingClientMessageReceivedFunc)(UINT64, PReceivedSignalingMessage);
 
typedef STATUS (*SignalingClientErrorReportFunc)(UINT64, STATUS, PCHAR, UINT32);
 
typedef STATUS (*SignalingClientStateChangedFunc)(UINT64, SIGNALING_CLIENT_STATE);
typedef struct {
    UINT32 version;                                       
    UINT64 customData;                                    
    SignalingClientMessageReceivedFunc messageReceivedFn; 
    SignalingClientErrorReportFunc errorReportFn;         
    SignalingClientStateChangedFunc stateChangeFn;        
    GetCurrentTimeFunc getCurrentTimeFn;                  
} SignalingClientCallbacks, *PSignalingClientCallbacks;
 
typedef struct {
    UINT32 version;                                 
    CHAR channelArn[MAX_ARN_LEN + 1];               
    CHAR channelName[MAX_CHANNEL_NAME_LEN + 1];     
    SIGNALING_CHANNEL_STATUS channelStatus;         
    SIGNALING_CHANNEL_TYPE channelType;             
    CHAR updateVersion[MAX_UPDATE_VERSION_LEN + 1]; 
    UINT64 messageTtl;                              
    UINT64 creationTime;                            
} SignalingChannelDescription, *PSignalingChannelDescription;
 
typedef struct {
    RTC_RTP_TRANSCEIVER_DIRECTION direction; 
} RtcRtpTransceiverInit, *PRtcRtpTransceiverInit;
 
typedef struct {
    BOOL ordered;                                     
    NullableUint16 maxPacketLifeTime;                 
    NullableUint16 maxRetransmits;                    
    CHAR protocol[MAX_DATA_CHANNEL_PROTOCOL_LEN + 1]; 
    BOOL negotiated;                                  
} RtcDataChannelInit, *PRtcDataChannelInit;
 
typedef struct {
    UINT32 version;                                    
    RtcIceServerStats rtcIceServerStats;               
    RtcIceCandidateStats localRtcIceCandidateStats;    
    RtcIceCandidateStats remoteRtcIceCandidateStats;   
    RtcIceCandidatePairStats rtcIceCandidatePairStats; 
} RtcIceMetrics, *PRtcIceMetrics;
 
typedef struct {
    UINT32 version;                                 
    RtcRemoteInboundRtpStreamStats rtcInboundStats; 
    RtcOutboundRtpStreamStats rtcOutboundStats;     
    RtcTransportStats rtcTransportStats;            
} RtcStreamMetrics, *PRtcStreamMetrics;
 
typedef struct {
    UINT32 version; 
    UINT64 signalingStartTime;
    UINT64 signalingEndTime;
    UINT64 signalingCallTime;
    SignalingClientStats signalingClientStats; 
} SignalingClientMetrics, *PSignalingClientMetrics;
 
typedef struct {
    UINT32 version;                    
    KvsIceAgentStats kvsIceAgentStats; 
} KvsIceAgentMetrics, *PKvsIceAgentMetrics;
 
typedef struct {
    UINT32 version;                          
    PeerConnectionStats peerConnectionStats; 
} PeerConnectionMetrics, *PPeerConnectionMetrics;
 
typedef struct {
    UINT64 timestamp;                    
    RTC_STATS_TYPE requestedTypeOfStats; 
    RtcStatsObject rtcStatsObject;       
} RtcStats, *PRtcStats;
 
typedef struct {
    UINT32 targetBitrate;  
    UINT16 width;          
    UINT16 height;         
    UINT16 bitDepth;       
    UINT32 encodeTimeMsec; 
    BOOL voiceActivity;    
    DOMString encoderImplementation; 
} RtcEncoderStats, *PRtcEncoderStats;
 
PUBLIC_API STATUS configureTransceiverRollingBuffer(PRtcRtpTransceiver, PRtcMediaStreamTrack, DOUBLE, DOUBLE);
 
PUBLIC_API STATUS createPeerConnection(PRtcConfiguration, PRtcPeerConnection*);
 
PUBLIC_API STATUS freePeerConnection(PRtcPeerConnection*);
 
PUBLIC_API STATUS peerConnectionOnIceCandidate(PRtcPeerConnection, UINT64, RtcOnIceCandidate);
 
PUBLIC_API STATUS peerConnectionOnSenderBandwidthEstimation(PRtcPeerConnection, UINT64, RtcOnSenderBandwidthEstimation);
 
PUBLIC_API STATUS setOnTwccFeedbackReceived(PRtcPeerConnection, UINT64, RtcOnTwccFeedbackReceived);
 
PUBLIC_API STATUS setOnPeerCongestionFeedbackFn(PRtcPeerConnection, UINT64, RtcOnPeerCongestionFeedback);
 
PUBLIC_API STATUS peerConnectionOnDataChannel(PRtcPeerConnection, UINT64, RtcOnDataChannel);
 
PUBLIC_API STATUS peerConnectionOnConnectionStateChange(PRtcPeerConnection, UINT64, RtcOnConnectionStateChange);
 
PUBLIC_API STATUS peerConnectionGetLocalDescription(PRtcPeerConnection, PRtcSessionDescriptionInit);
 
PUBLIC_API STATUS peerConnectionGetCurrentLocalDescription(PRtcPeerConnection, PRtcSessionDescriptionInit);
 
PUBLIC_API STATUS createOffer(PRtcPeerConnection, PRtcSessionDescriptionInit);
 
PUBLIC_API NullableBool canTrickleIceCandidates(PRtcPeerConnection);
 
PUBLIC_API STATUS createAnswer(PRtcPeerConnection, PRtcSessionDescriptionInit);
 
PUBLIC_API STATUS serializeSessionDescriptionInit(PRtcSessionDescriptionInit, PCHAR, PUINT32);
 
PUBLIC_API STATUS deserializeSessionDescriptionInit(PCHAR, UINT32, PRtcSessionDescriptionInit);
 
PUBLIC_API STATUS deserializeRtcIceCandidateInit(PCHAR, UINT32, PRtcIceCandidateInit);
 
PUBLIC_API STATUS setLocalDescription(PRtcPeerConnection, PRtcSessionDescriptionInit);
 
PUBLIC_API STATUS setRemoteDescription(PRtcPeerConnection, PRtcSessionDescriptionInit);
 
PUBLIC_API STATUS restartIce(PRtcPeerConnection);
 
PUBLIC_API STATUS closePeerConnection(PRtcPeerConnection);
 
PUBLIC_API STATUS peerConnectionUpdateIceServers(PRtcPeerConnection, PRtcIceServer, UINT32);
 
PUBLIC_API STATUS addTransceiver(PRtcPeerConnection, PRtcMediaStreamTrack, PRtcRtpTransceiverInit, PRtcRtpTransceiver*);
 
PUBLIC_API STATUS transceiverOnFrame(PRtcRtpTransceiver, UINT64, RtcOnFrame);
 
PUBLIC_API STATUS transceiverOnBandwidthEstimation(PRtcRtpTransceiver, UINT64, RtcOnBandwidthEstimation);
 
PUBLIC_API STATUS transceiverOnPictureLoss(PRtcRtpTransceiver, UINT64, RtcOnPictureLoss);
 
PUBLIC_API STATUS transceiverSetFmtp(PRtcRtpTransceiver, PCHAR);
 
PUBLIC_API STATUS freeTransceiver(PRtcRtpTransceiver*);
 
PUBLIC_API STATUS initKvsWebRtc(VOID);
 
PUBLIC_API STATUS deinitKvsWebRtc(VOID);
 
PUBLIC_API STATUS addSupportedCodec(PRtcPeerConnection, RTC_CODEC);
 
PUBLIC_API STATUS writeFrame(PRtcRtpTransceiver, PFrame);
 
PUBLIC_API STATUS updateEncoderStats(PRtcRtpTransceiver, PRtcEncoderStats);
 
PUBLIC_API STATUS addIceCandidate(PRtcPeerConnection, PCHAR);
 
PUBLIC_API STATUS createDataChannel(PRtcPeerConnection, PCHAR, PRtcDataChannelInit, PRtcDataChannel*);
 
PUBLIC_API STATUS dataChannelOnMessage(PRtcDataChannel, UINT64, RtcOnMessage);
 
PUBLIC_API STATUS dataChannelOnOpen(PRtcDataChannel, UINT64, RtcOnOpen);
 
PUBLIC_API STATUS dataChannelSend(PRtcDataChannel, BOOL, PBYTE, UINT32);
 
PUBLIC_API STATUS discoverNatBehavior(PCHAR, NAT_BEHAVIOR*, NAT_BEHAVIOR*, IceSetInterfaceFilterFunc, UINT64);
 
PUBLIC_API PCHAR getNatBehaviorStr(NAT_BEHAVIOR natBehavior);
 
PUBLIC_API STATUS createSignalingClientSync(PSignalingClientInfo, PChannelInfo, PSignalingClientCallbacks, PAwsCredentialProvider,
                                            PSIGNALING_CLIENT_HANDLE);
 
PUBLIC_API STATUS freeSignalingClient(PSIGNALING_CLIENT_HANDLE);
 
PUBLIC_API STATUS signalingClientSendMessageSync(SIGNALING_CLIENT_HANDLE, PSignalingMessage);
 
PUBLIC_API STATUS signalingClientGetIceConfigInfoCount(SIGNALING_CLIENT_HANDLE, PUINT32);
 
PUBLIC_API STATUS signalingClientGetIceConfigInfo(SIGNALING_CLIENT_HANDLE, UINT32, PIceConfigInfo*);
 
PUBLIC_API STATUS signalingClientFetchSync(SIGNALING_CLIENT_HANDLE);
 
PUBLIC_API STATUS signalingClientConnectSync(SIGNALING_CLIENT_HANDLE);
 
PUBLIC_API STATUS signalingClientDisconnectSync(SIGNALING_CLIENT_HANDLE);
 
PUBLIC_API STATUS signalingClientGetCurrentState(SIGNALING_CLIENT_HANDLE, PSIGNALING_CLIENT_STATE);
 
PUBLIC_API STATUS signalingClientGetStateString(SIGNALING_CLIENT_STATE, PCHAR*);
 
PUBLIC_API STATUS signalingClientDeleteSync(SIGNALING_CLIENT_HANDLE);
 
PUBLIC_API STATUS signalingClientGetMetrics(SIGNALING_CLIENT_HANDLE, PSignalingClientMetrics);
 
PUBLIC_API STATUS peerConnectionGetMetrics(PRtcPeerConnection, PPeerConnectionMetrics);
 
PUBLIC_API STATUS iceAgentGetMetrics(PRtcPeerConnection, PKvsIceAgentMetrics);
 
PUBLIC_API STATUS rtcPeerConnectionGetMetrics(PRtcPeerConnection, PRtcRtpTransceiver, PRtcStats);
 
PUBLIC_API STATUS createRtcCertificate(PRtcCertificate*);
 
PUBLIC_API STATUS freeRtcCertificate(PRtcCertificate);
 
#ifdef __cplusplus
}
#endif
#endif /* __KINESIS_VIDEO_WEBRTC_CLIENT_INCLUDE__ */