Player custom DataSource streaming without RTSP possible?
did anybody SUCCEED with Manager.createPlayer(DataSource source)
with custom DataSource with real audio STREAMING?
I mean without using the "rtsp://" locator, just feeding the player with your data buffer, which is growing...
The RIM example is downloading the complete file first which is nothing new when compared to the default behaviour of Player (read complete datafile before playing; I understand that this might fit into J2ME standard, but then such methods doesn't make sense
When I try to play a stream of audio (audio/amr) I see that the player is trying to cache the data first (calling read() with length starting with 58000 down to my actual buffer size), the it starts playing (plays the part that he was able to buffer at the beginning) but ends up with error code 5 which "Unspecified: some error occured which does not fit into any other category."
@rab
I'm testing on BB9000 and debugging shows following:
SMP
treaming session aquired id=2313MN: init0(2000000)=0
MN: load 1
player update com.rim.loading eventData null
MN: getPlayableStreams0(2000000)=1
MN: getLength0(2000000)=-1
MN: getPlayableStreams0(2000000)=1
MN: isSeekable0(2000000)=0
MN: play0(2000000) is audio, NO check for active pause
MN: play0(2000000)=0
update com.rim.playableStreams eventData 1
update started eventData 0
update bufferingStopped eventData 0
update error eventData 5
update stopped eventData 2940000
Streaming done reason=1 prev-state=300
While at the time of buffering I can see that the method
read(byte[] b, int off, int len) of my SourceStream is beeing called (starting with length=58000 down to 4702, where I was still responding with the maximum I had at the time in the stream which was length of 2538),
after MN: play0(2000000) is audio, NO check for active pause there were NO calls for additional data (although the buffer was growing in the meantime)
Well, I'm not sure 
but I can hear the first few seconds of audio that the player was trying to cache at the beginning, however, here's my code:
public class PlayerStreamDataSource extends DataSource {
public final static String CONTENT_TYPE = "audio/amr";
private final static byte[] AMR_HEADER = {(byte) 0x23, (byte) 0x21, (byte) 0x41,
(byte) 0x4d, (byte) 0x52,(byte) 0x0a};
private NoCopyByteArrayOutputStream baos;
private PlayerSourceStream playerSourceStream;
private volatile int totalRead;
private volatile boolean _stop = false;
public PlayerStreamDataSource(String locator) {
super(locator);
this.baos = new NoCopyByteArrayOutputStream(30000);
this.playerSourceStream = new PlayerSourceStream(CONTENT_TYPE, baos);
try {
baos.write(AMR_HEADER);
} catch (IOException e) {
System.out.println(e);
}
}
public void connect() throws IOException {
// TODO Auto-generated method stub
}
public void disconnect() {
try {
stop();
baos.close();
playerSourceStream = null;
} catch (IOException e) {
System.out.println(e);
}
}
public SourceStream[] getStreams() {
return new SourceStream[] {
playerSourceStream
};
}
public void start() throws IOException {
// TODO Auto-generated method stub
}
public void stop() throws IOException {
_stop = true;
}
public String getContentType() {
return playerSourceStream.getContentDescriptor().getContentType();
}
public Control getControl(String controlType) {
// TODO Auto-generated method stub
return null;
}
public Control[] getControls() {
// TODO Auto-generated method stub
return null;
}
public NoCopyByteArrayOutputStream getBaos() {
return baos;
}
}
public class PlayerSourceStream implements SourceStream {
private ContentDescriptor _contentDescriptor;
private long currentPosition;
private NoCopyByteArrayOutputStream stream;
public PlayerSourceStream(String contentType, NoCopyByteArrayOutputStream stream) {
_contentDescriptor = new ContentDescriptor(contentType);
this.stream = stream;
currentPosition = 0;
}
public ContentDescriptor getContentDescriptor() {
return _contentDescriptor;
}
public long getContentLength() {
return -1;
}
public int getSeekType() {
return SEEKABLE_TO_START;
}
public int getTransferSize() {
return 16;
}
public int read(byte[] b, int off, int len) throws IOException {
if ((currentPosition + len) > stream.size()) {
int currentSize = stream.size();
System.arraycopy(stream.getByteArray(), (int) currentPosition, b, off, currentSize);
System.out.println("Stream READ request beyond buffer size: "
+ Long.toString(currentPosition) + " len: " + Integer.toString(len) + " returning " + Integer.toString(currentSize));
return currentSize;
} else {
System.arraycopy(stream.getByteArray(), (int) currentPosition, b, off, len);
return len;
}
}
public long seek(long where) throws IOException {
if (where <= 0) this.currentPosition = 0;
else if (where < stream.size()) this.currentPosition = where;
else {
System.out.println(Seek request beyond buffer size: " + Long.toString(where));
}
return this.currentPosition;
}
public long tell() {
return currentPosition;
}
public Control getControl(String controlType) {
// TODO Auto-generated method stub
return null;
}
public Control[] getControls() {
// TODO Auto-generated method stub
return null;
}
}
In another thread I'm receiving the audio data and writing them into the NoCopyByteArrayOutputStream so it's constantly growing.
AmrPlayer
....
playerStreamDataSource = new PlayerStreamDataSource("audio/amr"); // no idea what locator should I use here
player = Manager.createPlayer(playerStreamDataSource);
