Yep, that should work as expected.
On 12/12/06, Costin Tuculescu <[EMAIL PROTECTED]> wrote:
Hi Dan,
I've made a modification to the publish method in the StreamService.java
class, and it did the trick for me. Notice the parts commented with
"Added
by CT..."
public void publish(String name, String mode) {
log.info("publish: " + name + ", " + mode);
IConnection conn = Red5.getConnectionLocal();
if (!(conn instanceof IStreamCapableConnection)) return;
IStreamCapableConnection streamConn =
(IStreamCapableConnection) conn;
int streamId = getCurrentStreamId();
IClientStream stream = streamConn.getStreamById(streamId);
if (stream != null && !(stream instanceof
IClientBroadcastStream)) return;
if (stream == null)
stream = streamConn.newBroadcastStream(streamId);
IClientBroadcastStream bs = (IClientBroadcastStream)
stream;
try {
if (IClientStream.MODE_RECORD.equals(mode)) {
//Added by CT to play and record at the
same time:
IContext context = conn.getScope
().getContext();
IProviderService providerService =
(IProviderService)
context.getBean(IProviderService.KEY);
bs.setPublishedName(name);
// TODO handle registration failure
if (
providerService.registerBroadcastStream(conn.getScope(), name, bs))
{
IBroadcastScope bsScope =
getBroadcastScope(conn.getScope(),
bs.getPublishedName());
bsScope.setAttribute(
IBroadcastScope.STREAM_ATTRIBUTE, bs);
if (conn instanceof
BaseConnection)
((BaseConnection)
conn).registerBasicScope(bsScope);
}
// end add
bs.start();
bs.saveAs(name, false);
} else if (IClientStream.MODE_APPEND.equals(mode))
{
// Added by CT to play and record at the same
time:
IContext context = conn.getScope
().getContext();
IProviderService providerService =
(IProviderService)
context.getBean(IProviderService.KEY);
bs.setPublishedName(name);
// TODO handle registration failure
if (
providerService.registerBroadcastStream(conn.getScope(), name, bs))
{
IBroadcastScope bsScope =
getBroadcastScope(conn.getScope(),
bs.getPublishedName());
bsScope.setAttribute(
IBroadcastScope.STREAM_ATTRIBUTE, bs);
if (conn instanceof
BaseConnection)
((BaseConnection)
conn).registerBasicScope(bsScope);
}
// end add
bs.start();
bs.saveAs(name, true);
} else if (IClientStream.MODE_LIVE.equals(mode)) {
IContext context = conn.getScope
().getContext();
IProviderService providerService =
(IProviderService)
context.getBean(IProviderService.KEY);
bs.setPublishedName(name);
// TODO handle registration failure
if (
providerService.registerBroadcastStream(conn.getScope(), name, bs))
{
IBroadcastScope bsScope =
getBroadcastScope(conn.getScope(),
bs.getPublishedName());
bsScope.setAttribute(
IBroadcastScope.STREAM_ATTRIBUTE, bs);
if (conn instanceof
BaseConnection)
((BaseConnection)
conn).registerBasicScope(bsScope);
}
bs.start();
}
} catch (Exception e) {
// TODO report publish error
}
}
So try replacing the original publish function in that class with this
one,
and let me know if it does the trick. It worked for me. I've been
meaning
to submit it back to the community but I've just been slammed, plus I
don't
really know how to go about putting this type of stuff in the trunk, nor
am
I any good at programming Java. The mod I made just made sense based on
the
stream being published as live -- the recorded streams didn't seem to be
registering themselves with the scope. So yeah, let me know. Thanks.
-Costin
----Original Message Follows----
From: Dan Rossi <[EMAIL PROTECTED]>
Reply-To: [email protected]
To: [email protected]
Subject: Re: [Red5] Cannot subscribe to Live Stream if its being Recorded
Date: Tue, 12 Dec 2006 15:30:42 +1100
any solutions ?
Dan Rossi wrote:
>Hi does someone have a solution for subscribing to an archiving stream,
>this hack below doesnt work, the broadcast stops at the server
immediately.
> If i try play(stream, -1) the subscribe just hangs like the stream isnt
>available even though the server aknowledges the publish name and the
>server stream aware handlers work fine and call the clients when a
>broadcast is happening just cant stream.
>
>I am using the filenamegenerator bean to record to one path, and playback
a
>trailer in another path, could this be the problem, ive had my ticket
open
>for ages now and got an ignorant response.
>
>If i call with play(stream, -2) i get an exception
>
> [java] [ERROR] 1020437 pool-1-thread-15:(
>org.red5.io.flv.impl.FLVReader.er
>ror ) Error fillBuffer
> [java] java.lang.IllegalArgumentException
> [java] at java.nio.ByteBuffer.allocate(ByteBuffer.java:311)
> [java] at
>org.red5.io.flv.impl.FLVReader.fillBuffer(FLVReader.java:242)
>
> [java] at
>org.red5.io.flv.impl.FLVReader.setCurrentPosition(FLVReader.j
>ava:170)
> [java] at
>org.red5.io.flv.impl.FLVReader.analyzeKeyFrames(FLVReader.jav
>a:527)
> [java] at
>org.red5.io.flv.impl.FLVReader.postInitialize(FLVReader.java:
>264)
> [java] at
>org.red5.io.flv.impl.FLVReader.<init>(FLVReader.java:275)
> [java] at org.red5.io.flv.impl.FLV.getReader(FLV.java:172)
> [java] at
>org.red5.server.stream.provider.FileProvider.init(FileProvide
>r.java:179)
> [java] at
>org.red5.server.stream.provider.FileProvider.pullMessage(File
>Provider.java:87)
> [java] at
>org.red5.server.messaging.InMemoryPullPullPipe.pullMessage(In
>MemoryPullPullPipe.java:72)
> [java] at
>org.red5.server.stream.PlaylistSubscriberStream$PlayEngine.pu
>llAndPush(PlaylistSubscriberStream.java:847)
> [java] at
>org.red5.server.stream.PlaylistSubscriberStream$PlayEngine.pl
>ay(PlaylistSubscriberStream.java:681)
> [java] at
>org.red5.server.stream.PlaylistSubscriberStream.play(Playlist
>SubscriberStream.java:124)
> [java] at
>org.red5.server.stream.StreamService.play(StreamService.java:
>179)
> [java] at
>org.red5.server.stream.StreamService.play(StreamService.java:
>187)
> [java] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
>Method)
> [java] at
>sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAcces
>sorImpl.java:39)
> [java] at
>sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMet
>hodAccessorImpl.java:25)
> [java] at java.lang.reflect.Method.invoke(Method.java:585)
> [java] at
>org.red5.server.service.ServiceInvoker.invoke(ServiceInvoker.
>java:161)
> [java] at
>org.red5.server.net.rtmp.RTMPHandler.invokeCall(RTMPHandler.j
>ava:135)
> [java] at
>org.red5.server.net.rtmp.RTMPHandler.onInvoke(RTMPHandler.jav
>a:276)
> [java] at
>org.red5.server.net.rtmp.BaseRTMPHandler.messageReceived(Base
>RTMPHandler.java:114)
> [java] at
>org.red5.server.net.rtmp.RTMPMinaIoHandler.messageReceived(RT
>MPMinaIoHandler.java:84)
> [java] at
>org.apache.mina.common.support.AbstractIoFilterChain$2.messag
>eReceived(AbstractIoFilterChain.java:189)
> [java] at
>org.apache.mina.common.support.AbstractIoFilterChain.callNext
>MessageReceived(AbstractIoFilterChain.java:502)
> [java] at
>org.apache.mina.common.support.AbstractIoFilterChain.access$1
>000(AbstractIoFilterChain.java:52)
> [java] at
>org.apache.mina.common.support.AbstractIoFilterChain$EntryImp
>l$1.messageReceived(AbstractIoFilterChain.java:777)
> [java] at
>org.red5.io.filter.ExecutorFilter.processEvent(ExecutorFilter
>.java:231)
> [java] at
>org.red5.io.filter.ExecutorFilter$ProcessEventsRunnable.run(E
>xecutorFilter.java:280)
> [java] at
>java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Thread
>PoolExecutor.java:650)
> [java] at
>java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPool
>Executor.java:675)
> [java] at java.lang.Thread.run(Thread.java:595)
> [java] [INFO] 1020453 pool-1-thread-15:(
>org.red5.io.flv.impl.FLVReader.inf
>o ) New position exceeds limit
> [java] [INFO] 1020453 pool-1-thread-15:(
>org.red5.server.stream.PlaylistSub
>scriberStream.info ) Scheduled stop in: 1879753393
>
>I just checked with FMS, and my ported application was fine, subscribes
at
>it records.
>
>Alex Zimin wrote:
>
>>I have the following code and it works just fine for me.
>>ns.publish("stream1", "live");
>>ns.publish("stream2", "record");
>>Client, which connects to live stream, is able to play it, and recording
>>happens at the same time.
>> However I have a different problem. When I stop recording, by issuing
>>ns.close("stream2"); command, it closes both streams.
>>I am using Red5 0.6RC1.
>> Any help?
>> Thanks,
>> Alex.
>>
>
>
>_______________________________________________
>Red5 mailing list
>[email protected]
>http://osflash.org/mailman/listinfo/red5_osflash.org
>
>
_______________________________________________
Red5 mailing list
[email protected]
http://osflash.org/mailman/listinfo/red5_osflash.org
_________________________________________________________________
All-in-one security and maintenance for your PC. Get a free 90-day trial!
http://clk.atdmt.com/MSN/go/msnnkwlo0050000002msn/direct/01/?href=http://clk.atdmt.com/MSN/go/msnnkwlo0050000001msn/direct/01/?href=http://www.windowsonecare.com/?sc_cid=msn_hotmail
_______________________________________________
Red5 mailing list
[email protected]
http://osflash.org/mailman/listinfo/red5_osflash.org
--
I cannot tell why this heart languishes in silence. It is for small needs it
never asks, or knows or remembers. -- Tagore
Best Regards
Steven Gong
_______________________________________________
Red5 mailing list
[email protected]
http://osflash.org/mailman/listinfo/red5_osflash.org
