Dual-Stack Endpoints Support

CMake/Dependencies/libkvsCommonLws-CMakeLists.txt

@@ -6,7 +6,7 @@ include(ExternalProject)
 
 ExternalProject_Add(libkvsCommonLws-download
     GIT_REPOSITORY    https://github.com/awslabs/amazon-kinesis-video-streams-producer-c.git
-    GIT_TAG           v1.5.4
+    GIT_TAG           dual-stack-support
     PREFIX            ${CMAKE_CURRENT_BINARY_DIR}/build
     LIST_SEPARATOR    |
     CMAKE_ARGS        

CMake/Dependencies/libwebsockets-CMakeLists.txt

@@ -64,6 +64,7 @@ ExternalProject_Add(project_libwebsockets
         -DLWS_EXT_PTHREAD_LIBRARIES=${LWS_EXT_PTHREAD_LIBRARIES}
         -DLWS_OPENSSL_INCLUDE_DIRS=${LWS_OPENSSL_INCLUDE_DIRS}
         -DLWS_OPENSSL_LIBRARIES=${LWS_OPENSSL_LIBRARIES}
+        -DLWS_WITH_IPV6=ON
     BUILD_ALWAYS      TRUE
     TEST_COMMAND      ""
 )

samples/Common.c

@@ -794,14 +794,13 @@ STATUS lookForSslCert(PSampleConfiguration* ppSampleConfiguration)
     return retStatus;
 }
 
-STATUS createSampleConfiguration(PCHAR channelName, SIGNALING_CHANNEL_ROLE_TYPE roleType, BOOL trickleIce, BOOL useTurn, UINT32 logLevel,
-                                 PSampleConfiguration* ppSampleConfiguration)
+STATUS createSampleConfiguration(PCreateSampleConfigurationParams pCreateSampleConfigurationParams, PSampleConfiguration* ppSampleConfiguration)
 {
     STATUS retStatus = STATUS_SUCCESS;
     PCHAR pAccessKey, pSecretKey, pSessionToken;
     PSampleConfiguration pSampleConfiguration = NULL;
 
-    CHK(ppSampleConfiguration != NULL, STATUS_NULL_ARG);
+    CHK(ppSampleConfiguration != NULL && pCreateSampleConfigurationParams != NULL, STATUS_NULL_ARG);
 
     CHK(NULL != (pSampleConfiguration = (PSampleConfiguration) MEMCALLOC(1, SIZEOF(SampleConfiguration))), STATUS_NOT_ENOUGH_MEMORY);
 
@@ -870,23 +869,39 @@ STATUS createSampleConfiguration(PCHAR channelName, SIGNALING_CHANNEL_ROLE_TYPE
     pSampleConfiguration->signalingSendMessageLock = MUTEX_CREATE(FALSE);
     /* This is ignored for master. Master can extract the info from offer. Viewer has to know if peer can trickle or
      * not ahead of time. */
-    pSampleConfiguration->trickleIce = trickleIce;
-    pSampleConfiguration->useTurn = useTurn;
+    pSampleConfiguration->trickleIce = pCreateSampleConfigurationParams->trickleIce;
+    pSampleConfiguration->useTurn = pCreateSampleConfigurationParams->useTurn;
     pSampleConfiguration->enableSendingMetricsToViewerViaDc = FALSE;
     pSampleConfiguration->receiveAudioVideoSource = NULL;
 
     pSampleConfiguration->channelInfo.version = CHANNEL_INFO_CURRENT_VERSION;
-    pSampleConfiguration->channelInfo.pChannelName = channelName;
+    pSampleConfiguration->channelInfo.pChannelName = pCreateSampleConfigurationParams->channelName;
 #ifdef IOT_CORE_ENABLE_CREDENTIALS
     if ((pIotCoreCertificateId = GETENV(IOT_CORE_CERTIFICATE_ID)) != NULL) {
         pSampleConfiguration->channelInfo.pChannelName = pIotCoreCertificateId;
     }
 #endif
+
+    if(pCreateSampleConfigurationParams->useDualStackEndpoints) {
+        // Create the custom fully qualified control plane endpoint, sans the legacy/dual-stack postfix.
+        SNPRINTF(pSampleConfiguration->customControlPlaneEndpoint, MAX_CONTROL_PLANE_URI_CHAR_LEN, "%s%s.%s", CONTROL_PLANE_URI_PREFIX, KINESIS_VIDEO_SERVICE_NAME, pSampleConfiguration->channelInfo.pRegion);
+
+        if (STRSTR(pSampleConfiguration->channelInfo.pRegion, "cn-")) {
+            STRCAT(pSampleConfiguration->customControlPlaneEndpoint, CONTROL_PLANE_URI_POSTFIX_CN_DUAL_STACK); // Will use CN region dual-stack endpoint.
+        } else {
+            STRCAT(pSampleConfiguration->customControlPlaneEndpoint, CONTROL_PLANE_URI_POSTFIX_DUAL_STACK); // Will use Dual-stack endpoint.
+        }
+
+        pSampleConfiguration->channelInfo.pControlPlaneUrl = pSampleConfiguration->customControlPlaneEndpoint;
+    } else {
+        pSampleConfiguration->channelInfo.pControlPlaneUrl = NULL; // Will use default legacy endpoints.
+    }
+
     pSampleConfiguration->channelInfo.pKmsKeyId = NULL;
     pSampleConfiguration->channelInfo.tagCount = 0;
     pSampleConfiguration->channelInfo.pTags = NULL;
     pSampleConfiguration->channelInfo.channelType = SIGNALING_CHANNEL_TYPE_SINGLE_MASTER;
-    pSampleConfiguration->channelInfo.channelRoleType = roleType;
+    pSampleConfiguration->channelInfo.channelRoleType = pCreateSampleConfigurationParams->roleType;
     pSampleConfiguration->channelInfo.cachingPolicy = SIGNALING_API_CALL_CACHE_TYPE_FILE;
     pSampleConfiguration->channelInfo.cachingPeriod = SIGNALING_API_CALL_CACHE_TTL_SENTINEL_VALUE;
     pSampleConfiguration->channelInfo.asyncIceServerConfig = TRUE; // has no effect
@@ -901,7 +916,7 @@ STATUS createSampleConfiguration(PCHAR channelName, SIGNALING_CHANNEL_ROLE_TYPE
     pSampleConfiguration->signalingClientCallbacks.customData = (UINT64) pSampleConfiguration;
 
     pSampleConfiguration->clientInfo.version = SIGNALING_CLIENT_INFO_CURRENT_VERSION;
-    pSampleConfiguration->clientInfo.loggingLevel = logLevel;
+    pSampleConfiguration->clientInfo.loggingLevel = pCreateSampleConfigurationParams->logLevel;
     pSampleConfiguration->clientInfo.cacheFilePath = NULL; // Use the default path
     pSampleConfiguration->clientInfo.signalingClientCreationMaxRetryAttempts = CREATE_SIGNALING_CLIENT_RETRY_ATTEMPTS_SENTINEL_VALUE;
     pSampleConfiguration->iceCandidatePairStatsTimerId = MAX_UINT32;

samples/Samples.h

@@ -115,6 +115,15 @@ typedef struct {
     UINT64 prevTs;
 } RtcMetricsHistory, *PRtcMetricsHistory;
 
+typedef struct {
+    PCHAR channelName;
+    SIGNALING_CHANNEL_ROLE_TYPE roleType;
+    BOOL trickleIce;
+    BOOL useTurn;
+    BOOL useDualStackEndpoints;
+    UINT32 logLevel;
+} CreateSampleConfigurationParams, *PCreateSampleConfigurationParams;
+
 typedef struct {
     volatile ATOMIC_BOOL appTerminateFlag;
     volatile ATOMIC_BOOL interrupted;
@@ -176,6 +185,8 @@ typedef struct {
     UINT32 logLevel;
     BOOL enableTwcc;
     BOOL enableIceStats;
+    BOOL useDualStackEndpoints;
+    CHAR customControlPlaneEndpoint[MAX_CONTROL_PLANE_URI_CHAR_LEN];
 } SampleConfiguration, *PSampleConfiguration;
 
 typedef struct {
@@ -247,7 +258,7 @@ PVOID sampleReceiveAudioVideoFrame(PVOID);
 PVOID getPeriodicIceCandidatePairStats(PVOID);
 STATUS getIceCandidatePairStatsCallback(UINT32, UINT64, UINT64);
 STATUS pregenerateCertTimerCallback(UINT32, UINT64, UINT64);
-STATUS createSampleConfiguration(PCHAR, SIGNALING_CHANNEL_ROLE_TYPE, BOOL, BOOL, UINT32, PSampleConfiguration*);
+STATUS createSampleConfiguration(PCreateSampleConfigurationParams, PSampleConfiguration*);
 STATUS freeSampleConfiguration(PSampleConfiguration*);
 STATUS signalingClientStateChanged(UINT64, SIGNALING_CLIENT_STATE);
 STATUS signalingMessageReceived(UINT64, PReceivedSignalingMessage);

samples/kvsWebRTCClientMaster.c

@@ -12,6 +12,7 @@ INT32 main(INT32 argc, CHAR* argv[])
     signalingClientMetrics.version = SIGNALING_CLIENT_METRICS_CURRENT_VERSION;
     RTC_CODEC audioCodec = RTC_CODEC_OPUS;
     RTC_CODEC videoCodec = RTC_CODEC_H264_PROFILE_42E01F_LEVEL_ASYMMETRY_ALLOWED_PACKETIZATION_MODE;
+    CreateSampleConfigurationParams createSampleConfigurationParams;
 
     SET_INSTRUMENTED_ALLOCATORS();
     UINT32 logLevel = setLogLevel();
@@ -27,8 +28,15 @@ INT32 main(INT32 argc, CHAR* argv[])
     pChannelName = argc > 1 ? argv[1] : SAMPLE_CHANNEL_NAME;
 #endif
 
-    CHK_STATUS(createSampleConfiguration(pChannelName, SIGNALING_CHANNEL_ROLE_TYPE_MASTER, TRUE, TRUE, logLevel, &pSampleConfiguration));
+    createSampleConfigurationParams.channelName = pChannelName;
+    createSampleConfigurationParams.roleType = SIGNALING_CHANNEL_ROLE_TYPE_MASTER;
+    createSampleConfigurationParams.trickleIce = TRUE;
+    createSampleConfigurationParams.useTurn = TRUE;
+    createSampleConfigurationParams.useDualStackEndpoints = FALSE;
+    createSampleConfigurationParams.logLevel = logLevel;
 
+    CHK_STATUS(createSampleConfiguration(&createSampleConfigurationParams, &pSampleConfiguration));
+
     if (argc > 3) {
         if (!STRCMP(argv[3], AUDIO_CODEC_NAME_OPUS)) {
             audioCodec = RTC_CODEC_OPUS;

samples/kvsWebRTCClientViewer.c

@@ -44,6 +44,7 @@ INT32 main(INT32 argc, CHAR* argv[])
     BOOL locked = FALSE;
     PCHAR pChannelName;
     CHAR clientId[256];
+    CreateSampleConfigurationParams createSampleConfigurationParams;
 
     SET_INSTRUMENTED_ALLOCATORS();
     UINT32 logLevel = setLogLevel();
@@ -81,7 +82,14 @@ INT32 main(INT32 argc, CHAR* argv[])
         }
     }
 
-    CHK_STATUS(createSampleConfiguration(pChannelName, SIGNALING_CHANNEL_ROLE_TYPE_VIEWER, TRUE, TRUE, logLevel, &pSampleConfiguration));
+    createSampleConfigurationParams.channelName = pChannelName;
+    createSampleConfigurationParams.roleType = SIGNALING_CHANNEL_ROLE_TYPE_VIEWER;
+    createSampleConfigurationParams.trickleIce = TRUE;
+    createSampleConfigurationParams.useTurn = TRUE;
+    createSampleConfigurationParams.useDualStackEndpoints = FALSE;
+    createSampleConfigurationParams.logLevel = logLevel;
+
+    CHK_STATUS(createSampleConfiguration(&createSampleConfigurationParams, &pSampleConfiguration));
     pSampleConfiguration->mediaType = SAMPLE_STREAMING_AUDIO_VIDEO;
     pSampleConfiguration->audioCodec = audioCodec;
     pSampleConfiguration->videoCodec = videoCodec;

samples/kvsWebRTCClientViewerGstSample.c

@@ -44,6 +44,7 @@ INT32 main(INT32 argc, CHAR* argv[])
     BOOL locked = FALSE;
     PCHAR pChannelName;
     CHAR clientId[256];
+    CreateSampleConfigurationParams createSampleConfigurationParams;
 
     SET_INSTRUMENTED_ALLOCATORS();
     UINT32 logLevel = setLogLevel();
@@ -74,8 +75,15 @@ INT32 main(INT32 argc, CHAR* argv[])
             DLOGI("[KVS Gstreamer Viewer] Defaulting to H264 video codec");
         }
     }
-
-    CHK_STATUS(createSampleConfiguration(pChannelName, SIGNALING_CHANNEL_ROLE_TYPE_VIEWER, TRUE, TRUE, logLevel, &pSampleConfiguration));
+
+    createSampleConfigurationParams.channelName = pChannelName;
+    createSampleConfigurationParams.roleType = SIGNALING_CHANNEL_ROLE_TYPE_VIEWER;
+    createSampleConfigurationParams.trickleIce = TRUE;
+    createSampleConfigurationParams.useTurn = TRUE;
+    createSampleConfigurationParams.useDualStackEndpoints = FALSE;
+    createSampleConfigurationParams.logLevel = logLevel;
+
+    CHK_STATUS(createSampleConfiguration(&createSampleConfigurationParams, &pSampleConfiguration));
     pSampleConfiguration->mediaType = SAMPLE_STREAMING_AUDIO_VIDEO;
     pSampleConfiguration->receiveAudioVideoSource = receiveGstreamerAudioVideo;
     pSampleConfiguration->audioCodec = audioCodec;

samples/kvsWebrtcClientMasterGstSample.c

@@ -359,6 +359,7 @@ INT32 main(INT32 argc, CHAR* argv[])
     PCHAR pChannelName;
     RTC_CODEC audioCodec = RTC_CODEC_OPUS;
     RTC_CODEC videoCodec = RTC_CODEC_H264_PROFILE_42E01F_LEVEL_ASYMMETRY_ALLOWED_PACKETIZATION_MODE;
+    CreateSampleConfigurationParams createSampleConfigurationParams;
 
     SET_INSTRUMENTED_ALLOCATORS();
     UINT32 logLevel = setLogLevel();
@@ -372,7 +373,14 @@ INT32 main(INT32 argc, CHAR* argv[])
     pChannelName = argc > 1 ? argv[1] : SAMPLE_CHANNEL_NAME;
 #endif
 
-    CHK_STATUS(createSampleConfiguration(pChannelName, SIGNALING_CHANNEL_ROLE_TYPE_MASTER, TRUE, TRUE, logLevel, &pSampleConfiguration));
+    createSampleConfigurationParams.channelName = pChannelName;
+    createSampleConfigurationParams.roleType = SIGNALING_CHANNEL_ROLE_TYPE_MASTER;
+    createSampleConfigurationParams.trickleIce = TRUE;
+    createSampleConfigurationParams.useTurn = TRUE;
+    createSampleConfigurationParams.useDualStackEndpoints = FALSE;
+    createSampleConfigurationParams.logLevel = logLevel;
+
+    CHK_STATUS(createSampleConfiguration(&createSampleConfigurationParams, &pSampleConfiguration));
 
     if (argc > 3 && STRCMP(argv[3], "testsrc") == 0) {
         if (argc > 4) {

src/include/com/amazonaws/kinesis/video/webrtcclient/Include.h

@@ -460,6 +460,11 @@ extern "C" {
  */
 #define MAX_SIGNALING_ENDPOINT_URI_LEN 512
 
+/**
+ * Maximum allowed Control Plane URI length
+ */
+#define MAX_CONTROL_PLANE_URI_CHAR_LEN 256
+
 /**
  * Maximum allowed correlation ID length
  */

src/source/Signaling/ChannelInfo.c

@@ -64,7 +64,7 @@ STATUS createValidateChannelInfo(PChannelInfo pOrigChannelInfo, PChannelInfo* pp
         pRegionPtr = DEFAULT_AWS_REGION;
     }
 
-    if (pOrigChannelInfo->pControlPlaneUrl != NULL) {
+    if (!IS_NULL_OR_EMPTY_STRING(pOrigChannelInfo->pControlPlaneUrl)) {
         CHK((cpUrlLen = (UINT32) STRNLEN(pOrigChannelInfo->pControlPlaneUrl, MAX_URI_CHAR_LEN + 1)) <= MAX_URI_CHAR_LEN,
             STATUS_SIGNALING_INVALID_CPL_LENGTH);
     } else {
@@ -173,7 +173,7 @@ STATUS createValidateChannelInfo(PChannelInfo pOrigChannelInfo, PChannelInfo* pp
     pChannelInfo->pRegion = pCurPtr;
     pCurPtr += ALIGN_UP_TO_MACHINE_WORD(regionLen + 1);
 
-    if (pOrigChannelInfo->pControlPlaneUrl != NULL && *pOrigChannelInfo->pControlPlaneUrl != '\0') {
+    if (!IS_NULL_OR_EMPTY_STRING(pOrigChannelInfo->pControlPlaneUrl)) {
         STRCPY(pCurPtr, pOrigChannelInfo->pControlPlaneUrl);
     } else {
         // Create a fully qualified URI

src/source/Signaling/ChannelInfo.h

@@ -10,9 +10,6 @@ Signaling internal include file
 extern "C" {
 #endif
 
-// Max control plane URI char len
-#define MAX_CONTROL_PLANE_URI_CHAR_LEN 256
-
 // Max channel status string length in describe API call in chars
 #define MAX_DESCRIBE_CHANNEL_STATUS_LEN 32
 

tst/DualStackEndpointsTest.cpp

@@ -0,0 +1,138 @@
+#include "WebRTCClientTestFixture.h"
+
+namespace com {
+namespace amazonaws {
+namespace kinesis {
+namespace video {
+namespace webrtcclient {
+
+class DualStackEndpointsTest : public WebRtcClientTestBase {
+};
+
+TEST_F(DualStackEndpointsTest, customControlPlaneEndpointBasicCase)
+{
+    STATUS retStatus;
+    ChannelInfo channelInfo;
+    memset(&channelInfo, 0, sizeof(channelInfo));
+    PChannelInfo pChannelInfo;
+    CHAR originalCustomControlPlaneUrl[MAX_CONTROL_PLANE_URI_CHAR_LEN] = "https://kinesisvideo.us-west-2.api.aws";
+    CHAR validatedCustomControlPlaneUrl[MAX_CONTROL_PLANE_URI_CHAR_LEN]  =  {0};
+
+    // Make a deep copy of originalCustomControlPlaneUrl into validatedCustomControlPlaneUrl to save the value for later comparison.
+    strncpy(validatedCustomControlPlaneUrl, originalCustomControlPlaneUrl, MAX_CONTROL_PLANE_URI_CHAR_LEN);
+    validatedCustomControlPlaneUrl[MAX_CONTROL_PLANE_URI_CHAR_LEN - 1] = '\0';
+
+    channelInfo.pControlPlaneUrl = (PCHAR) validatedCustomControlPlaneUrl;
+
+    // pChannelName must be set to make the createValidateChannelInfo call.
+    channelInfo.pChannelName = "TestChannelName";
+
+    EXPECT_EQ(STATUS_SUCCESS, createValidateChannelInfo(&channelInfo, &pChannelInfo));
+
+    // Validate the ChanelInfo's Control Plane URL against the originalCustomControlPlaneUrl.
+    EXPECT_STREQ(pChannelInfo->pControlPlaneUrl, (PCHAR) originalCustomControlPlaneUrl);
+
+    freeChannelInfo(&pChannelInfo);
+}
+
+TEST_F(DualStackEndpointsTest, customControlPlaneEndpointEdgeCases)
+{
+    STATUS retStatus;
+    ChannelInfo channelInfo;
+    memset(&channelInfo, 0, sizeof(channelInfo));
+    PChannelInfo pChannelInfo;
+
+    // TODO: Verify why we use MAX_URI_CHAR_LEN instead of MAX_CONTROL_PLANE_URI_CHAR_LEN for the custom URL.
+    // MAX_URI_CHAR_LEN does not include the null terminator, so add 1.
+    CHAR originalCustomControlPlaneUrl[MAX_URI_CHAR_LEN + 1] =  {0};
+    CHAR validatedCustomControlPlaneUrl[MAX_URI_CHAR_LEN + 1] =  {0};
+    CHAR expectedSdkGeneratedUri[MAX_CONTROL_PLANE_URI_CHAR_LEN] = {0};
+
+    // If createValidateChannelInfo needs to generate the URL, it will use DEFAULT_AWS_REGION since
+    // we are not setting a region on ChannelInfo.
+    SNPRINTF(expectedSdkGeneratedUri, sizeof(expectedSdkGeneratedUri), "%s%s.%s%s",
+             CONTROL_PLANE_URI_PREFIX, KINESIS_VIDEO_SERVICE_NAME, DEFAULT_AWS_REGION, CONTROL_PLANE_URI_POSTFIX);
+
+    channelInfo.pControlPlaneUrl = (PCHAR) validatedCustomControlPlaneUrl;
+
+    // pChannelName must be set to make the createValidateChannelInfo call.
+    channelInfo.pChannelName = "TestChannelName";
+
+
+    /* MAX URL ARRAY LENGTH (expect the custom URL be used) */
+
+    // Fill array full of non-null values, accounting for null terminator.
+    memset(originalCustomControlPlaneUrl, 'X', sizeof(originalCustomControlPlaneUrl));
+    originalCustomControlPlaneUrl[sizeof(originalCustomControlPlaneUrl) - 1] = '\0';
+
+    // Make a deep copy of originalCustomControlPlaneUrl into validatedCustomControlPlaneUrl to save the value for
+    //      later comparison in case createValidateChannelInfo modified validatedCustomControlPlaneUrl.
+    strncpy(validatedCustomControlPlaneUrl, originalCustomControlPlaneUrl, sizeof(validatedCustomControlPlaneUrl));
+    validatedCustomControlPlaneUrl[sizeof(validatedCustomControlPlaneUrl) - 1] = '\0';
+
+    channelInfo.pControlPlaneUrl = (PCHAR) validatedCustomControlPlaneUrl;
+
+    EXPECT_EQ(STATUS_SUCCESS, createValidateChannelInfo(&channelInfo, &pChannelInfo));
+
+    // Validate the ChanelInfo's Control Plane URL against originalCustomControlPlaneUrl in case createValidateChannelInfo
+    //      modified validatedCustomControlPlaneUrl.
+    EXPECT_STREQ(pChannelInfo->pControlPlaneUrl, (PCHAR) originalCustomControlPlaneUrl);
+    freeChannelInfo(&pChannelInfo);
+
+
+    /* EMPTY URL ARRAY (expect SDK to construct a proper URL) */
+
+    // Fill array with null values.
+    memset(validatedCustomControlPlaneUrl, 0, sizeof(validatedCustomControlPlaneUrl));
+
+    channelInfo.pControlPlaneUrl = (PCHAR) validatedCustomControlPlaneUrl;
+
+    EXPECT_EQ(STATUS_SUCCESS, createValidateChannelInfo(&channelInfo, &pChannelInfo));
+
+    // Validate the ChanelInfo's Control Plane URL should be the default one the SDK generated.
+    EXPECT_STREQ(pChannelInfo->pControlPlaneUrl, (PCHAR) expectedSdkGeneratedUri);
+    freeChannelInfo(&pChannelInfo);
+
+
+    /* NULL URL ARRAY (expect SDK to construct a proper URL) */
+
+    channelInfo.pControlPlaneUrl = (PCHAR) NULL;
+
+    EXPECT_EQ(STATUS_SUCCESS, createValidateChannelInfo(&channelInfo, &pChannelInfo));
+    EXPECT_STREQ(pChannelInfo->pControlPlaneUrl, (PCHAR) expectedSdkGeneratedUri);
+    freeChannelInfo(&pChannelInfo);
+}
+
+
+TEST_F(DualStackEndpointsTest, customControlPlaneMaxEndpointLengthFailingCase)
+{
+    STATUS retStatus;
+    ChannelInfo channelInfo;
+    memset(&channelInfo, 0, sizeof(channelInfo));
+    PChannelInfo pChannelInfo;
+
+
+    /* Exceed MAX URL ARRAY LENGTH (expect SDK to error out) */
+
+    // MAX_URI_CHAR_LEN does not include the null terminator, so add 2.
+    CHAR customControlPlaneUrl[MAX_URI_CHAR_LEN + 2] =  {0};
+
+    // pChannelName must be set to make the createValidateChannelInfo call.
+    channelInfo.pChannelName = "TestChannelName";
+
+    // Fill array full of non-null values, accounting for null terminator.
+    memset(customControlPlaneUrl, 'X', sizeof(customControlPlaneUrl));
+    customControlPlaneUrl[sizeof(customControlPlaneUrl) - 1] = '\0';
+
+    channelInfo.pControlPlaneUrl = (PCHAR) customControlPlaneUrl;
+
+    EXPECT_EQ(STATUS_SIGNALING_INVALID_CPL_LENGTH, createValidateChannelInfo(&channelInfo, &pChannelInfo));
+    freeChannelInfo(&pChannelInfo);
+}
+
+
+} // namespace webrtcclient
+} // namespace video
+} // namespace kinesis
+} // namespace amazonaws
+} // namespace com