plugins/rtsp_streamer/rtsp.cpp

87 	HaikuRTSPClient* client = (HaikuRTSPClient*) rtspClient;
102 		client->session = MediaSession::createNew(env, sdpDescription);
104 		if (client->session == NULL) {
111 		} else if (!client->session->hasSubsessions()) {
123 		client->iter = new MediaSubsessionIterator(*client->session);
136 	HaikuRTSPClient* client = (HaikuRTSPClient*) rtspClient;
138 	client->subsession = client->iter->next();
139 	if (client->subsession != NULL) {
140 		if (!client->subsession->initiate()) {
143 				<< *client->subsession << "\" subsession: "
151 				<< *client->subsession << "\" subsession (";
153 			if (client->subsession->rtcpIsMuxed()) {
154 				env << "client port " << client->subsession->clientPortNum();
156 				env << "client ports " << client->subsession->clientPortNum()
157 					<< "-" << client->subsession->clientPortNum() + 1;
163 			rtspClient->sendSetupCommand(*client->subsession,
171 	if (client->session->absStartTime() != NULL) {
174 		rtspClient->sendPlayCommand(*client->session, continueAfterPLAY,
175 			client->session->absStartTime(), client->session->absEndTime());
177 		client->duration = client->session->playEndTime()
178 			- client->session->playStartTime();
179 		rtspClient->sendPlayCommand(*client->session, continueAfterPLAY);
189 		HaikuRTSPClient* client = (HaikuRTSPClient*) rtspClient;
193 				<< *client->subsession << "\" subsession: "
199 			<< *client->subsession << "\" subsession (";
200 		if (client->subsession->rtcpIsMuxed()) {
201 			env << "client port " << client->subsession->clientPortNum();
203 			env << "client ports " << client->subsession->clientPortNum()
204 				<< "-" << client->subsession->clientPortNum() + 1;
211 		// flow of data from the client won't start happening until later,
214 		client->subsession->sink = AdapterSink::createNew(env, *client->subsession,
217 		if (client->subsession->sink == NULL) {
219 				<< *client->subsession << "\" subsession: "
225 			<< *client->subsession << "\" subsession\n";
228 		client->subsession->miscPtr = rtspClient;
229 		client->subsession->sink
230 				->startPlaying(*(client->subsession->readSource()),
231 					subsessionAfterPlaying, client->subsession);
234 		if (client->subsession->rtcpInstance() != NULL) {
235 			client->subsession->rtcpInstance()->setByeHandler(
237 				client->subsession);
252 	HaikuRTSPClient* client = (HaikuRTSPClient*) rtspClient;
269 		if (client->duration > 0) {
273 			client->duration += delaySlop;
274 			unsigned uSecsToDelay = (unsigned)(client->duration * 1000000);
275 			client->streamTimerTask
281 		if (client->duration > 0) {
282 			env << " (for up to " << client->duration << " seconds)";
294 		client->NotifySucces();
316 	// All subsessions' streams have now been closed, so shutdown the client:
337 	HaikuRTSPClient* client = (HaikuRTSPClient*)clientData;
339 	client->streamTimerTask = NULL;
342 	shutdownStream(client);
349 	HaikuRTSPClient* client = (HaikuRTSPClient*) rtspClient;
352 	if (client->session != NULL) {
354 		MediaSubsessionIterator iter(*client->session);
376 			rtspClient->sendTeardownCommand(*client->session, NULL);
384 	client->NotifyError();