CurlApiCallbacks.c File Reference

#include "Include_i.h"

Include dependency graph for CurlApiCallbacks.c:

Macros
#define	LOG_CLASS   "CurlApiCallbacks"

Functions
STATUS	createCurlApiCallbacks (PCallbacksProvider pCallbacksProvider, PCHAR region, API_CALL_CACHE_TYPE cacheType, UINT64 endpointCachingPeriod, PCHAR controlPlaneUrl, PCHAR certPath, PCHAR userAgentNamePostfix, PCHAR customUserAgent, PCurlApiCallbacks *ppCurlApiCallbacks)
STATUS	freeCurlApiCallbacks (PCurlApiCallbacks *ppCurlApiCallbacks)
STATUS	freeApiCallbacksCurl (PUINT64 customData)
STATUS	curlApiCallbacksShutdown (PCurlApiCallbacks pCurlApiCallbacks, UINT64 timeout)
STATUS	curlApiCallbacksMarkStreamShuttingdownCallback (UINT64 customData, PHashEntry pHashEntry)
STATUS	curlApiCallbacksCachedEndpointsTableShutdownCallback (UINT64 customData, PHashEntry pHashEntry)
STATUS	curlApiCallbacksShutdownActiveRequests (PCurlApiCallbacks pCurlApiCallbacks, STREAM_HANDLE streamHandle, UINT64 timeout, BOOL fromCurlThread, BOOL killThread)
STATUS	curlApiCallbacksShutdownCachedEndpoints (PCurlApiCallbacks pCurlApiCallbacks, STREAM_HANDLE streamHandle, BOOL removeFromTable)
STATUS	curlApiCallbacksShutdownActiveUploads (PCurlApiCallbacks pCurlApiCallbacks, STREAM_HANDLE streamHandle, UPLOAD_HANDLE uploadHandle, UINT64 timeout, BOOL fromCurlThread, BOOL killThread)
STATUS	notifyCallResult (PCallbacksProvider pCallbacksProvider, STATUS status, STREAM_HANDLE streamHandle)
STREAM_STATUS	getStreamStatusFromString (PCHAR status, UINT32 length)
STATUS	curlCallApi (PCurlRequest pCurlRequest)
STATUS	clientShutdownCurl (UINT64 customData, CLIENT_HANDLE clientHandle)
STATUS	shutdownStreamCurl (UINT64 customData, STREAM_HANDLE streamHandle, BOOL resetStream)
STATUS	dataAvailableCurl (UINT64 customData, STREAM_HANDLE streamHandle, PCHAR streamName, UPLOAD_HANDLE uploadHandle, UINT64 durationAvailable, UINT64 bytesAvailable)
STATUS	streamClosedCurl (UINT64 customData, STREAM_HANDLE streamHandle, UPLOAD_HANDLE uploadHandle)
STATUS	fragmentAckReceivedCurl (UINT64 customData, STREAM_HANDLE streamHandle, UPLOAD_HANDLE uploadHandle, PFragmentAck pFragmentAck)
STATUS	createDeviceCurl (UINT64 customData, PCHAR deviceName, PServiceCallContext pServiceCallContext)
STATUS	createStreamCurl (UINT64 customData, PCHAR deviceName, PCHAR streamName, PCHAR contentType, PCHAR kmsKeyId, UINT64 retentionPeriod, PServiceCallContext pServiceCallContext)
STATUS	createStreamCachingCurl (UINT64 customData, PCHAR deviceName, PCHAR streamName, PCHAR contentType, PCHAR kmsKeyId, UINT64 retentionPeriod, PServiceCallContext pServiceCallContext)
PVOID	createStreamCurlHandler (PVOID arg)
STATUS	describeStreamCurl (UINT64 customData, PCHAR streamName, PServiceCallContext pServiceCallContext)
STATUS	describeStreamCachingCurl (UINT64 customData, PCHAR streamName, PServiceCallContext pServiceCallContext)
PVOID	describeStreamCurlHandler (PVOID arg)
STATUS	getStreamingEndpointCurl (UINT64 customData, PCHAR streamName, PCHAR apiName, PServiceCallContext pServiceCallContext)
STATUS	getStreamingEndpointCachingCurl (UINT64 customData, PCHAR streamName, PCHAR apiName, PServiceCallContext pServiceCallContext)
PVOID	getStreamingEndpointCurlHandler (PVOID arg)
STATUS	tagResourceCurl (UINT64 customData, PCHAR streamArn, UINT32 tagCount, PTag tags, PServiceCallContext pServiceCallContext)
STATUS	tagResourceCachingCurl (UINT64 customData, PCHAR streamArn, UINT32 tagCount, PTag tags, PServiceCallContext pServiceCallContext)
PVOID	tagResourceCurlHandler (PVOID arg)
STATUS	putStreamCurl (UINT64 customData, PCHAR streamName, PCHAR containerType, UINT64 startTimestamp, BOOL absoluteFragmentTimestamp, BOOL acksEnabled, PCHAR streamingEndpoint, PServiceCallContext pServiceCallContext)
PVOID	putStreamCurlHandler (PVOID arg)
STATUS	findRequestWithUploadHandle (UPLOAD_HANDLE uploadHandle, PCurlApiCallbacks pCurlApiCallbacks, PCurlRequest *ppCurlRequest)
STATUS	checkApiCallEmulation (PCurlApiCallbacks pCurlApiCallbacks, STREAM_HANDLE streamHandle, PBOOL pEmulateApiCall)

Macro Definition Documentation

LOG_CLASS

#define LOG_CLASS   "CurlApiCallbacks"

Kinesis Video Producer CURL based API Callbacks

Function Documentation

checkApiCallEmulation()

STATUS checkApiCallEmulation	(	PCurlApiCallbacks	pCurlApiCallbacks,
		STREAM_HANDLE	streamHandle,
		PBOOL	pEmulateApiCall
	)

Here is the caller graph for this function:

clientShutdownCurl()

STATUS clientShutdownCurl	(	UINT64	customData,
		CLIENT_HANDLE	clientHandle
	)

Here is the call graph for this function:

Here is the caller graph for this function:

createCurlApiCallbacks()

STATUS createCurlApiCallbacks	(	PCallbacksProvider	pCallbacksProvider,
		PCHAR	region,
		API_CALL_CACHE_TYPE	cacheType,
		UINT64	endpointCachingPeriod,
		PCHAR	controlPlaneUrl,
		PCHAR	certPath,
		PCHAR	userAgentNamePostfix,
		PCHAR	customUserAgent,
		PCurlApiCallbacks *	ppCurlApiCallbacks
	)

Creates CURL based API callbacks provider

Here is the call graph for this function:

Here is the caller graph for this function:

createDeviceCurl()

STATUS createDeviceCurl	(	UINT64	customData,
		PCHAR	deviceName,
		PServiceCallContext	pServiceCallContext
	)

Here is the caller graph for this function:

createStreamCachingCurl()

STATUS createStreamCachingCurl	(	UINT64	customData,
		PCHAR	deviceName,
		PCHAR	streamName,
		PCHAR	contentType,
		PCHAR	kmsKeyId,
		UINT64	retentionPeriod,
		PServiceCallContext	pServiceCallContext
	)

Here is the call graph for this function:

Here is the caller graph for this function:

createStreamCurl()

STATUS createStreamCurl	(	UINT64	customData,
		PCHAR	deviceName,
		PCHAR	streamName,
		PCHAR	contentType,
		PCHAR	kmsKeyId,
		UINT64	retentionPeriod,
		PServiceCallContext	pServiceCallContext
	)

Here is the call graph for this function:

Here is the caller graph for this function:

createStreamCurlHandler()

PVOID createStreamCurlHandler

(

PVOID

arg

)

Here is the call graph for this function:

Here is the caller graph for this function:

curlApiCallbacksCachedEndpointsTableShutdownCallback()

STATUS curlApiCallbacksCachedEndpointsTableShutdownCallback	(	UINT64	customData,
		PHashEntry	pHashEntry
	)

Here is the call graph for this function:

Here is the caller graph for this function:

curlApiCallbacksMarkStreamShuttingdownCallback()

STATUS curlApiCallbacksMarkStreamShuttingdownCallback	(	UINT64	customData,
		PHashEntry	pHashEntry
	)

Here is the caller graph for this function:

curlApiCallbacksShutdown()

STATUS curlApiCallbacksShutdown	(	PCurlApiCallbacks	pCurlApiCallbacks,
		UINT64	timeout
	)

Here is the call graph for this function:

Here is the caller graph for this function:

curlApiCallbacksShutdownActiveRequests()

STATUS curlApiCallbacksShutdownActiveRequests	(	PCurlApiCallbacks	pCurlApiCallbacks,
		STREAM_HANDLE	streamHandle,
		UINT64	timeout,
		BOOL	fromCurlThread,
		BOOL	killThread
	)

Here is the call graph for this function:

Here is the caller graph for this function:

curlApiCallbacksShutdownActiveUploads()

STATUS curlApiCallbacksShutdownActiveUploads	(	PCurlApiCallbacks	pCurlApiCallbacks,
		STREAM_HANDLE	streamHandle,
		UPLOAD_HANDLE	uploadHandle,
		UINT64	timeout,
		BOOL	fromCurlThread,
		BOOL	killThread
	)

Here is the call graph for this function:

Here is the caller graph for this function:

curlApiCallbacksShutdownCachedEndpoints()

STATUS curlApiCallbacksShutdownCachedEndpoints	(	PCurlApiCallbacks	pCurlApiCallbacks,
		STREAM_HANDLE	streamHandle,
		BOOL	removeFromTable
	)

Here is the caller graph for this function:

curlCallApi()

STATUS curlCallApi

(

PCurlRequest

pCurlRequest

)

Here is the call graph for this function:

Here is the caller graph for this function:

dataAvailableCurl()

STATUS dataAvailableCurl	(	UINT64	customData,
		STREAM_HANDLE	streamHandle,
		PCHAR	streamName,
		UPLOAD_HANDLE	uploadHandle,
		UINT64	durationAvailable,
		UINT64	bytesAvailable
	)

Here is the call graph for this function:

Here is the caller graph for this function:

describeStreamCachingCurl()

STATUS describeStreamCachingCurl	(	UINT64	customData,
		PCHAR	streamName,
		PServiceCallContext	pServiceCallContext
	)

Here is the call graph for this function:

Here is the caller graph for this function:

describeStreamCurl()

STATUS describeStreamCurl	(	UINT64	customData,
		PCHAR	streamName,
		PServiceCallContext	pServiceCallContext
	)

Here is the call graph for this function:

Here is the caller graph for this function:

describeStreamCurlHandler()

PVOID describeStreamCurlHandler

(

PVOID

arg

)

Here is the call graph for this function:

Here is the caller graph for this function:

findRequestWithUploadHandle()

STATUS findRequestWithUploadHandle	(	UPLOAD_HANDLE	uploadHandle,
		PCurlApiCallbacks	pCurlApiCallbacks,
		PCurlRequest *	ppCurlRequest
	)

Here is the caller graph for this function:

fragmentAckReceivedCurl()

STATUS fragmentAckReceivedCurl	(	UINT64	customData,
		STREAM_HANDLE	streamHandle,
		UPLOAD_HANDLE	uploadHandle,
		PFragmentAck	pFragmentAck
	)

Here is the call graph for this function:

Here is the caller graph for this function:

freeApiCallbacksCurl()

STATUS freeApiCallbacksCurl

(

PUINT64

customData

)

Here is the call graph for this function:

Here is the caller graph for this function:

freeCurlApiCallbacks()

STATUS freeCurlApiCallbacks

(

PCurlApiCallbacks *

ppCurlApiCallbacks

)

Frees the CURL API callbacks object

NOTE: The caller should have passed a pointer which was previously created by the corresponding function NOTE: The call is idempotent

Here is the call graph for this function:

Here is the caller graph for this function:

getStreamingEndpointCachingCurl()

STATUS getStreamingEndpointCachingCurl	(	UINT64	customData,
		PCHAR	streamName,
		PCHAR	apiName,
		PServiceCallContext	pServiceCallContext
	)

Here is the call graph for this function:

Here is the caller graph for this function:

getStreamingEndpointCurl()

STATUS getStreamingEndpointCurl	(	UINT64	customData,
		PCHAR	streamName,
		PCHAR	apiName,
		PServiceCallContext	pServiceCallContext
	)

Here is the call graph for this function:

Here is the caller graph for this function:

getStreamingEndpointCurlHandler()

PVOID getStreamingEndpointCurlHandler

(

PVOID

arg

)

Here is the call graph for this function:

Here is the caller graph for this function:

getStreamStatusFromString()

STREAM_STATUS getStreamStatusFromString	(	PCHAR	status,
		UINT32	length
	)

Here is the caller graph for this function:

notifyCallResult()

STATUS notifyCallResult	(	PCallbacksProvider	pCallbacksProvider,
		STATUS	status,
		STREAM_HANDLE	streamHandle
	)

Here is the caller graph for this function:

putStreamCurl()

STATUS putStreamCurl	(	UINT64	customData,
		PCHAR	streamName,
		PCHAR	containerType,
		UINT64	startTimestamp,
		BOOL	absoluteFragmentTimestamp,
		BOOL	acksEnabled,
		PCHAR	streamingEndpoint,
		PServiceCallContext	pServiceCallContext
	)

Here is the call graph for this function:

Here is the caller graph for this function:

putStreamCurlHandler()

PVOID putStreamCurlHandler

(

PVOID

arg

)

Here is the call graph for this function:

Here is the caller graph for this function:

shutdownStreamCurl()

STATUS shutdownStreamCurl	(	UINT64	customData,
		STREAM_HANDLE	streamHandle,
		BOOL	resetStream
	)

Here is the call graph for this function:

Here is the caller graph for this function:

streamClosedCurl()

STATUS streamClosedCurl	(	UINT64	customData,
		STREAM_HANDLE	streamHandle,
		UPLOAD_HANDLE	uploadHandle
	)

Here is the caller graph for this function:

tagResourceCachingCurl()

STATUS tagResourceCachingCurl	(	UINT64	customData,
		PCHAR	streamArn,
		UINT32	tagCount,
		PTag	tags,
		PServiceCallContext	pServiceCallContext
	)

Here is the call graph for this function:

Here is the caller graph for this function:

tagResourceCurl()

STATUS tagResourceCurl	(	UINT64	customData,
		PCHAR	streamArn,
		UINT32	tagCount,
		PTag	tags,
		PServiceCallContext	pServiceCallContext
	)

Here is the call graph for this function:

Here is the caller graph for this function:

tagResourceCurlHandler()

PVOID tagResourceCurlHandler

(

PVOID

arg

)

Here is the call graph for this function:

Here is the caller graph for this function: