MediaController::MjpegPull::Stream Class Reference

Represents an MJPEG pull stream. More...

#include <MjpegPullStream.h>

Public Member Functions
	Stream (MediaRequest &request)
	Constructor. More...
virtual	~Stream ()
	Virtual destructor. More...
bool	Play (float speed, unsigned int unixTime) override
	Call Play on the stream. More...
void	PlayStream (float speed, unsigned int unixTime) override
void	Pause () override
	Call Pause on the stream. More...
void	Stop () override
	Call TearDown on the stream. More...
bool	Resume (float speed, unsigned int unixTime) override
	Send PLAY on an existing stream. More...
bool	GoToLive () override
	Set the stream to Live and call Play. More...
void	NewRequest (MediaRequest &request) override
	Set the stream to a new source. More...
Public Member Functions inherited from MediaController::StreamBase
virtual	~StreamBase ()
	Virtual destructor. More...
bool	Play (float speed=0, unsigned int unixTime=0) override
	Call Play on the stream. More...
void	Pause () override
	Call Pause on the stream. More...
void	Stop () override
	Call TearDown on the stream. More...
void	NewRequest (MediaRequest &request) override
	Set the stream to a new source. More...
GstWrapper *	GetGstreamer () const
	Get the current GStreamer wrapper instance. More...
unsigned int	GetLastTimestamp () const
	Gets the current time of the stream. More...
Mode	GetMode () override
	Get the current playback mode. More...
Public Member Functions inherited from MediaController::IStream
virtual	~IStream ()
	Virtual destructor. More...

Private Attributes
VxSdk::IVxDataSession *	_dataSession

Additional Inherited Members
Public Types inherited from MediaController::IStream
enum	Mode {   kStopped,   kLive,   kPlayback }
	Values that represent the different playback modes. More...
Public Attributes inherited from MediaController::StreamBase
StreamState *	state
	The current state of the stream. More...
VxSdk::VxStreamProtocol::Value	protocol
	The protocol of the stream. More...
Protected Member Functions inherited from MediaController::StreamBase
	StreamBase (MediaRequest &request)
	Constructor. More...
Protected Attributes inherited from MediaController::StreamBase
MediaRequest	_mediaRequest
GstWrapper *	_gst

Detailed Description

Represents an MJPEG pull stream.

Definition at line 16 of file MjpegPullStream.h.

Inherits MediaController::StreamBase.

Constructor & Destructor Documentation

MjpegPull::Stream::Stream

(

MediaRequest &

request

)

Constructor.

Parameters

request	The requested media.
controller	A media controller object.

Definition at line 12 of file MjpegPullStream.cpp.

                                             : StreamBase(request) {
    Stream::NewRequest(request);
}

MjpegPull::Stream::~Stream ( )

virtual

Virtual destructor.

Definition at line 16 of file MjpegPullStream.cpp.

{}

Member Function Documentation

bool MjpegPull::Stream::GoToLive ( )

overridevirtual

Set the stream to Live and call Play.

Implements MediaController::IStream.

Definition at line 82 of file MjpegPullStream.cpp.

{ return true; }

void MjpegPull::Stream::NewRequest ( MediaRequest &  request )

overridevirtual

Set the stream to a new source.

Parameters

request

The new MediaRequest to reset the stream to.

Implements MediaController::IStream.

Definition at line 115 of file MjpegPullStream.cpp.

                                                      {
    _mediaRequest = request;
    _mediaRequest.dataSource->CreateMjpegDataSession(_dataSession);
    this->_gst->SetLocation(std::string(_dataSession->jpegUri));
    char* authToken = nullptr;
    int size = 0;
    VxSdk::VxResult::Value result = _dataSession->GetAuthToken(authToken, size);
    if (result == VxSdk::VxResult::kInsufficientSize) {
        // Allocate enough space for authToken
        authToken = new char[size];
        // The result should now be kOK since we have allocated enough space
        _dataSession->GetAuthToken(authToken, size);
    }

    if (authToken != nullptr)
        this->_gst->SetCookie(std::string(authToken));
}

void MjpegPull::Stream::Pause ( )

overridevirtual

Call Pause on the stream.

Implements MediaController::IStream.

Definition at line 58 of file MjpegPullStream.cpp.

                            {
    // If the jpegUri is empty do not send a request.
    if (_dataSession->jpegUri[0] == '\0')
        return;

    // Pausing the stream moves it to playback mode so the live stream session needs to be deleted.
    _dataSession->Pause();
    this->_gst->Pause();
    // The timestamp is set to the last received timestamp so Resume will start at the correct time.
    this->_gst->SetTimestamp(this->_gst->GetLastTimestamp());
    this->state = new PausedState();
}

bool MjpegPull::Stream::Play ( float  speed, unsigned int  unixTime  )

overridevirtual

Call Play on the stream.

Parameters

speed	The playback speed. Negative values can be used for reverse playback. A value of 0 will resume a paused stream.
unixTime	The start time for playback. A value of 0 will start a live stream.

Implements MediaController::IStream.

Definition at line 18 of file MjpegPullStream.cpp.

                                                             {
    // If the jpegUri is empty send a new stream request.
    if (_dataSession->jpegUri[0] == '\0')
        NewRequest(_mediaRequest);

    if (!this->_gst->IsPipelineActive())
        this->_gst->CreateMjpegPipeline();

    if (unixTime == 0) {
        VxSdk::VxResult::Value ret = _dataSession->GoLive();
        if (ret != VxSdk::VxResult::kOK)
            return false;

        this->_gst->SetMode(IController::kLive);
    }
    else
    {
        VxSdk::VxResult::Value ret = _dataSession->Seek(unixTime, speed);
        if (ret != VxSdk::VxResult::kOK)
            return false;

        this->_gst->SetMode(IController::kPlayback);
        // Set the initial timestamp to the seek time.
        this->_gst->SetTimestamp(unixTime);
    }

    if (speed < 1.0f && speed > -1.0f) {
        if (speed >= 0.0f)
            speed = 1.0f;
        else
            speed = -1.0f;
    }

    this->_gst->Play(speed);
    this->state = new PlayingState();
    return true;
}

void MjpegPull::Stream::PlayStream ( float  speed, unsigned int  unixTime  )

overridevirtual

Implements MediaController::IStream.

Definition at line 56 of file MjpegPullStream.cpp.

{ }

bool MjpegPull::Stream::Resume ( float  speed, unsigned int  unixTime  )

overridevirtual

Send PLAY on an existing stream.

Parameters

speed	The playback speed. Negative values can be used for reverse playback. A value of 0 will resume a paused stream.
unixTime	The start time for playback. A value of 0 will start a live stream.

Reimplemented from MediaController::StreamBase.

Definition at line 84 of file MjpegPullStream.cpp.

                                                               {
    // If the jpegUri is empty send a new stream request.
    if (_dataSession->jpegUri[0] == '\0')
        NewRequest(_mediaRequest);

    if (!this->_gst->IsPipelineActive())
        this->_gst->CreateMjpegPipeline();

    unsigned int seekTime = unixTime == 0 ? this->_gst->GetLastTimestamp() : unixTime;
    // Seek to the last received timestamp generated during the Pause call.
    VxSdk::VxResult::Value ret = _dataSession->Seek(seekTime, speed);
    if (ret != VxSdk::VxResult::kOK)
        return false;

    // Set the mode to playback.
    this->_gst->SetMode(IController::kPlayback);
    // Set the initial timestamp to the seek time.
    this->_gst->SetTimestamp(seekTime);

    if (speed < 1.0f && speed > -1.0f) {
        if (speed >= 0.0f)
            speed = 1.0f;
        else
            speed = -1.0f;
    }

    this->_gst->Play(speed);
    this->state = new PlayingState();
    return true;
}

void MjpegPull::Stream::Stop ( )

overridevirtual

Call TearDown on the stream.

Implements MediaController::IStream.

Definition at line 71 of file MjpegPullStream.cpp.

                           {
    // If the jpegUri is empty do not send a request.
    if (_dataSession->jpegUri[0] == '\0')
        return;

    _dataSession->DeleteDataSession();
    this->_gst->ClearPipeline();
    this->_gst->SetMode(IController::kStopped);
    this->state = new StoppedState();
}

Member Data Documentation

VxSdk::IVxDataSession* MediaController::MjpegPull::Stream::_dataSession

private

Definition at line 39 of file MjpegPullStream.h.

---

The documentation for this class was generated from the following files:

• C:/Git/VxSDK-Samples/MediaController/Include/MjpegPullStream.h
• C:/Git/VxSDK-Samples/MediaController/Source/MjpegPullStream.cpp