[Live-devel] Streaming Relay
wissam.l at free.fr
wissam.l at free.fr
Fri Oct 7 16:14:54 PDT 2005
Hi Ross,
First of all, thank you for your answer.
> >I would like to create a unicast streaming relay called Relay that launches
> 2
> >threads
>
> No you don't. See <http://www.live555.com/liveMedia/faq.html#threads>
I removed all the threads in my program and I used an unique class called relay
where I defined the same UsageEnvironment and TaskScheduler for all my objects:
I defined a global variable:
FramedSource* fVideoSource;
In relay I do the following:
setupStreams();
iter.reset();
madeProgress = False;
while ((subsession = iter.next()) != NULL) {
if (subsession->readSource() == NULL) continue;
setVideoSource(subsession->readSource());
madeProgress = True;
break;
}
startPlayingStreams();
launchServer(getVideoSource());
return 0;
*****************************************************************
void * Relay::setVideoSource(FramedSource * source){
fVideoSource=source;
}
FramedSource * Relay::getVideoSource(){
return fVideoSource;
}
Then just after I got the reference on that VideoSource, I used the code of the
testOnDemand to use it like described in my previous email.
It is what the method launchServer(getVideoSource()) defined in the same class
Relay is supposed to do.
void * launchServer(FramedSource* source) {
{
char const* streamName = "x";
ServerMediaSession* sms
= ServerMediaSession::createNew(*env, streamName, streamName,
descriptionString);
*env << sms->addSubsession(MPEG4ESVideoServerMediaSubsession
::createNew(*env, reuseFirstSource,source));
rtspServer->addServerMediaSession(sms);
*env << "running...";
announceStream(rtspServer, sms, streamName);
}
env->taskScheduler().doEventLoop();
I am able to set up a RTSP session with the encoder, I succeed to create a media
session, a media subsession. When I request the relayed stream in question using
a VLC, I am able to get back the SDP.
It still though giving me exactly the same error:
parseRequestString() returned cmdName "PLAY", urlPreSuffix "", urlSuffix "x"
>> fOurServerMediaSession(0x80caca0)
PLAY rtsp://192.165.2.234:8556/x RTSP/1.0
CSeq: 4
Session: 1
Range: npt=0.000-
User-Agent: VLC Media Player (LIVE.COM Streaming Media v2005.07.19)
[ 260 ] startStream()- OnDemandServerMediaSubsession.cpp : here we start the
stream [ 72 ] startPlaying()- MediaSink.cpp : here[ 83 ] startPlaying()-
MediaSink.cpp : here[ 68 ] getNextFrame()- FramedSource.cpp :
fIsCurrentlyAwaitingData (nil)
[ 69 ] getNextFrame()- FramedSource.cpp : attempting to get the next frame[ 68
] getNextFrame()- FramedSource.cpp : fIsCurrentlyAwaitingData (nil)
[ 69 ] getNextFrame()- FramedSource.cpp : attempting to get the next frame[ 68
] getNextFrame()- FramedSource.cpp : fIsCurrentlyAwaitingData 0x1
FramedSource[0x80c9c78]::getNextFrame(): attempting to read more than once at
the same time!
[ 69 ] getNextFrame()- FramedSource.cpp : attempting to get the next frame.
It seems definitely that the threads I am using are not the origin of the
problems.
- Would you see please why am not able to read my source ?
- Any alternative solution to do an unicast relay for live streams with RTSP
signalling files would be with a great help.
Thanks a lot for your attention.
Selon wissam.l at free.fr:
> Hi,
>
> I would like to create a unicast streaming relay called Relay that launches 2
> threads: one thread for a relayClient and another one for a relayServer.
>
> I do have an streamer (a testOnDemandRTSPServer) that streams m4v files on
> demand. My relayClient would be the equivalent of the openRTSP client and the
> playcommon merged , and my relayServer would be the testOnDemandRTSPServer
> modified in a way to support live streaming; my purpose is to get the live
> stream from the streamer with my relayClient and stream it again with my
> relayServer:
>
> So basically what I do in my client is that I get the reference to
> freadSource
> defined in the object MediaSession in this way:
>
> ***********************MediaSession**********************************
> } else if (strcmp(fCodecName, "MP4V-ES") == 0) {
> fReadSource = fRTPSource
> = MPEG4ESVideoRTPSource::createNew(env(), fRTPSocket,
> fRTPPayloadFormat,
> fRTPTimestampFrequency);
> ***********************MediaSession**********************************
>
> ***********************relayClient start **********************************
> setupStreams();
> iter.reset();
> madeProgress = False;
> while ((subsession = iter.next()) != NULL) {
> if (subsession->readSource() == NULL) continue;
>
> setVideoSource(subsession->readSource());
> //to pass the reference to the relayserver.
>
> madeProgress = True;
> break;
> }
> if (!madeProgress) shutdown();
> //Note that for the moment I have only one video subsession.
>
> void * relayClient::setVideoSource(FramedSource * source){
> fVideoSource=source;
> }
>
> FramedSource * relayClient::getVideoSource(){
> return fVideoSource;
> }
> ***********************relayClient end **********************************
>
>
> In Relay:
> - Client is relayClient.
> - Server is relayServer.
>
> Launch the thread relayClient then I pass the reference freadSource to the
> relayServer server:
>
>
> server->setVideoSource(shr->client->getVideoSource());
> server->launchServer(shr->env_server);
> And I launch the thread of the serve later on.
>
> So definetly I do have the fVideoSource reference in my relayServer as
> following
>
> {
> char const* streamName = "x";
>
> ServerMediaSession* sms
> = ServerMediaSession::createNew(*env1, streamName, streamName,
> descriptionString);
>
> *env1 << sms->addSubsession(MPEG4ESVideoServerMediaSubsession
> ::createNew(*env1, reuseFirstSource,fVideoSource));
> rtspServer->addServerMediaSession(sms);
> *env1 << "running...";
>
> announceStream(rtspServer, sms, streamName);
> }
>
> env1->taskScheduler().doEventLoop(); // does not return
> }
>
> So then I defined my own ServerSubsession called
> MPEG4ESVideoServerMediaSubsession where I can inject the fVideoSource
> unstead
> of the filename... (I got inspired from what have been done in
> MPEG4ESVideoFileServerMediaSubsession.)
>
> Later on in the method createNewStreamSource I used the same reference to the
> fVideoSource unstead of creating a ByteStreamFileSource* fileSource
>
>
> FramedSource* MPEG4ESVideoServerMediaSubsession
> ::createNewStreamSource(unsigned /*clientSessionId*/, unsigned& estBitrate)
> {
> estBitrate = 500;
> return MPEG4VideoStreamFramer::createNew(envir(), fVideoSource);
> }
>
> At the end when I requested the stream in question on the appropriate
> announced
> address and port, the framed source blocks and says your are trying to read
> twice on the same source
I guess this comes from the method getNextframe in
> FramedSource:
>
> if (fIsCurrentlyAwaitingData) {
> envir() << "FramedSource[" << this << "]::getNextFrame(): attempting to
> read
> more than once at the same time!\n";
> exit(1);
> }
>
> But what would that mean ?
>
> The curious thing is that the dummy source is played by the dummy sink and I
> can
> get the SDP lines correctly .
>
> Knowing that if I pass the same reference fVideoSource to the code of the
> testMPEG4VideoStreamer as a relayServer in the method play:
>
> void play() {
>
> debug(">> relayServer::setVideoSource(%p)\n",fVideoSource);
> videoSource = MPEG4VideoStreamFramer::createNew(*env1, fVideoSource);
> *env1 << "Beginning to play...\n";
> videoSink->startPlaying(*videoSource, afterPlaying, videoSink);
> }
>
> I don’t have any problem playing it except that the
> PassiveServerMediaSubsession
> is not a good solution for me.
>
> I would like to know if I need really in this case to write a DeviceSource
> class
> ?
>
> Do I miss something in the method createNewStreamSource?
>
> Any help is welcome.
>
> Best regards.
>
> _______________________________________________
> live-devel mailing list
> live-devel at lists.live555.com
> http://lists.live555.com/mailman/listinfo/live-devel
>
More information about the live-devel
mailing list