Home    News    Components    Get ViTooKi    Documentation    Community    Developers    @sf.net  

Info

Last update:
12 Feb 2007

Documentation

Doxygen LXR

DataChannel Class Reference

a DataChannel object reads data from an input. <short description=""> More...

#include <DataChannel.hpp>

Inheritance diagram for DataChannel:

List of all members.

Public Member Functions
	DataChannel (IO *input, ESInfo *es)
	creates a DataChannel only a dummy adaptor is set
	DataChannel (IO *input, ESInfo *es, Adaptor *adapt)
	creates a DataChannel object that reads data from an input.
void	setAdaptor (Adaptor *adapt)
	changes the adaptor to a new one, works even while the thread is working.
void	setESInfo (ESInfo *new_es)
	changes the connected ESInfo
void	setFinalFrameNumber (long frameNumber)
	set the frame number, where the DC-thread should stop streaming.
void	initiateThreadStop (bool forceTearDown)
	waits until the DC-thread is stopped
void	setInput (IO *new_io)
bool	play (u32 clientId, double prefetch)
	Moves a previously inserted cliented from the paused list to the active list returns false when the DataChannel has already ended.
bool	mute (u32 clientId)
	mutes a client.
bool	unmute (u32 clientId)
	unmutes a MUTED client.
bool	pause (u32 clientId)
	pauses a client.
bool	insert (DataSink *c)
	inserts the client into the paused queue.
char *	enableCaching (bool omitHeader, const char *outDir, bool proxyMode=true, const Url *url=NULL)
	stores the result of the global Adaptor stream to the disk.
void	visualizeCaching ()
	renders the result of the global Adaptor stream to the screen.
bool	teardown (u32 clientId, bool immediate=false)
	returns false, when the client was not found in the active or paused queue.
bool	tearDownFlagSet () const
int	getNumberOfActiveDataSinks ()
	returns the number of active clients
IO *	getInput ()
Adaptor *	getAdaptor () const
void	run ()
	starts the thread.
void	setSessionId (int i)
uint	getSessionId () const
const ESInfo *	getESInfo () const
DataSink *	getDataSink (u32 clientId)
	returns the DataSink with id
const DataSink *	getActiveDataSink (u32 clientId)
list< u32 >	getListOfActiveClientIds ()
list< u32 >	getListOfPausedClientIds ()
void	setOutputStatistics (Statistics *stats)
	this is BIG HACK...
Statistics *	getOutputStatistics ()
	this is BIG HACK...
Protected Attributes
int	sessionId
IO *	input
list< DataSink * >	active
	list of receivers
list< DataSink * >	paused
	list of paused receivers
DataSink *	localViewer
	local viewer
VMutex	lockDataSink
	Semaphore used to sync access to the active clients.
VMutex	lockInput
	Semaphore used to sync access to the Input IO.
VMutex	lockAdaptor
	a semaphore to lock the adaptor
Adaptor *	adaptor
	each DataChannel can have an Adaptor, per default a Forwarder is set here
list< Frame * >	sendQueue
bool	channelOpen
	specifies if new DataSinks can be added
bool	tearDown
bool	immediateClose
ESInfo *	es
Statistics *	outstats
long	currentFrameNumber
long	finalFrameNumber

---

Detailed Description

a DataChannel object reads data from an input. <short description="">

Note that you must at least add one DataSink via play before the DataChannel can actually send data. Each DataChannel has an Adaptor, after sending the data through the the Adaptor, the result of the adaptation is distributed to each DataSink. To each DataSink, there has to be attached an IO output

Author:

Michael Kropfberger and Peter Schojer

Version:

Id

DataChannel.hpp,v 1.23 2006/01/26 09:50:45 mkropfbe Exp

Definition at line 74 of file DataChannel.hpp.

---

Constructor & Destructor Documentation

DataChannel::DataChannel (  IO *  input, ESInfo *  es, Adaptor *  adapt )

creates a DataChannel object that reads data from an input. Note that you must at least add one DataSink via play before the DataChannel can actually send data. Each DataChannel has an Adaptor, after sending the data through the the Adaptor, the result of the adaptation is distributed to each DataSink. Definition at line 76 of file DataChannel.cpp. { init(in, es, adapt); };

---

Member Function Documentation

char * DataChannel::enableCaching (  bool  omitHeader, const char *  outDir, bool  proxyMode = true, const Url *  url = NULL )

stores the result of the global Adaptor stream to the disk. Parameters: proxyMode  tells how the filename is generated. if set to true the serverName is included in the local file name which makes it impossible to reuse demuxed files when the serverName changes return  returns a pointer to the new outName. This will create internally a DataSink with ID 1. Use this id to control the DataSink e.g. pause(1), teardown(1) etc. Definition at line 587 of file DataChannel.cpp. References active, channelOpen, ESInfo::getContainerInfo(), ContainerInfo::getLocalFile(), ESInfo::getStreamId(), ESInfo::isAudioStream(), ESInfo::isODStream(), ESInfo::isSceneDescriptionStream(), ESInfo::isVisualStream(), VMutex::lock(), lockDataSink, and VMutex::release(). Referenced by ContainerDemux::demultiplexAndUpdateIO(). { char *out = new char[1024]; IO* output=NULL; out[0] = 0; lockDataSink.lock(); if (channelOpen && es) { char intnum[32]; out[0] = 0; intnum[0] = 0; sprintf(intnum, "%llu", es->getStreamId()); if(!dir) { output=new DevNull(); } else { strcpy(out,dir); if(!(out[strlen(out)-1]=='/' || out[strlen(out)-1]=='\\' )) { int xy=strlen(out); out[xy]=PATHSEPARATORCHAR; out[xy+1]='\0'; } // problem: recursive servers -> eliminate path just get filename const char* tmp=es->getContainerInfo()->getLocalFile(); const char* t2=NULL; char* dummy=NULL; if(tmp!=NULL) { if((t2=strrchr(tmp,PATHSEPARATORCHAR))!=NULL) { t2++; } else t2=tmp; } if(url) { if(proxyMode) { dummy=Url::transformUrlToLocalFile(url); strcat(out,dummy); delete[] dummy; } else { dummy=Url::transformPathToLocalFile(url); strcat(out,dummy); delete[] dummy; } } else { strcat(out,"localfile"); if(t2) { strcat(out,"_"); strcat(out, t2); } } if (es->isVisualStream()) strcat(out, ".video."); else if (es->isAudioStream()) strcat(out, ".audio."); else if(es->isSceneDescriptionStream()) strcat(out, ".bifs."); else if(es->isODStream()) strcat(out, ".ODstream."); else strcat(out, ".generic."); strcat(out, intnum); // check if file exists!!!! FILE* fp=NULL; while((fp=fopen(out,"r")) != 0) { // merde! file exists sprintf(out,"%s%u",out,(unsigned int)(rand()%10)); fclose(fp);fp=NULL; } if(fp) fclose(fp); // create a writer, out is deep-copied, also in QFile! output = new MPGStreamIO(es, out, true, omitHeader); if (!output->open()) { dprintf_err("DataChannel::enableCaching: Failed to open output channel\n"); } } char tmp2[12]; strcpy(tmp2, "127.0.0.1"); DataSink *c = new DataSink(0,output, tmp2, 0, 0); active.push_front(c); } lockDataSink.release(); return out; };

DataSink * DataChannel::getDataSink (  u32  clientId  )

returns the DataSink with id Parameters: clientId.  searches only in paused. You are not allowed to change clients that are currently playing Definition at line 806 of file DataChannel.cpp. References VMutex::lock(), lockDataSink, paused, and VMutex::release(). { DataSink* result=NULL; lockDataSink.lock(); if(!paused.empty()) { list < DataSink * >::iterator li = paused.begin(); while(li != paused.end()) { if((*li)->getDataSinkId()==clientId) { result=(*li); li=paused.end(); } else ++li; } } lockDataSink.release(); return result; };

Statistics * DataChannel::getOutputStatistics (   )

this is BIG HACK... by that, you get only one output stats from the first datasink out (eg. RTP) since the code isnt able to cope with more than one networked DataSink anyway, it should workDefinition at line 974 of file DataChannel.cpp. { return outstats; }

void DataChannel::initiateThreadStop (  bool  forceTearDown  )

waits until the DC-thread is stopped Parameters: forceTearDown:  true will immedately stop the DC-thread, false will block until the DC is done with input or has reached finalFrameNumber Definition at line 477 of file DataChannel.cpp. { if (forceTearDown) tearDown=true; //if not forceTearDown, thread will stop when finalFrameNumber is reached while ( this->running() || !this->finished()) { msleep(40); dprintf_full("DataChannel::initiateThreadStop waiting on DataChannel::run finished... sendQueue (%i elems)\n",sendQueue.size()); } if (forceTearDown) tearDown=false; }

bool DataChannel::insert (  DataSink *  c  )

inserts the client into the paused queue. This is the first mandatory step, if you want to start playing a client.Definition at line 794 of file DataChannel.cpp. References DataSink::getDataSinkId(), VMutex::lock(), lockDataSink, paused, and VMutex::release(). Referenced by ContainerDemux::createDataChannel(). { dprintf_full("DataChannel::insert(DataSink* c=%p,c->clientId=%u\r\n)\r\n",c, (c?c->getDataSinkId():0)); lockDataSink.lock(); paused.push_front(c); lockDataSink.release(); return true; };

bool DataChannel::mute (  u32  clientId  )

mutes a client. The client stays on the active list, and received frames are still passed through the global DC adaptors (eg. statistics), but it will bypass the client adaptors (eg. decoding). But the frames will still be handed over to the I/O output classes' writeFrame for sync. To return to PLAY state, call DataChannel::unmute(clientId) Definition at line 718 of file DataChannel.cpp. References active, VMutex::lock(), lockDataSink, and VMutex::release(). { dprintf_full("DataChannel::mute(u32 clientId=%u)\r\n",clientId); if(active.empty()) return false; lockDataSink.lock(); list<DataSink*>::iterator cLi=active.begin(); while(cLi!=active.end()) { if( (*cLi)->getDataSinkId()==clientId) { (*cLi)->muteOutput(); lockDataSink.release(); return true; } cLi++; } lockDataSink.release(); return false; };

bool DataChannel::pause (  u32  clientId  )

pauses a client. The client is searched in the active list. If it is found there, it is moved to the pause queue. Otherwise false is returned. Note that when you pause the last client, the thread will terminate and has to be restarted where it will continue from the last frame. Definition at line 762 of file DataChannel.cpp. References active, VMutex::lock(), lockDataSink, IO::pause(), paused, and VMutex::release(). { if(active.empty()) { dprintf_full("DataChannel::pause(u32 clientId=%u): NO ACTIVE CLIENTS!\r\n",clientId); return false; } //pause the input stream input->pause(); lockDataSink.lock(); // remove the client from the active list list<DataSink*>::iterator cLi=active.begin(); while(cLi!=active.end()) { dprintf_full("DataChannel::pause found client %p Id=%u, looking for Id %u)\n", (*cLi), (*cLi)->getDataSinkId(),clientId); if( (*cLi)->getDataSinkId()==clientId) { paused.push_front((*cLi)); (*cLi)->pauseOutput(); active.remove(*cLi); lockDataSink.release(); return true; } cLi++; } lockDataSink.release(); return false; };

bool DataChannel::play (  u32  clientId, double  prefetch )

Moves a previously inserted cliented from the paused list to the active list returns false when the DataChannel has already ended. In this case the client is not added. Note that for at least one client play must be called PRIOR starting the DataChannel, otherwise the thread will terminate immediately. You can only play clients which were inserted previously. Definition at line 527 of file DataChannel.cpp. References active, channelOpen, VMutex::lock(), lockDataSink, paused, IO::play(), and VMutex::release(). Referenced by ContainerDemux::createDataChannel(). { dprintf_full("DataChannel::play(u32 clientId=%u prefetch %f)\r\n",clientId,prefetch); if(paused.empty()) { dprintf_err("DataChannel::play: (Empty) Failed to play non existing client %u\r\n",clientId); return false; } if(!input) { dprintf_err("bool DataChannel::play: No input is set!\r\n"); return false; } //FIXME: unpausing will only work for one DC with ONE client input->play(prefetch); //open the io stream (if not yet open) lockDataSink.lock(); // if (channelOpen && !tearDown) { // localDataSinkAdaptors are not allowed to modify the ES directly // FIXME: one DC -> one CLient // Problem here is the global Adaptor and // the local Adaptor, we could only clone an ES, when // the global adaptor is initialized! // the next three lines also break TC support // client receives an invalid (old) ESheader // through Rtp when the server adapts the stream // for the client // ESInfo *es2 = es->clone(es->getContainerInfo()); //c->getAdaptor()->setESInfo(es2); //c->getOutput()->setESInfo(es2); // remove the client from the paused list, list<DataSink*>::iterator cLi=paused.begin(); while(cLi!=paused.end()) { if( (*cLi)->getDataSinkId()==clientId) { active.push_front((*cLi)); (*cLi)->playOutput(prefetch); paused.remove(*cLi); lockDataSink.release(); dprintf_full("DataChannel::play: Started client %u\r\n",clientId); return true; } cLi++; } lockDataSink.release(); dprintf_err("DataChannel::play: Failed to play non existing paused client %u\r\n",clientId); return false; // } dprintf_err("DataChannel::play: Failed to play client %u. channelOpen=%i, tearDown=%i\r\n", clientId,channelOpen,tearDown); lockDataSink.release(); return false; };

void DataChannel::run (   )  [virtual]

starts the thread. if for no client play was called previously, the thread terminates immediately. If clients were set, the thread runs till the input reaches End-of-stream. When this state is reached, all buffered data is sent, then the active queue is emptied. The clients are not destroyed. Implements VThread. Definition at line 187 of file DataChannel.cpp. References active, Adaptor::adapt(), adaptor, channelOpen, Adaptor::close(), IO::close(), Frame::getAU(), IO::getFrame(), Adaptor::getName(), IO::getState(), IO::getURL(), localViewer, VMutex::lock(), lockAdaptor, lockDataSink, lockInput, IO::open(), VMutex::release(), DataSink::send(), and ESInfo::setCompleteState(). { bool resetSendHeader; dprintf_full("DataChannel::run: DC.Thread started: %s\n", input->getURL()); resetSendHeader=false; if (!active.empty() || localViewer) { if (input->getState()!=IO::OPEN && !input->open()) { dprintf_err("DataChannel::run: failed to open input\r\n"); return; } // read data from input dprintf_full("DataChannel::run: Input is open\n"); Frame *frm = NULL; //only continue if OPEN, PAUSED, MUTED, PREBUFFERING or STREAMEOF //STREAMEOF is not a problem, as long as eg. the Rtp Class still has buffered data! IO::State mystate = input->getState(); while (! ( (mystate == IO::CLOSED) || (mystate == IO::CLOSING) || (mystate == IO::STREAMERR) ) //|| (input->getState() == IO::STREAMEOF) ) && !tearDown && ((finalFrameNumber == -1) || (currentFrameNumber < finalFrameNumber)) ) { lockInput.lock(); lockDataSink.lock(); if(mystate == IO::OPENING) #ifndef WINCE msleep(10); #else Sleep(5); #endif if(active.empty() && !localViewer) { lockInput.release(); lockDataSink.release(); return; } lockDataSink.release(); //read frame frm = input->getFrame(); if( frm == NULL ) { dprintf_full("DataChannel::run no frm got via getFrame\n"); if(mystate != IO::OPEN) { if(frm) { delete frm; frm=NULL; } } lockInput.release(); } else { dprintf_full("DataChannel::run passing frame to adaptor\n"); // we got data // adapt it with the global adaptor (chain) lockAdaptor.lock(); list < Frame * >result; //adapt (i.e. decode) frame result = adaptor->adapt(frm); lockAdaptor.release(); if (!result.empty() ) { list < Frame * >::iterator rLi; // now append the received frame(s) to the sendqueue if(result.size()==1) { rLi=result.begin(); if ( frm && (*rLi) != frm) { // caching adaptors have to deep-copy the frame dprintf_full("DataChannel::run Frame was adapted and orig frame will be deleted now...\n"); delete frm; frm=NULL; } else { // frame is in result dprintf_full("DataChannel::run frame is in result\n"); frm=NULL; } } //append results to sendQueue while (!result.empty()) { rLi = result.begin(); if (!(*rLi)->isMarkedForDelete()) //may be dropped in ESSynchronizer sendQueue.push_back((*rLi)); else { dprintf_full("DataChannel::run adaptor result was marked for delete... dropping!\n"); delete (*rLi); (*rLi)=NULL; } result.pop_front(); } } else { dprintf_full("DataChannel::run adaptor result was empty!!! dropped, so delete frm CTS %i...\n",frm->getAU()->cts); //ATTENTION: DC only deletes frames coming from inputIO, not eg. adaptor-decoded and then dropped ones! //so make sure, to markForDelete() delete frm; frm=NULL; } lockInput.release(); } // end frame != NULL // result now empty // check if we have data in the sendqueue list < Frame * >::iterator rLi; if (sendQueue.empty() && (input->getState() == IO::STREAMEOF) ) break; //give up, no more data coming, nothing left to forward // must be an if not while -> avoids bursts if (!sendQueue.empty() && !tearDown) { // distribute it to all active clients lockDataSink.lock(); rLi = sendQueue.begin(); //set this frame to be deleted after all output-DataSinks, this may be changed by eg. buffering output-IOs (*rLi)->markForDelete(); if(!active.empty()) { dprintf_full("DataChannel::run: READ FRAME %p (currentFrameNumber %li)\n",(*rLi),currentFrameNumber); currentFrameNumber++; list < DataSink * >::iterator li = active.begin(); while (li != active.end()) { if(*rLi) { dprintf_full("Sending one frame %p (TS %i size %i) to one client\n",(*rLi), (*rLi)->getAU()->cts,(*rLi)->getAU()->size); if (!(*li)->send((*rLi))) { //finally, writeFrame of output class // sth went wrong dprintf_err("DataChannel::run: Sending of frame failed\n"); tearDown = true; } } ++li; } dprintf_full("DataChannel::run: SENT one FRAME %p to all clients\n",(*rLi)); } // when we have no client and not even a localViewer -> exit else if(!localViewer) { lockDataSink.release(); if((*rLi)) { delete (*rLi); (*rLi)=NULL; } return; } if(localViewer) localViewer->send( (*rLi) ); lockDataSink.release(); if ((*rLi)->isMarkedForDelete()) { dprintf_full("DataChannel::run cleanup sendQueue with frame %p\n",(*rLi)); if((*rLi)) delete (*rLi); } //else: ignore and let the buffering output-IO do the delete on it's own! *rLi=NULL; sendQueue.pop_front(); } else { dprintf_full("DataChannel::run sendQueue was empty!!! teardown %i\n",tearDown); } if(frm) { dprintf_full("DataChannel::run cleanup incoming frame %p\n",frm); delete frm; frm=NULL; } mystate = input->getState(); } // while() end reading //lockDataSink.lock(); channelOpen = false; //lockDataSink.release(); dprintf_full("DataChannel::run: Finished Reading (state %i) currentFrameNumber %li\n", input->getState(),currentFrameNumber); if(input->getState()==IO::STREAMEOF) resetSendHeader=true; input->close(true); if (adaptor && (strcmp(adaptor->getName(),"Forwarder") != 0)) { //maybe there is some cached data? list < Frame * >result; dprintf_full("DataChannel::run: Closing Adaptor %s\n",adaptor->getName()); result = adaptor->close(); list < Frame * >::iterator rLi; if (result.size() > 0) { dprintf_full("DataChannel::run: adaptor->close() returned %i frames\n",result.size()); // now append the received frame(s) to the sendqueue while (!result.empty()) { rLi = result.begin(); sendQueue.push_back((*rLi)); result.pop_front(); } // now we have read all data, we have to ensure that everything is sent dprintf_full("DataChannel::run: Sending %i cached frames\n",sendQueue.size()); while (!sendQueue.empty() && !tearDown) { // distribute it to all active clients rLi = sendQueue.begin(); //set this frame to be deleted after all output-DataSinks, this may be changed by eg. buffering output-IOs (*rLi)->markForDelete(); dprintf_full("DataChannel::run: READ cached FRAME\n"); lockDataSink.lock(); if(!active.empty()) { list < DataSink * >::iterator li = active.begin(); while (li != active.end() && !tearDown) { dprintf_full("DataChannel::run: Sending one frame to one client\n"); if (!(*li)->send((*rLi))) { // sth went wrong dprintf_err("DataChannel::run: Sending of frame failed\n"); } ++li; } } if(localViewer) localViewer->send( (*rLi) ); dprintf_full("DataChannel::run: SEND cached FRAME\n"); // finished with sending one frame lockDataSink.release(); if ((*rLi)->isMarkedForDelete()) { dprintf_full("DataChannel::run cleanup sendQueue with frame %p\n",(*rLi)); if((*rLi)) delete (*rLi); } //else: ignore and let the buffering output-IO do the delete on it's own! (*rLi)=NULL; sendQueue.pop_front(); } // end sending all frames } // if a teardown was received while sending, empty sendqueue while (!sendQueue.empty()) { rLi = sendQueue.begin(); dprintf_full("DataChannel::run, emptying sendqueue because of teardown: frame %p\n",(*rLi)); delete(*rLi); (*rLi)=NULL; sendQueue.pop_front(); } }// if(adaptor) // not necessary with BitField, but we better do it es->setCompleteState(true); } else { dprintf_small("DataChannel::run: Thread Started with no clients\n"); input->close(true); } channelOpen=true; closeAllClients(false); dprintf_small("DataChannel::run: EXIT!\n"); this->exit(); } //DataChannel::run

void DataChannel::setAdaptor (  Adaptor *  adapt  )

changes the adaptor to a new one, works even while the thread is working. If null is passed as parameter, a forwarder is set Definition at line 455 of file DataChannel.cpp. References adaptor, VMutex::lock(), lockAdaptor, and VMutex::release(). Referenced by ContainerDemux::createDataChannel(). { lockAdaptor.lock(); delete adaptor; adaptor = adapt; if (!adaptor) { adaptor = new Forwarder(); } lockAdaptor.release(); };

void DataChannel::setFinalFrameNumber (  long  frameNumber  )

set the frame number, where the DC-thread should stop streaming. this is needed for reaching the switchPoint for stream switchingDefinition at line 473 of file DataChannel.cpp. { finalFrameNumber = frameNumber; }

void DataChannel::setOutputStatistics (  Statistics *  stats  )

this is BIG HACK... by that, we set the stats of the FIRST dataSink output (eg. RTP), since the code isnt able to cope with more than one networked DataSink anyway :(Definition at line 969 of file DataChannel.cpp. { //just overwrite old stats, if exist (stats will be deleted elsewhere) outstats = stats; }

bool DataChannel::teardown (  u32  clientId, bool  immediate = false )

returns false, when the client was not found in the active or paused queue. If c was found, the client will be deleted! Definition at line 904 of file DataChannel.cpp. References active, channelOpen, IO::close(), VMutex::lock(), lockDataSink, paused, and VMutex::release(). { dprintf_full("DataChannel::teardown(u32 clientId=%u,bool immediate=%i)\r\n",clientId,immediate); lockDataSink.lock(); immediateClose=immediate; if(active.empty()) { dprintf_full("DataChannel::teardown: Closing input\r\n"); if (input) input->close(immediate); tearDown=true; channelOpen=false; } // remove the client from the active list, list < DataSink * >::iterator li = active.begin(); while (li != active.end()) { if (clientId == (*li)->getDataSinkId()) { dprintf_full("DataChannel::teardown: Deleted client from active list\r\n"); delete *li; *li=NULL; active.erase(li); if(active.empty()) { dprintf_full("DataChannel::teardown: Closing input from active list \r\n"); if (input) input->close(immediate); tearDown=true; channelOpen=false; } lockDataSink.release(); return true; } ++li; } //while // if not found on active, remove the client from the pause list, li = paused.begin(); while (li != paused.end()) { if (clientId == (*li)->getDataSinkId()) { dprintf_full("DataChannel::teardown: Deleted client from paused list\r\n"); delete *li; *li=NULL; paused.erase(li); if(paused.empty()) { dprintf_full("DataChannel::teardown: Closing input from paused list \r\n"); if (input) input->close(immediate); tearDown=true; channelOpen=false; } lockDataSink.release(); return true; } ++li; } //while // client really not found dprintf_err("DataChannel::teardown DataSink not found\r\n"); fflush(stdout); lockDataSink.release(); return false; };

bool DataChannel::unmute (  u32  clientId  )

unmutes a MUTED client. This returns the client into PLAY state Definition at line 740 of file DataChannel.cpp. References active, VMutex::lock(), lockDataSink, and VMutex::release(). { dprintf_full("DataChannel::unmute(u32 clientId=%u)\r\n",clientId); if(active.empty()) return false; lockDataSink.lock(); list<DataSink*>::iterator cLi=active.begin(); while(cLi!=active.end()) { if( (*cLi)->getDataSinkId()==clientId) { (*cLi)->playOutput(0.0); lockDataSink.release(); return true; } cLi++; } lockDataSink.release(); return false; };

void DataChannel::visualizeCaching (   )

renders the result of the global Adaptor stream to the screen. Creates internally a DataSink with ID 0. Use this id to control the visualizing DataSinkDefinition at line 685 of file DataChannel.cpp. References AdaptorChain::addAdaptor(), channelOpen, UncompressedVideoFrame::ColorSpace, ESInfo::isVisualStream(), localViewer, VMutex::lock(), lockDataSink, VMutex::release(), and Adaptor::setESInfo(). Referenced by ContainerDemux::createDataChannel(). { lockDataSink.lock(); if (channelOpen && es->isVisualStream()) { if(!this->localViewer) { char *tmp2 = new char[12]; strcpy(tmp2, "127.0.0.1"); AdaptorChain *chain = new VideoAdaptorChain(); chain->setESInfo((ESInfo*)es); #if defined (BUILD_ARCH_INTEL) || defined (WIN32) //assuming display with 24 or 32 bit (4byte) depth // YV12 is super-fast with Visualizer::SDL! UncompressedVideoFrame::ColorSpace cs = UncompressedVideoFrame::ColorSpaceYV12; // UncompressedVideoFrame::ColorSpace cs = UncompressedVideoFrame::ColorSpaceRGB32; // UncompressedVideoFrame::ColorSpace cs = UncompressedVideoFrame::ColorSpaceGRAY8; // UncompressedVideoFrame::ColorSpace cs = UncompressedVideoFrame::ColorSpaceRGB565; #elif BUILD_ARCH_ARM //iPAQ only has 16 bit display! UncompressedVideoFrame::ColorSpace cs = UncompressedVideoFrame::ColorSpaceRGB565; #endif chain->addAdaptor(new MP4Decoder((VideoESInfo*)es, false, cs, MP4Decoder::FFMPEG)); //chain->addAdaptor(new FrameRotate((VideoESInfo*)es, 90)); //add after decoder //chain->addAdaptor(new Visualizer((VideoESInfo*)es, Visualizer::X11, cs)); chain->addAdaptor(new Visualizer((VideoESInfo*)es, Visualizer::SDL, cs)); this->localViewer = new DataSink(1,new DevNull(), tmp2, 0, chain); delete tmp2; } } lockDataSink.release(); };

---

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

• DataChannel.hpp
• DataChannel.cpp

© ViTooKi 2003 :: [Lite version] Created with Doxygen