AWS KVS(Kinesis Video Streams)之WebRTC的C库

/** * Implementation of a data stream */ #define LOG_CLASS "Stream" #include "Include_i.h" /** * Static definitions of the states */ extern StateMachineState STREAM_STATE_MACHINE_STATES[]; extern UINT32 STREAM_STATE_MACHINE_STATE_COUNT; /** * Creates a new Kinesis Video stream */ STATUS createStream(PKinesisVideoClient pKinesisVideoClient, PStreamInfo pStreamInfo, PKinesisVideoStream* ppKinesisVideoStream) { ENTERS(); STATUS retStatus = STATUS_SUCCESS; PKinesisVideoStream pKinesisVideoStream = NULL; PContentView pView = NULL; PStackQueue pStackQueue = NULL; PMkvGenerator pMkvGenerator = NULL; PStateMachine pStateMachine = NULL; UINT32 allocationSize, maxViewItems, i; PBYTE pCurPnt = NULL; BOOL locked = FALSE; BOOL tearDownOnError = TRUE; CHAR tempStreamName[MAX_STREAM_NAME_LEN]; UINT32 trackInfoSize, tagsSize; CHK(pKinesisVideoClient != NULL && ppKinesisVideoStream != NULL, STATUS_NULL_ARG); // Set the return stream pointer first *ppKinesisVideoStream = NULL; // Validate the input structs CHK_STATUS(validateStreamInfo(pStreamInfo, &pKinesisVideoClient->clientCallbacks)); logStreamInfo(pStreamInfo); // Lock the client pKinesisVideoClient->clientCallbacks.lockMutexFn(pKinesisVideoClient->clientCallbacks.customData, pKinesisVideoClient->base.lock); locked = TRUE; // Check for the stream count CHK(pKinesisVideoClient->streamCount < pKinesisVideoClient->deviceInfo.streamCount, STATUS_MAX_STREAM_COUNT); // Fix-up the stream name if not specified if (pStreamInfo->name[0] == '\0') { createRandomName(tempStreamName, DEFAULT_STREAM_NAME_LEN, pKinesisVideoClient->clientCallbacks.getRandomNumberFn, pKinesisVideoClient->clientCallbacks.customData); } else { // Copy the stream name otherwise // NOTE: Stream name length has already been validated STRCPY(tempStreamName, pStreamInfo->name); } // Check if a stream by that name already exists for (i = 0; i < pKinesisVideoClient->deviceInfo.streamCount; i++) { if (NULL != pKinesisVideoClient->streams[i]) { CHK(0 != STRCMP(pKinesisVideoClient->streams[i]->streamInfo.name, tempStreamName), STATUS_DUPLICATE_STREAM_NAME); } } // Space for track info bits trackInfoSize = SIZEOF(TrackInfo) * pStreamInfo->streamCaps.trackInfoCount; // Get the max tags structure size CHK_STATUS(packageTags(pStreamInfo->tagCount, pStreamInfo->tags, 0, NULL, &tagsSize)); // Allocate the main struct // NOTE: The calloc will Zero the fields // We are allocating more than the structure size to accommodate for // the variable size buffers which will come at the end and for the tags allocationSize = SIZEOF(KinesisVideoStream) + tagsSize + trackInfoSize + MKV_SEGMENT_UUID_LEN; pKinesisVideoStream = (PKinesisVideoStream) MEMCALLOC(1, allocationSize); CHK(pKinesisVideoStream != NULL, STATUS_NOT_ENOUGH_MEMORY); // Set the stream id first available slot so during the teardown it will clean it up. for (i = 0; i < pKinesisVideoClient->deviceInfo.streamCount; i++) { if (NULL == pKinesisVideoClient->streams[i]) { // Found an empty slot pKinesisVideoStream->streamId = i; break; } } // set the maximum frame size observed to 0 pKinesisVideoStream->maxFrameSizeSeen = 0; // Set the back reference pKinesisVideoStream->pKinesisVideoClient = pKinesisVideoClient; // Set the basic info pKinesisVideoStream->base.identifier = KINESIS_VIDEO_OBJECT_IDENTIFIER_STREAM; pKinesisVideoStream->base.version = STREAM_CURRENT_VERSION; // Set the initial state and the stream status pKinesisVideoStream->streamState = STREAM_STATE_NONE; pKinesisVideoStream->streamStatus = STREAM_STATUS_CREATING; // Stream is not ready, not stopped and not closed pKinesisVideoStream->streamStopped = FALSE; pKinesisVideoStream->streamReady = FALSE; pKinesisVideoStream->streamClosed = FALSE; // Set the stream start timestamps and index pKinesisVideoStream->newSessionTimestamp = INVALID_TIMESTAMP_VALUE; pKinesisVideoStream->newSessionIndex = INVALID_VIEW_INDEX_VALUE; // Not in a grace period pKinesisVideoStream->gracePeriod = FALSE; // Shouldn't reset the generator on next key frame pKinesisVideoStream->resetGeneratorOnKeyFrame = FALSE; // Skip non-key frames at start pKinesisVideoStream->skipNonKeyFrames = TRUE; // Shouldn't reset the generator so set invalid time pKinesisVideoStream->resetGeneratorTime = INVALID_TIMESTAMP_VALUE; // No connections have been dropped as this is a new stream pKinesisVideoStream->connectionState = UPLOAD_CONNECTION_STATE_OK; // Set the last frame EoFr indicator pKinesisVideoStream->eofrFrame = FALSE; // Set the initial diagnostics information from the defaults pKinesisVideoStream->diagnostics.currentFrameRate = pStreamInfo->streamCaps.frameRate; pKinesisVideoStream->diagnostics.currentTransferRate = pStreamInfo->streamCaps.avgBandwidthBps; pKinesisVideoStream->diagnostics.accumulatedByteCount = 0; pKinesisVideoStream->diagnostics.lastFrameRateTimestamp = pKinesisVideoStream->diagnostics.lastTransferRateTimestamp = 0; // Set the trackers pKinesisVideoStream->eosTracker.size = 0; pKinesisVideoStream->eosTracker.offset = 0; pKinesisVideoStream->eosTracker.send = FALSE; pKinesisVideoStream->eosTracker.data = NULL; pKinesisVideoStream->metadataTracker.size = 0; pKinesisVideoStream->metadataTracker.offset = 0; pKinesisVideoStream->metadataTracker.send = FALSE; pKinesisVideoStream->metadataTracker.data = NULL; // initialize streamingAuthInfo expiration pKinesisVideoStream->streamingAuthInfo.expiration = INVALID_TIMESTAMP_VALUE; // Reset the current view item MEMSET(&pKinesisVideoStream->curViewItem, 0x00, SIZEOF(CurrentViewItem)); pKinesisVideoStream->curViewItem.viewItem.handle = INVALID_ALLOCATION_HANDLE_VALUE; // Copy the structures in their entirety MEMCPY(&pKinesisVideoStream->streamInfo, pStreamInfo, SIZEOF(StreamInfo)); fixupStreamInfo(&pKinesisVideoStream->streamInfo); // Fix-up the stream name if not specified if (pKinesisVideoStream->streamInfo.name[0] == '\0') { STRCPY(pKinesisVideoStream->streamInfo.name, tempStreamName); } // Create the stream lock pKinesisVideoStream->base.lock = pKinesisVideoClient->clientCallbacks.createMutexFn(pKinesisVideoClient->clientCallbacks.customData, TRUE); // Create the Ready state condition variable pKinesisVideoStream->base.ready = pKinesisVideoClient->clientCallbacks.createConditionVariableFn(pKinesisVideoClient->clientCallbacks.customData); // Create the Stream Closed notifier condition variable pKinesisVideoStream->streamClosedCondition = pKinesisVideoClient->clientCallbacks.createConditionVariableFn(pKinesisVideoClient->clientCallbacks.customData); // Create the buffer availability condition variable pKinesisVideoStream->bufferAvailabilityCondition = pKinesisVideoClient->clientCallbacks.createConditionVariableFn(pKinesisVideoClient->clientCallbacks.customData); // Fix-up the buffer duration and replay duration first if (pKinesisVideoStream->streamInfo.streamCaps.bufferDuration <= MIN_CONTENT_VIEW_BUFFER_DURATION) { pKinesisVideoStream->streamInfo.streamCaps.bufferDuration = MIN_VIEW_BUFFER_DURATION; } pKinesisVideoStream->streamInfo.streamCaps.replayDuration = MIN(pStreamInfo->streamCaps.bufferDuration, pStreamInfo->streamCaps.replayDuration); // Set the tags pointer to point after the KinesisVideoStream