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

Info

Last update:
12 Feb 2007

Documentation

Doxygen LXR

SemiProxySession Class Reference

This class is used to handle a single rtsp-session. More...

#include <SemiProxySession.hpp>

Inheritance diagram for SemiProxySession:

List of all members.

Public Member Functions
	SemiProxySession (int fdclient, struct sockaddr_in *clientsock, SemiProxy *sp)
	default constructor
	~SemiProxySession ()
	default destructor
void	run ()
	Reads messages from client and server until the end of this session.
void	parseResponseFromServer (char *buffer, int len)
	This function parses the response from the server.
void	forwardToServer (char *buffer, int len)
	This function forwards a message to the server.
void	forwardToClient (char *buffer, int len)
	Forwards a message to the client.
void	handleOptionsResponse (string &buf, int &bytesRead)
	Handles the OPTIONS-response from the server.
void	handleDescribeResponse (string &buf, int &bytesRead)
	Handles the DESCRIBE-response from the server.
void	handleSetupResponse (string &buf, int &bytesRead)
	Handles the SETUP-response from the server.
void	handlePlayResponse (string &buf, int &bytesRead)
	Handles the PLAY-response from the server.
void	handlePauseResponse (string &buf, int &bytesRead)
	Handles the PAUSE-response from the server.
void	handleTeardownResponse (string &buf, int &bytesRead)
	Handles the TEARDOWN-response from the server.
bool	getOptions (const Url *fileName, const char *remaining)
	Handles a GET_PARAMETER message, sent from the client.
bool	setOptions (const Url *fileName, const char *remaining)
	Handles a SET_PARAMETER message, sent from the client.
bool	options (const Url *fileName, const char *remaining)
	Parses a OPTIONS message and forwards it to the server.
bool	connect (const Url *fileName, const char *remaining)
	Parses a DESCRIBE message and forwards it to the server.
bool	setup (const Url *fileName, const char *remaining)
	Parses a SETUP message and forwards it to the server.
bool	play (const Url *fileName, const char *remaining)
	Parses a PLAY message and forwards it to the server.
bool	pause (const Url *fileName, const char *remaining)
	Handles a PAUSE message, sent from the client.
bool	tearDown (int sessionKey, bool immediate=false, const Url *fileName=NULL, const char *remaining=NULL)
	Handles a TEARDOWN message, sent from the client.
bool	containsSessionID (uint SessionID)
	Look if specified SessionID is contained in any track of this session.
uint	getServerTimeMs ()
	Retrieve current 'client playout time' of this session from server.
uint	getClientTimeMs ()
	Retrieve current 'client playout time' of this session from client.
void	testClientOptions ()
uint	requestServerTimeMs ()
	Initiate request of current 'client playout time' of this session on next main-loop run from the serrver.
uint	requestClientTimeMs ()
	Initiate request of current 'client playout time' of this session on next main-loop run from the client.
void	sendTeardownToClient ()
	Send a Rtsp-TEARDOWN to the client.
void	closeSession ()
	Close the current session (by closing the socket to client and server) Furthermore, the SSession object is marked as 'closed'.
void	removeSession ()
	Close the current session (by closing the socket to client and server) Furthermore, the SSession object is removed from the sessionlist.
void	setUrl (const Url *uri, bool makeExactMatch=true)
	Empty method which is created for conformance to Session.cpp.
void	setStateClosed ()
	Set the session state.
PlayerInformation	getPlayerInfo ()
Static Public Member Functions
SemiProxySession *	getSemiProxySession (uint RtspSessionId)
	Return the reference to a particular session from the static vector of this class.

---

Detailed Description

This class is used to handle a single rtsp-session.

It contains the most functionality of the semiproxy application.

Author:

Klaus Schoeffmann

Definition at line 97 of file SemiProxySession.hpp.

---

Member Function Documentation

void SemiProxySession::forwardToClient (  char *  buffer, int  len )

Forwards a message to the client. Also replaces the CSeq value, set by the server to the stored CSeq value received from the client! Definition at line 588 of file SemiProxySession.cpp. References getClientTimeMs(), URIParameters::getFullURI(), URIParameters::getHost(), getPlayerInfo(), URIParameters::getPort(), getSemiProxySession(), semifunc::replaceStr(), TimeMeasurement::setTSclientPlayout(), SemiProxy::shouldRequestClientPosition(), and TimeMeasurement::startTS(). Referenced by handleDescribeResponse(), handleOptionsResponse(), handlePauseResponse(), handlePlayResponse(), handleSetupResponse(), and handleTeardownResponse(). { Globals::sdebug << "\n::forwardToClient(): starts"; if (buffer == NULL) { Globals::sdebug << "\n::forwardToClient(): detected buffer=NULL!!!"; } else { //first store CSeq received from server extractCSeq(buffer, lastServerCSeq); Globals::sdebug << "\n::forwardToClient(): lastServerCSeq=" << lastServerCSeq; string str(buffer); //if the client uses a host/port parameter (because it doesn't support a proxy), //replace the content-base to the original filename if ((params.getFullURI() != NULL) && ((params.getHost() != NULL) || (params.getPort() != 0)) ) { uint cbstart = str.find("Content-Base: "); if (cbstart != string::npos) { uint cbend = str.find("\r\n", cbstart); std::ostringstream newContentBase; newContentBase << "Content-Base: " << params.getFullURI(); semifunc::replaceStr(str, cbstart, cbend, (char*)newContentBase.str().c_str()); } } //replace CSeq value replaceCSeq(str, lastClientCSeq); //debugging output string tmpstr (str); semifunc::replaceStr(tmpstr, "\r\n", "\r \n\t", true); Globals::sdebug << "\n::forwardToClient(): Forwarding to CLIENT:\n" << tmpstr; send(this->fdclient, str.c_str(), str.length(), 0); //if last client message was PLAY, start time-measurement for current time-section //but only for the _first_ PLAY message (session-state not ACTIVE) if (this->lastClientRtspMsg == RTSP_PLAY && state != SESSION_ACTIVE) { Globals::sdebug << "\n::forwardToClient(): _time measurement started_"; timemsmnt->startTS(); } else { Globals::sdebug << "\n::forwardToClient(): _time measureemnt not started (" << lastClientRtspMsg << "==" << RTSP_PLAY << ", " << state << "!=" << SESSION_ACTIVE << ")"; } //request current media time from media player //but only for the _first_ PAUSE message (if there are more than on track) if (this->lastClientRtspMsg == RTSP_PAUSE && sp->shouldRequestClientPosition() && state != SESSION_PAUSED && SemiProxySession::getSemiProxySession(this->RtspSessionID)->getPlayerInfo() != PI_PVPLAYER) { ulong cplayout = SemiProxySession::getSemiProxySession(this->RtspSessionID)->getClientTimeMs(); timemsmnt->setTSclientPlayout(cplayout); } Globals::sdebug << "\n::forwardToClient(): success"; } }

void SemiProxySession::forwardToServer (  char *  buffer, int  len )

This function forwards a message to the server. It also looks for parameters specified in the RTSP-URI and removes it. If message-type is DESCRIBE and a profile-ID was specified, also the TerminalCapabilites (of the specified profile) will be added. Furthermore, this function stores the received CSeq value from the client. Definition at line 482 of file SemiProxySession.cpp. References URIParameters::getHost(), URIParameters::getPort(), ProfileList::getProfileById(), URIParameters::getProfileId(), SemiProxy::getProfileList(), and SemiProxy::shouldAddTermCaps(). Referenced by connect(), getOptions(), options(), pause(), play(), setOptions(), setup(), and tearDown(). { Globals::sdebug << "\n::forwardToServer(): starts"; if (buffer == NULL) { Globals::sdebug << "\n::forwardToServer(): detected buffer=NULL!!!"; } else { //first store CSeq received from client Globals::sdebug << "\n::forwardToServer(): before call to extractCSeq()"; extractCSeq(buffer, lastClientCSeq); Globals::sdebug << "\n::forwardToServer(): lastClientCSeq=" << lastClientCSeq; //additional newlines, needed for pvplayer string strbuf(buffer); if (params.getPort() > 0 || params.getHost() != NULL) { strbuf.append("\r\n\r\n"); } //add/change terminal capabilites? if (sp->shouldAddTermCaps()) { //check terminal capabilities (only if profile specified) if (lastClientRtspMsg == RTSP_DESCRIBE && params.getProfileId() != 0) { uint tcBegin, tcEnd; Profile *profile = sp->getProfileList()->getProfileById(params.getProfileId()); assert(profile != NULL); string termCaps = createTerminalCapabilities(profile); tcBegin = strbuf.find("<xml "); tcEnd = strbuf.find("</DIDL>"); if (strbuf.find("Content-Type: application/mpeg21_dia") != string::npos && tcBegin != string::npos && tcEnd != string::npos) { //termcaps found strbuf.replace(tcBegin, (tcEnd + 7) - tcBegin, termCaps); uint currentLength = getContentLength(strbuf); currentLength -= (tcEnd + 7) - tcBegin; currentLength += termCaps.length(); //correct content-length changeContentLength(strbuf, currentLength); } else { noTermCapsFound = true; Globals::sdebug << "\n::forwardToServer(): No Terminalcapabilities found... will add!"; if (strbuf.find("Content-Length:") != string::npos) { cerr << "\n::forwardToServer(): cannot handle existing DESCRIBE content!" << endl; } else { ostringstream ctinfo, content; ctinfo << "Content-Type: application/mpeg21_dia\r\n" << "Content-Length: " << termCaps.length() << "\r\n\r\n" << termCaps << "\r\n"; uint uapos1, uapos2; if ((uapos1 = strbuf.find("User-Agent:")) != string::npos) { uapos2 = strbuf.find("\r\n", uapos1); strbuf.insert(uapos2+2, ctinfo.str()); //append tercaps to end strbuf.insert(strbuf.rend()-strbuf.rbegin(), content.str()); } else { cerr << "\n::forwardToServer(): User-Agent not found in message!" << endl; } } } } } //replace CSeq value replaceCSeq(strbuf, lastServerCSeq+1); //debugging output string tmpstr(strbuf); Globals::sdebug << "\n::forwardToServer(): Forwarding to SERVER:\n" << tmpstr; send(this->fdserver, strbuf.c_str(), strbuf.length(), 0); Globals::sdebug << "\n::forwardToServer(): success"; } }

void SemiProxySession::parseResponseFromServer (  char *  buffer, int  len )

This function parses the response from the server. Depending on this response, this function either creates a new SSession (on successful response to a play-message) sets the SSession to state 'active' again (when the response was the ok for a subsequent play-message) Definition at line 794 of file SemiProxySession.cpp. References URIParameters::getMovieId(), URIParameters::getProfileId(), URIParameters::getUserId(), handleDescribeResponse(), handleOptionsResponse(), handlePauseResponse(), handlePlayResponse(), handleSetupResponse(), and handleTeardownResponse(). Referenced by run(). { assert(buffer); Globals::sdebug << "\n::parseResponseFromServer(): starts"; //only parse response, if all necessary params were passed from the client if (params.getMovieId() != NULL && params.getUserId() != 0 && params.getProfileId() != 0) { string buf (buffer); //look if RTSP 200 OK is contained in the message if (buf.find("200") != string::npos && buf.find("OK") != string::npos) { switch(lastClientRtspMsg) { case RTSP_OPTIONS: handleOptionsResponse(buf, len); break; case RTSP_DESCRIBE: handleDescribeResponse(buf, len); break; case RTSP_SETUP: handleSetupResponse(buf, len); break; case RTSP_PLAY: handlePlayResponse(buf, len); break; case RTSP_PAUSE: handlePauseResponse(buf, len); break; case RTSP_TEARDOWN: handleTeardownResponse(buf, len); break; } } } else { Globals::sdebug << "\n::parseResponseFromServer(): IGNORED (not all params found!)"; cerr << "\n::parseResponseFromServer(): IGNORED (not all params found!)"; } Globals::sdebug << "\n::parseResponseFromServer(): ends"; }

bool SemiProxySession::play (  const Url *  fileName, const char *  remaining )  [virtual]

Parses a PLAY message and forwards it to the server. If the URI of this message contains an existing RTSP-Session-ID (which means, this session should take over the other session), the Range- Parameter of this message will be replaced by the current time of the other session. This function also extracts the RTSP-SessionId of the message. Implements Session. Definition at line 948 of file SemiProxySession.cpp. References TimeMeasurement::addNewSection(), RTSP::extractSessionKeyFromCMD(), forwardToServer(), Profile::getBufferingDelayms(), SSession::getElapsedMsecs(), getPlayerInfo(), SSession::getPreviousSessionDuration(), ProfileList::getProfileById(), URIParameters::getProfileId(), SemiProxy::getProfileList(), URIParameters::getRange(), URIParameters::getSection(), getSemiProxySession(), SemiProxy::getSession(), URIParameters::getSessionId(), SSession::getState(), URIParameters::getSubtractSecs(), TrackList::getTCHavingState(), requestClientTimeMs(), requestServerTimeMs(), TimeMeasurement::setTSrequestedFrom(), SemiProxy::shouldRequestClientPosition(), SemiProxy::shouldRequestServerPosition(), and Url::toString(). { assert(remaining); assert(fileName); Globals::sdebug << "\n::play(): starts"; lastClientRtspMsg = RTSP_PLAY; string strbuf (buffer); //extract prebuffer-time ulong prebuffer = extractPrebuffer(strbuf); if (prebuffer == 0 && params.getProfileId() != 0) { //if no prebuffer-time was specified by the player, use prebuffer-time from profile prebuffer = sp->getProfileList()->getProfileById(params.getProfileId())->getBufferingDelayms(); } Globals::sdebug << "\n::play(): prebuffer=" << prebuffer; //on known protocol: extract RTSP-SessionId and URI if (prot) { lastCRtspSessionID = prot->extractSessionKeyFromCMD(remaining); //extract sessionID and URI only for first track if (tracks.getTCHavingState(TRACK_ACTIVE) == 0) { RtspSessionID = lastCRtspSessionID;//prot->extractSessionKeyFromCMD(remaining); SessionURI = new char[strlen(fileName->toString())+1]; strcpy(SessionURI, fileName->toString()); } } else { Globals::sdebug << "\n::play(): prot IS NULL !!!"; } //for consecutive play (resumes): //if this session is a migrated session, add elapsed time of //original session to the range, requested by the client //(otherwise, some players would start from wrong position) if (sessionHasBeenPaused) { Globals::sdebug << "\n::play(): consecutive play"; if (asess->getPreviousSessionDuration() != 0) { Globals::sdebug << "\n::play(): prevDur= " << asess->getPreviousSessionDuration(); replaceRange(strbuf, semifunc::convertToString(extractRangeFrom(strbuf)+asess->getPreviousSessionDuration())); } } if (state != SESSION_ACTIVE && tracks.getTCHavingState(TRACK_ACTIVE) == 0) { assert(timemsmnt != NULL); //create new time-section on time-measurement timemsmnt->addNewSection(prebuffer); //set requested range-from value timemsmnt->setTSrequestedFrom(extractRangeFrom(strbuf)); } //check if this session should take over another session //do not migrate a migrated session again (which is only paused and resumed!) //moreover, do not migrate a session if the PLAY message for the second track was received if (params.getSessionId() != 0 && tracks.getTCHavingState(TRACK_ACTIVE) == 0) { //session, which should be taken over must exist! SSession *otherSession = sp->getSession(params.getSessionId()); if (otherSession != NULL) { //get time OF OTHER SESSION ulong splayout = 0, cplayout = 0; //should request mediatime from client? Globals::sdebug << "\n::play() requesting position from client?"; if (sp->shouldRequestClientPosition() && otherSession && otherSession->getState() != STATE_CLOSED && SemiProxySession::getSemiProxySession(params.getSessionId())->getPlayerInfo() != PI_PVPLAYER) { //get client-playout time for other session from server assert(SemiProxySession::getSemiProxySession(params.getSessionId()) != NULL); cplayout = SemiProxySession::getSemiProxySession(params.getSessionId())->requestClientTimeMs(); Globals::sdebug << "\n::play(" << RtspSessionID << "): client playout of other session= " << cplayout; } if (cplayout == 0) { Globals::sdebug << "\n::play(): NO REQUEST FROM CLIENT, try server"; //should request mediatime from server? if (sp->shouldRequestServerPosition() && otherSession && otherSession->getState() != STATE_CLOSED) { //get client-playout time for other session from server assert(SemiProxySession::getSemiProxySession(params.getSessionId()) != NULL); splayout = SemiProxySession::getSemiProxySession(params.getSessionId())->requestServerTimeMs(); Globals::sdebug << "\n::play(" << RtspSessionID << "): server playout of other session= " << splayout; } else { Globals::sdebug << "\n::play(): NO REQUEST FROM SERVER, use own estimation"; } } //calculate position (correct value from server or user own estimation) ulong msecsOS = sp->getSession(params.getSessionId())->getElapsedMsecs(params.getSection(), splayout, cplayout); Globals::sdebug << "\n::play(): msecs of other session= " << msecsOS; //add/subtract the specified number of seconds (if specified) if (msecsOS >= (uint)(params.getSubtractSecs() * 1000)) { msecsOS -= params.getSubtractSecs() * 1000; } Globals::sdebug << "\n::play(): msecs of other session after subtract(" << params.getSubtractSecs() * 1000 << ") = " << msecsOS; //store time of old session in variable 'elapsedTimeMsecs' for NEW SESSION //(will be used on creation of SSession) //prevDuration = msecsOS + startupOffset; prevDuration = msecsOS; //convert time to string and replace range-parameter in the message replaceRange(strbuf, semifunc::convertToString(msecsOS)); } } else if (params.getSessionId() != 0) { replaceRange(strbuf, semifunc::convertToString(prevDuration)); } //check if an explicit range parameter were specified if (params.getRange() != NULL) { //if so, replace the previous range replaceRange(strbuf, params.getRange(), false); } forwardToServer((char*)strbuf.c_str(), strbuf.length()); return true; }

void SemiProxySession::run (   )  [virtual]

Reads messages from client and server until the end of this session. The messages will be parsed and forwarded to the opponent. Implements VThread. Definition at line 1630 of file SemiProxySession.cpp. References RTSP::applyReqToSession(), closeSession(), Session::determineProtocol(), getClientTimeMs(), Protocol::getID(), getServerTimeMs(), parseResponseFromServer(), removeSession(), URIParameters::setAction(), URIParameters::setFullURI(), URIParameters::setHost(), URIParameters::setMovieId(), URIParameters::setPort(), URIParameters::setProfileId(), URIParameters::setRange(), URIParameters::setSection(), URIParameters::setSessionId(), URIParameters::setSubtractSecs(), URIParameters::setUserId(), TimeMeasurement::stopTS(), and tearDown(). { fd_set rfds; struct timeval tv; //number of microseconds to sleep after a loop run ulong sleep_msecs = PROXY_SLEEP_USECS; int bytesReadClient = -1; int bytesReadServer = -1; //pointer to begin of buffer char *bufferstart = buffer; while (state!=SESSION_ERR && state!=SESSION_CLOSED) { //first check if socket has closed if (fdclient == 0) { Globals::sdebug << "\n::run(): Client has closed socket -> CLOSE SESSION"; closeSession(); break; } //(maximum) waiting time for select tv.tv_sec = 0; tv.tv_usec = 10000; FD_ZERO(&rfds); //only add client or server to FD_LIST, when socket has not been closed! if (bytesReadClient != 0) FD_SET(fdclient, &rfds); if (bytesReadServer != 0) FD_SET(fdserver, &rfds); //use bigger socket-number for select int maxsocknr = (fdclient < fdserver) ? fdserver : fdclient; int retval = select(maxsocknr+1, &rfds, NULL, NULL, &tv); if (retval == -1) { cerr << "\nSPS::run(): ERROR select()" << endl; } else if (retval) { //************************READ FROM CLIENT start************************* if (FD_ISSET(fdclient, &rfds)) { sessionControlChannel = fdclient; buffer = bufferstart; memset(buffer, 0, MSG_BUFFER_SIZE); //read until no more bytes (because of MTU) readFromSocket(fdclient, tv, rfds); bytesReadClient = bytesRead; //**readRequest does not correctly work with other players !!!** //bytesReadClient = bytesRead = readRequest(buffer, MSG_BUFFER_SIZE); //on PAUSE stop time-measurement if (strstr(buffer, "PAUSE rtsp://") != NULL) { //stop time-measurement for current time-section timemsmnt->stopTS(); } //special handling for quicktime embedded //(TODO:CAN BE REMOVED, IF applyReqToSession can handle several callbacks) char *teardownstart; if (strncmp(buffer, "PAUSE", 5) == 0 && (teardownstart = strstr(buffer, "TEARDOWN")) != NULL) { //remove pause bytesReadClient = bytesRead = bytesRead - (teardownstart - buffer); buffer = teardownstart; } char *playstart; if (strncmp(buffer, "SET_PARAMETER", 13) == 0 && (playstart = strstr(buffer, "PLAY")) != NULL) { bytesReadClient = bytesRead = bytesRead - (playstart - buffer); //remove set_parameter buffer = playstart; } //on DESCRIBE extract full-URI if (strstr(buffer, "DESCRIBE rtsp://") != NULL) { char *fnstart, *fnend; if ((fnstart = strstr(buffer, "rtsp://")) != NULL) { if ((fnend = strstr(fnstart, " ")) != NULL) { params.setFullURI(semifunc::newStrCpy(fnstart, fnend-fnstart)); } } } //new extract (and remove!) ALL PARAMETERS string bufferstr (buffer); //look for parameters in the URI and remove them char *pmovieid, *prange, *phost; int puid, pproid, psid, pport, action, section, subtractMsecs; if ((puid = extractParameter(bufferstr, "/uid=", true)) >= 0) { params.setUserId(puid); } if ((pproid = extractParameter(bufferstr, "/proid=", true)) >= 0) { params.setProfileId(pproid); } if ((pmovieid = extractStrParameter(bufferstr, "/id=", true)) != NULL) { params.setMovieId(pmovieid); } if ((psid = extractParameter(bufferstr, "/sid=", true)) >= 0) { params.setSessionId(psid); } if ((action = extractParameter(bufferstr, "/action=", true)) >= 0) { params.setAction(action); } if ((section = extractParameter(bufferstr, "/section=", true)) >= 0) { params.setSection(section); } if ((subtractMsecs = extractParameter(bufferstr, "/sub=", true)) >= 0) { params.setSubtractSecs(subtractMsecs); } //special parameters (if no RTSP proxy can be used!) if ((prange =extractStrParameter(bufferstr, "/range=",true)) != NULL) { params.setRange(prange); } if ((phost = extractStrParameter(bufferstr, "/host=", true)) != NULL) { params.setHost(phost); } if ((pport = extractParameter(bufferstr, "/port=", true)) >= 0) { params.setPort(pport); } //store back buffer (with params removed) buffer = bufferstart; memset(buffer, 0, MSG_BUFFER_SIZE); bufferstr.copy(buffer, bufferstr.length()); //buffer = (char*)bufferstr.c_str(); //check hostname and port (cannot be same as host+port of proxy) //NOTE: this function may change the address and port of the request!!! if (checkForValidAddress(buffer, bytesRead)) { Globals::sdebug << "\nSP::run(): received from client:\n\t" << buffer; if (bytesRead == 0) { //no data read; the other side has closed the connection, teardown all tearDown(TEARDOWN_ALL,true, NULL, NULL); } else if (bytesRead < 0) { cerr << "\nSPS::run(): Error reading from controlchannel" << endl; tearDown(TEARDOWN_ALL,true,NULL, NULL); state = SESSION_ERR; } else { // we have got a command from the client; parse it and forward it to the server //determine protocol of message if (!prot) { if ( determineProtocol(buffer) == PROTO_UNKNOWN) { cerr << "\nSPS::run(): Unknown protocol: " << buffer << endl; } } //if known protocol was recognized, perform further parsing... if (prot) { switch (prot->getID()) { case PROTO_RTSP: if (bytesRead >= MSG_BUFFER_SIZE) { cerr << "\nSPS::run(): received command exceeded buffer size" << endl; break; } break; default: cerr << "\nSPS::run(): Unknown protocol: " << buffer << endl; break; } //call control-function in RTSP-object; this function will callback other functions //in this object like connect(), setup(), play(), pause(), teardown()... if (!prot->applyReqToSession(buffer, bytesRead, this, true)) { cerr << "\nSPS::run(): Failed to parse request '" << buffer << "'" << endl; } } } } } //************************read from client end************************* //************************READ FROM SERVER start************************* if (FD_ISSET(fdserver, &rfds)) { sessionControlChannel = fdserver; buffer = bufferstart; memset(buffer, 0, MSG_BUFFER_SIZE); //use common receive-function, because readRequest do not //work sometimes (doesn't call options/setup/... functions) //read until no more bytes (because of MTU) readFromSocket(fdserver, tv, rfds); bytesReadServer = bytesRead; //bytesReadServer = bytesRead = recv(fdserver, buffer, MSG_BUFFER_SIZE, 0); //bytesReadServer = bytesRead = readRequest(buffer, MSG_BUFFER_SIZE); Globals::sdebug << "\nSP::run(): received from server (" << bytesReadServer << " bytes):\n\t" << buffer; if (bytesRead == 0) { //no data read; the server has closed the connection, teardown all cerr << "\nSPS::run(): No data read from ControlChannel (SERVER has closed connection)" << endl; removeSession(); } else if (bytesRead < 0) { cerr << "\nSPS::run(): Error reading from controlchannel" << endl; removeSession(); } else { // we got a command from the server; parse it and forward to client parseResponseFromServer(buffer, bytesRead); } } //************************read from server end************************* } //look if there is an outstanding position-request //this special handling is necessary, because otherwise (if another session directly //calls 'getServerTimeMs()') the response could be received in this main-loop as //instead of the recv() of 'getServerTimeMs()'. This is because concurrent execution if (state != SESSION_ERR && state != SESSION_CLOSED) { if (sendServerPositionRequest == true) { Globals::sdebug << "\n::run(" << RtspSessionID << "): outstanding server position request - STARTS"; receivedServerPosition = this->getServerTimeMs(); sendServerPositionRequest = false; Globals::sdebug << "\n::run(" << RtspSessionID << "): outstanding server position request - DONE"; } else if (sendClientPositionRequest == true) { Globals::sdebug << "\n::run(" << RtspSessionID << "): outstanding client position request - STARTS"; receivedClientPosition = this->getClientTimeMs(); sendClientPositionRequest = false; Globals::sdebug << "\n::run(" << RtspSessionID << "): outstanding client position request - DONE"; } #ifndef WIN32 usleep(sleep_msecs); #else Sleep(sleep_msecs); #endif } } Globals::sdebug << "::run() closing SemiProxySession " << RtspSessionID << "\n"; }

bool SemiProxySession::setup (  const Url *  fileName, const char *  remaining )  [virtual]

Parses a SETUP message and forwards it to the server. Also inserts a destination parameter, which is set to the address of the client that sent this message, into the the message. Implements Session. Definition at line 901 of file SemiProxySession.cpp. References TrackList::addTrack(), forwardToServer(), and SemiProxy::shouldAddDestination(). { assert(remaining); assert(fileName); Globals::sdebug << "\n::setup(): starts"; lastClientRtspMsg = RTSP_SETUP; string strbuf (buffer); //change destination-parameter? if (sp->shouldAddDestination()) { uint cpstart; if ((cpstart = strbuf.find("unicast")) != string::npos) { ostringstream strdest; strdest << "destination=" << inet_ntoa(clientsock->sin_addr) << ";"; //if there is already an existing destination, replace it, //otherwise insert it into the string uint deststart, destend; if ((deststart = strbuf.find("destination=")) != string::npos) { destend = getSmallerStringPos(strbuf, "\r\n", ";"); strbuf.replace(strbuf.begin()+deststart, strbuf.begin()+destend-1, strdest.str()); } else { strbuf.insert(cpstart, strdest.str()); } } } //store track in tracklist uint tstart = strbuf.find("/trackID="); if (tstart != string::npos) { uint tend = strbuf.find(" ", tstart); uint trackNr = atoi(strbuf.substr(tstart+strlen("/trackID="), tend-(tstart+strlen("/trackID="))).c_str()); tracks.addTrack(trackNr); } forwardToServer((char*)strbuf.c_str(), strbuf.length()); return true; }

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

Empty method which is created for conformance to Session.cpp. Parameters: uri  makeExactMatch  Implements Session. Definition at line 1173 of file SemiProxySession.cpp. {}

---

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

• SemiProxySession.hpp
• SemiProxySession.cpp

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