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

Info

Last update:
12 Feb 2007

Documentation

Doxygen LXR

ServerSession Class Reference

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

#include <ServerSession.hpp>

Inheritance diagram for ServerSession:

List of all members.

Public Member Functions
	ServerSession (int socket, const struct sockaddr_in *client, CacheManager *cm, AdmissionControl *am, bool enableRtx, SessionCounter *counter=NULL, TerminalCapabilities *tc=NULL)
	socket: the raw socket for initializing the session control channel.
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.
bool	getOptions (const Url *fileName, const char *remaining)
bool	setOptions (const Url *fileName, const char *remaining)
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
bool	startDCs (int sessionId, double startTime, double endTime, double prefetch, bool backwardsClosestIFrame)
Protected Attributes
char	buffer [MSG_BUFFER_SIZE]
	sets output at the client
CacheManager *	cm
char *	localAddress
char *	playerId
std::map< u32, std::map< char *, char *, struct stringCompare > *, struct intCompare >	params
	stores to an session id a map of params
AdmissionControl *	admControl
bool	enableRtx
SessionCounter *	counter

---

Detailed Description

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

Author:

Michael Kropfberger and Peter Schojer

Version:

Id

ServerSession.hpp,v 1.13 2006/01/20 15:37:54 mkropfbe Exp

Definition at line 86 of file ServerSession.hpp.

---

Constructor & Destructor Documentation

ServerSession::ServerSession (  int  socket, const struct sockaddr_in *  client, CacheManager *  cm, AdmissionControl *  am, bool  enableRtx, SessionCounter *  counter = NULL, TerminalCapabilities *  tc = NULL )

socket: the raw socket for initializing the session control channel. the client info is deep-copied Definition at line 70 of file ServerSession.cpp. :Session(),enableRtx(enableRTX) { assert(c); assert(am); this->counter = counter; termCap=tc; admControl=am; state = SESSION_CLOSED; 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; } sessionControlChannel=socket; sockaddr_in localaddr; canAdmitRequest=true; #ifdef WIN32 int slen = sizeof(localaddr); #else /* */ socklen_t slen = sizeof(localaddr); #endif /* */ memset(&localaddr, 0, sizeof(localaddr)); getsockname(socket, (sockaddr *) & localaddr, &slen); const char* tmp=inet_ntoa(localaddr.sin_addr); localAddress=new char[strlen(tmp)+1]; strcpy(localAddress,tmp); prot = NULL; url = NULL; userPref=NULL; suggestedAdaptor=NULL; // clientObj=NULL; mp4Stream=NULL; playerId=NULL; serverID=NULL; gtRefCount = new ReferenceCounter(); globalTimer = new GlobalTimer(); //this will prevent deletion on DataChannel closes: gtSharedAdapt = new SharedAdaptor(gtRefCount, (Adaptor*&)globalTimer); resUsage.cpu=resUsage.disk=resUsage.network=0.0; }

---

Member Function Documentation

void ServerSession::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 870 of file ServerSession.cpp. References ContainerInfo::clone(), CacheManager::findMetaObject(), MetaObject::findMp4Stream(), TerminalCapabilities::getColorDisplay(), TerminalCapabilities::getDisplayHeight(), TerminalCapabilities::getDisplayRefreshRate(), TerminalCapabilities::getDisplayWidth(), Url::getFileName(), ContainerInfo::getFirstVisualES(), TerminalCapabilities::getMaxDecoderBitRateInBit(), TerminalCapabilities::getNetworkCapacityInByte(), CacheManager::getVideo(), and Url::toString(). { bool insertResUsage=false; if (cm && uri) { if (url) { delete url; } dprintf_full("ServerSession::setUrl: %s \r\n", uri->toString()); //if (url->getFileName() == NULL) // dprintf_full("ServerSession::setUrl: file NULL!!!\n"); dprintf_full("ServerSession::setUrl: %s filename: %s\r\n", uri->toString(), uri->getFileName()); url = new Url(uri->toString()); bool exactMatch; MetaObject *meta = cm->findMetaObject(url); if (meta != NULL) { dprintf_full("ServerSession::setUrl metadata found\n"); } else { dprintf_full("ServerSession::setUrl metadata NOT found\n"); } dprintf_full("ServerSession::setUrl termcap: %p, userpref %p meta: %p\n", termCap, userPref, meta); if( (!termCap && !userPref)) { // just send ANY version dprintf_full("ServerSession::setUrl NO metaobject/metadata found!\n"); mp4Stream = cm->getVideo(url); if (mp4Stream == NULL) { fprintf(stderr,"\nERROR: demuxed stream not found or maybe you are starting the server from a different computer (hostname/IP) now? DELETE demux directory!\n"); //::exit(1); return; } mp4Stream=mp4Stream->clone(); // CM returns the orig video, we don't want it in server // calc resUsage VideoESInfo* vis=mp4Stream->getFirstVisualES(); if(vis) { dprintf_full("ServerSession::setUrl VIS found\n"); 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; } } } else if(meta && userPref) { // FIXME: hardcode delay values to 100ms dprintf_full("ServerSession::setUrl meta && userPref\n"); suggestedAdaptor=admControl->makeBestMatch(userPref,100,meta,&mp4Stream,&resUsage); if(mp4Stream) mp4Stream=mp4Stream->clone(); } else if(meta && termCap ) { //use MetaObject for best match // bandwidth should be the minimum of network and decodeBandwidth // if one of them is zero, ignore the zero param dprintf_full("ServerSession::setUrl meta && termCap\n"); u32 bandwidth=termCap->getNetworkCapacityInByte()*8; if(bandwidth==0) bandwidth=termCap->getMaxDecoderBitRateInBit(); else if(termCap->getMaxDecoderBitRateInBit() && termCap->getMaxDecoderBitRateInBit() < bandwidth) { bandwidth=termCap->getMaxDecoderBitRateInBit(); } dprintf_full("ServerSession::setUrl: termCap->getColorDisplay()=%u\r\n",termCap->getColorDisplay()); mp4Stream=meta->findMp4Stream(0,termCap->getDisplayWidth(), 0,termCap->getDisplayHeight(), 0,bandwidth, (termCap->getColorDisplay()==0), (float)termCap->getDisplayRefreshRate(), &exactMatch); if(mp4Stream) mp4Stream=mp4Stream->clone(); if(makeExactMatch && !exactMatch) { suggestedAdaptor=admControl->makeExactMatch(termCap->getDisplayWidth(), termCap->getDisplayHeight(), bandwidth, (termCap->getColorDisplay()==0), (float)termCap->getDisplayRefreshRate(), mp4Stream,&resUsage); } else { // calc the resource usage for the non transcoding case 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; } } } } } #ifndef WINCE else if(termCap && ((strcmp(uri->getFileName(), "v4l")) ==0)) { dprintf_full("ServerSession::setUrl v4l && termCap &&\n"); u32 bandwidth=termCap->getNetworkCapacityInByte()*8; if(bandwidth==0) bandwidth=termCap->getMaxDecoderBitRateInBit(); else if(termCap->getMaxDecoderBitRateInBit() && termCap->getMaxDecoderBitRateInBit() < bandwidth) { bandwidth=termCap->getMaxDecoderBitRateInBit(); } dprintf_full("ServerSession::setUrl: v4l termCap->getColorDisplay()=%u\r\n", termCap->getColorDisplay()); mp4Stream = Video4LinuxContainerFile::loadContainerInfo(); if(mp4Stream) { dprintf_full("ServerSession::setUrl: v4l mp4stream ok\n"); mp4Stream=mp4Stream->clone(); } else dprintf_full("ServerSession::setUrl: v4l mp4stream NULL!! \n"); if(makeExactMatch && !exactMatch) { suggestedAdaptor=admControl->makeExactMatch(termCap->getDisplayWidth(), termCap->getDisplayHeight(),bandwidth, (termCap->getColorDisplay()==0), (float)termCap->getDisplayRefreshRate(),mp4Stream,&resUsage); } dprintf_full("ServerSession::setUrl: v4l OK\r\n"); } #endif } // now insert the resource usage for those other cases if(insertResUsage) { if(!userPref && !admControl->insertRequest(&resUsage)) { resUsage.cpu=resUsage.disk=resUsage.network=0.0; if(mp4Stream) delete mp4Stream; mp4Stream=NULL; if(suggestedAdaptor) delete suggestedAdaptor; suggestedAdaptor=NULL; } } };

bool ServerSession::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 533 of file ServerSession.cpp. References buffer, RTSP::generateOk(), RTSP::generateSessionNotFound(), RTSP::getBuffer(), and RTSP::incSeqNr(). { dprintf_full("ServerSession::tearDown(%i, %i)\r\n",sessionId,immediate); if(fileName && remaining) { sessionId=RTSP::extractSessionId(remaining); } if((u32)sessionId==TEARDOWN_ALL) { // teardown all state = SESSION_CLOSED; list < DataChannel * >::iterator dcI; while (!channels.empty()) { dcI=channels.begin(); (*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.pop_front(); } if(prot) { // can happen that no prot is set when teardown called first prot->generateOk(); const char* buf=prot->getBuffer(); strcpy(buffer,buf); prot->incSeqNr(); return true; } else return false; } else { // teardown one session bool sesFound=false; list < DataChannel * >::iterator dcI; if (!channels.empty()) { dcI = channels.begin(); while (dcI != channels.end()) { if ((*dcI)->getSessionId()== (unsigned)sessionId) { sesFound=true; (*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); } dcI = channels.erase(dcI); if(channels.empty()) { state = SESSION_CLOSED; prot->generateOk(); const char* buf=prot->getBuffer(); strcpy(buffer,buf); prot->incSeqNr(); return true; } } else ++dcI; } } if(sesFound) { prot->generateOk(); } else { prot->generateSessionNotFound(); } const char* buf=prot->getBuffer(); strcpy(buffer,buf); prot->incSeqNr(); return sesFound; } prot->generateSessionNotFound(); const char* buf=prot->getBuffer(); strcpy(buffer,buf); prot->incSeqNr(); return false; };

---

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

• ServerSession.hpp
• ServerSession.cpp

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