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

Info

Last update:
12 Feb 2007

Documentation

Doxygen LXR

ProxySession Class Reference

<class description="" goes="" here=""> <short description=""> More...

#include <ProxySession.hpp>

Inheritance diagram for ProxySession:

List of all members.

Public Member Functions
	ProxySession (int socket, const struct sockaddr_in *client, CacheManager *cm, AdmissionControl *adm, bool allowRTX, SessionCounter *counter=NULL, TerminalCapabilities *defTC=NULL)
	socket: the raw socket for initializing the session control channel.
bool	getOptions (const Url *fileName, const char *remaining)
bool	setOptions (const Url *fileName, const char *remaining)
bool	options (const Url *fileName, const char *remaining)
bool	connect (const Url *fileName, const char *remaining)
bool	setup (const Url *fileName, const char *remaining)
bool	play (const Url *fileName, const char *remaining)
bool	pause (const Url *fileName, const char *remaining)
bool	tearDown (int sessionKey, bool immediate=false, const Url *fileName=NULL, const char *remaining=NULL)
	teardowns the session specified with sessionKey (if no fileName and no reminaing is specified.
void	run ()
void	setUrl (const Url *uri, bool makeExactMatch=true)
	deep-copies uri, sets mp4Stream by asking the cacheManager
SessionState	getState () const
Protected Member Functions
int	readData (char *buffer, int numBytes)
	sets output at the client
Protected Attributes
ServerSession *	serverSession
std::map< u32, u32, struct intCompare >	sessionTranslator
CacheManager *	cm
char	buffer [MSG_BUFFER_SIZE+1]
char	bufferBackup [MSG_BUFFER_SIZE+1]
sockaddr_in *	server
bool	rtxEnabledToServer
bool	rtxEnabledToClient
bool	rtxEnabled
	does this proxysession support retransmissions
bool	delMp4Stream
	should the created mp4Stream object be deleted
char *	playerId
list< rtx_info * >	rtxInfoServer
bool	insertMp4StreamIntoCM
	is true, when the Mp4Stream Info object is newly created or updated and has to be inserted into the CacheManager
bool	dualMiss
	both, the original input stream and the adapted output stream, have to be inserted into the CacheManager
bool	dontCacheDualMiss
bool	noDescribeSeenYet
SessionCounter *	counter

---

Detailed Description

<class description="" goes="" here=""> <short description="">

Author:

Michael Kropfberger and Peter Schojer

Version:

Id

ProxySession.hpp,v 1.26 2006/01/20 15:37:54 mkropfbe Exp

Definition at line 135 of file ProxySession.hpp.

---

Constructor & Destructor Documentation

ProxySession::ProxySession (  int  socket, const struct sockaddr_in *  client, CacheManager *  cm, AdmissionControl *  adm, bool  allowRTX, SessionCounter *  counter = NULL, TerminalCapabilities *  defTC = NULL )

socket: the raw socket for initializing the session control channel. the client info is deep-copied Parameters: noRTX:  if this is set to true the proxy will not support rtx retransmissions and thus create SimpleRtp objects instead of Rtp objects hideMetaData:  never forward any meta-data Definition at line 93 of file ProxySession.cpp. References delMp4Stream, dualMiss, and insertMp4StreamIntoCM. :Session(), rtxEnabled(allowRTX),neverForwardMetaData(true) { assert(adm); dprintf_full("ProxySession::ProxySession\n"); prxStat.requests++; this->counter = counter; admControl=adm; state = SESSION_CLOSED; rtxEnabledToServer=false; rtxEnabledToClient=false; delMp4Stream=false; dualMiss=false; canAdmitRequest=true; dontCacheDualMiss=false; cm = c; if (clint) { client = new sockaddr_in(); memcpy(client, clint, sizeof(sockaddr_in)); clientId=(u32)client->sin_addr.s_addr; } else { client = NULL; clientId=0; } serverSession=NULL; server=NULL; sessionControlChannel=socket; prot = NULL; url = NULL; termCap=defTC; userPref=NULL; suggestedAdaptor=NULL; mp4Stream=NULL; playerId=NULL;serverID=NULL; insertMp4StreamIntoCM=false; noDescribeSeenYet=true; resUsage.cpu=resUsage.disk=resUsage.network=0.0; origSrc=NULL; mp4StreamReserved = 0; origSrcReserved = 0; }

---

Member Function Documentation

void ProxySession::setUrl (  const Url *  uri, bool  makeExactMatch = true )  [virtual]

deep-copies uri, sets mp4Stream by asking the cacheManager Parameters: makeExactMatch  decides on possible server-side transcoding Implements Session. Definition at line 1289 of file ProxySession.cpp. References ContainerInfo::clone(), ReferenceCounter::decrease(), delMp4Stream, CacheManager::findMetaObject(), MetaObject::findMp4Stream(), TerminalCapabilities::getColorDisplay(), TerminalCapabilities::getDisplayHeight(), TerminalCapabilities::getDisplayRefreshRate(), TerminalCapabilities::getDisplayWidth(), ContainerInfo::getFileSize(), ContainerInfo::getFirstVisualES(), TerminalCapabilities::getMaxDecoderBitRateInBit(), Adaptor::getName(), TerminalCapabilities::getNetworkCapacityInByte(), ContainerInfo::getUsageCounter(), CacheManager::getVideo(), insertMp4StreamIntoCM, CacheManager::lockCache(), CacheManager::reserveDiskSpace(), Adaptor::setESInfo(), Url::toString(), and CacheManager::unlockCache(). { bool insertResUsage=false; // problem: a 2nd describe arrives, don't allow that in the same session! if (cm && uri && !mp4Stream) { if (url) { delete url; } dprintf_full("ProxySession::setUrl: %s\r\n", uri->toString()); url = new Url(uri->toString()); cm->lockCache(); MetaObject* meta=cm->findMetaObject(url); bool exactMatch=false; if( (!termCap && !userPref)) { mp4Stream = cm->getVideo(url); // calc resUsage VideoESInfo* vis=NULL; if(mp4Stream) vis=mp4Stream->getFirstVisualES(); if(vis) { Feature src(vis); src.isCached=true; ResourceUsage* tmpRU=CostFunction::calcResourceUsage(&src,&src,admControl->getResourceLimit()); if(tmpRU) { resUsage.network=tmpRU->network; resUsage.disk=tmpRU->disk; resUsage.cpu=tmpRU->cpu; delete tmpRU; insertResUsage=true; } } insertMp4StreamIntoCM=false; dprintf_full("ProxySession::setUrl found video (no termcaps or userpref)\n"); } else if(meta && userPref) { // FIXME: hardcode delay values to 100ms dprintf_full("ProxySession::setUrl meta && userPref\n"); suggestedAdaptor=admControl->makeBestMatch(userPref,100,meta,&mp4Stream,&resUsage); dprintf_full("ProxySession::setUrl (N=%f,C=%f,D=%f)\n", resUsage.network,resUsage.cpu,resUsage.disk); if(mp4Stream && suggestedAdaptor && resUsage.network>=0.0000001 && strcmp(suggestedAdaptor->getName(),"Forwarder")!=0 && !strstr(suggestedAdaptor->getName(),"Temporal")){ // transcoding // a hit with transcoding! origSrc=mp4Stream; mp4Stream=mp4Stream->clone(); insertMp4StreamIntoCM=true; u64 durInMS=0; if(mp4Stream->getFirstVisualES()) durInMS=mp4Stream->getFirstVisualES()->getDurationInMs(); else if(mp4Stream->getFirstAudioES()) durInMS=mp4Stream->getFirstAudioES()->getDurationInMs(); u32 byteSize=0; if(userPref) { byteSize=userPref->bitrate.best/8*durInMS/1000; } assert (mp4StreamReserved == 0); if(cm->reserveDiskSpace(byteSize)) mp4StreamReserved+=byteSize; else { insertMp4StreamIntoCM=false; } prxStat.bytesHit+=mp4Stream->getFileSize(); prxStat.bytesRequested+=mp4Stream->getFileSize(); prxStat.objHits++; } else if(mp4Stream && resUsage.network>=0.0000001 ) { // never cache temporal transcoding or no transcoding origSrc=mp4Stream; insertMp4StreamIntoCM=false; mp4Stream=mp4Stream->clone(); this->delMp4Stream=true; prxStat.bytesHit+=mp4Stream->getFileSize(); prxStat.bytesRequested+=mp4Stream->getFileSize(); prxStat.objHits++; prxStat.qualHits++; } else if(mp4Stream) { // happens in MISS! prxStat.bytesRequested+=mp4Stream->getFileSize(); mp4Stream=NULL; } } else if(meta && termCap) { // bandwidth should be the minimum of network and decodeBandwidth // if one of them is zero, ignore the zero param u32 bandwidth=termCap->getNetworkCapacityInByte()*8; if(bandwidth==0) bandwidth=termCap->getMaxDecoderBitRateInBit(); else if(termCap->getMaxDecoderBitRateInBit() && termCap->getMaxDecoderBitRateInBit() < bandwidth) { bandwidth=termCap->getMaxDecoderBitRateInBit(); } mp4Stream=meta->findMp4Stream(0,termCap->getDisplayWidth(), 0,termCap->getDisplayHeight(), 0,bandwidth, (termCap->getColorDisplay()==0),(float)termCap->getDisplayRefreshRate() ,&exactMatch); if(makeExactMatch && !exactMatch) { // clone the mp4Stream origSrc=mp4Stream; mp4Stream=mp4Stream->clone(); mp4Stream->getUsageCounter()->increase(); insertMp4StreamIntoCM=true; suggestedAdaptor=admControl->makeExactMatch(termCap->getDisplayWidth(), termCap->getDisplayHeight(), bandwidth, (termCap->getColorDisplay()==0), (float)termCap->getDisplayRefreshRate(), mp4Stream,&resUsage); // check if we have a TemporalAdaptor, do not cache results of temporaladaptor if(strstr(suggestedAdaptor->getName(),"Temporal") || strcmp(suggestedAdaptor->getName(),"Forwarder")) { insertMp4StreamIntoCM=false; delMp4Stream=true; } prxStat.bytesHit+=mp4Stream->getFileSize(); prxStat.bytesRequested+=mp4Stream->getFileSize(); prxStat.objHits++; } else { // calc the resource usage for the non transcoding case origSrc=mp4Stream; mp4Stream=mp4Stream->clone(); mp4Stream->getUsageCounter()->increase(); insertMp4StreamIntoCM=false; delMp4Stream=true; if(mp4Stream) { VideoESInfo* vis=mp4Stream->getFirstVisualES(); if(vis) { Feature src(vis); src.isCached=true; ResourceUsage* tmpRU=CostFunction::calcResourceUsage(&src,&src,admControl->getResourceLimit()); if(tmpRU) { resUsage.network=tmpRU->network; resUsage.disk=tmpRU->disk; resUsage.cpu=tmpRU->cpu; delete tmpRU; insertResUsage=true; } } } } } cm->unlockCache(); } // now insert the resource usage for those other cases (all non-transcoding!) if(insertResUsage) { if(!admControl->insertRequest(&resUsage)) { resUsage.cpu=resUsage.disk=resUsage.network=0.0; prxStat.bytesRequested+=mp4Stream->getFileSize(); if(delMp4Stream) { mp4Stream->getUsageCounter()->decrease(); delete mp4Stream; mp4Stream=NULL; delMp4Stream=false; } if(origSrc) origSrc->getUsageCounter()->decrease(); origSrc=NULL; insertMp4StreamIntoCM=false; if(suggestedAdaptor) delete suggestedAdaptor; suggestedAdaptor=NULL; } else { prxStat.bytesHit+=mp4Stream->getFileSize(); prxStat.bytesRequested+=mp4Stream->getFileSize(); prxStat.objHits++; prxStat.qualHits++; } } if(!mp4Stream) prxStat.objMiss++; if(suggestedAdaptor && mp4Stream) suggestedAdaptor->setESInfo(mp4Stream->getFirstVisualES()); };

bool ProxySession::tearDown (  int  sessionKey, bool  immediate = false, const Url *  fileName = NULL, const char *  remaining = NULL )  [virtual]

teardowns the session specified with sessionKey (if no fileName and no reminaing is specified. Otherwise remaining will be parsed for the sessionkey, and the first param is ignored Implements Session. Definition at line 1124 of file ProxySession.cpp. References ReferenceCounter::decrease(), RTSP::generateOk(), RTSP::generateSessionNotFound(), RTSP::getBuffer(), ESInfo::getFrameStatistic(), ESInfo::getInput(), DataSink::getOutput(), BitField::getPercentageSetBits(), ESInfo::getUsageCounter(), RTSP::incSeqNr(), and ESInfo::setCompleteState(). { dprintf_full("ProxySession::tearDown(%i, %i)\r\n",sessionId,immediate); if(fileName && remaining) { sessionId=RTSP::extractSessionId(remaining); } // serverSession->tearDown(sessionId,immediate,fileName,remaining); if( ((u32)sessionId)==TEARDOWN_ALL) { // teardown all state = SESSION_CLOSED; list < DataChannel * >::iterator dcI; while (!channels.empty()) { dcI=channels.begin(); // pause the caching client (*dcI)->pause(0); DataSink* ds=(*dcI)->getDataSink(0); if(ds) { IO* dsOut=ds->getOutput(); if(dsOut) { ESInfo* es=(ESInfo*) (*dcI)->getESInfo(); float completeStatePercent=es->getFrameStatistic()->getPercentageSetBits(); //expensive if(completeStatePercent>0.75) { es->setCompleteState(true); dprintf_full("ProxySession::teardown: stream %s is complete with %f%%\r\n",es->getInput(),completeStatePercent); } dprintf_full("ProxySession::teardown: stream %s is cached with %f%%\r\n",es->getInput(),completeStatePercent); es->getUsageCounter()->decrease(); } } (*dcI)->teardown(clientId,immediate); // check if we have to delete it, might be shared with other sessions if((*dcI)->getNumberOfActiveDataSinks()==0) { (*dcI)->wait(); // wait for thread to finish delete (*dcI); // decrease RefCounter } channels.pop_front(); } // generate reply cmd prot->generateOk(); strcpy(buffer,prot->getBuffer()); prot->incSeqNr(); return true; } else { // teardown one session list < DataChannel * >::iterator dcI; if (!channels.empty()) { dcI = channels.begin(); while (dcI != channels.end()) { if ((*dcI)->getSessionId()== (unsigned)sessionId) { (*dcI)->pause(0); DataSink* ds=(*dcI)->getDataSink(0); if(ds) { IO* dsOut=ds->getOutput(); if(dsOut) { ESInfo* es=(ESInfo*) (*dcI)->getESInfo(); float completeStatePercent=es->getFrameStatistic()->getPercentageSetBits(); //expensive if(completeStatePercent>0.75) { es->setCompleteState(true); dprintf_full("ProxySession::teardown: stream %s is complete with %f%%\r\n",es->getInput(),completeStatePercent); } dprintf_full("ProxySession::teardown: stream %s is cached with %f%%\r\n",es->getInput(),completeStatePercent); es->getUsageCounter()->decrease(); } } (*dcI)->teardown(clientId,immediate); // check if we have to delete it, might be shared with other sessions if((*dcI)->getNumberOfActiveDataSinks()==0) { (*dcI)->wait(); // wait for thread to finish delete (*dcI); } channels.erase(dcI); if(channels.empty()) state = SESSION_CLOSED; prot->generateOk(); strcpy(buffer,prot->getBuffer()); prot->incSeqNr(); return true; } else { ++dcI; } } } } // session was not found prot->generateSessionNotFound(); dprintf_small("ProxySession::teardown: session %i not found\n",sessionId); strcpy(buffer,prot->getBuffer()); prot->incSeqNr(); return false; };

---

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

• ProxySession.hpp
• ProxySession.cpp

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