Hi Sir,
I appreciates your time and help. I post my whole RecvStream.java class sir my problem is that my read () meathod not working . and unable to playback audio. so please sir help me how to work my SourceStream.read()
method.
I post some deboug message again. please see below.
..........................Recvstream.java/.................
...............
public class RecvStream implements PlayerListener {
private Player mPlayer;
private SendStream mSendStream;
private RtpSession mSession;
private long mStartTime = 0;
static Timer mTimer;
private TimerTask rtpCollector;
private LabelField status;
private long mPlayerTs=-1;
private byte[] dencoded = null;
private Player player = null;
private int available = 0;
private int curPos = 0;
//private long startTime;
private int totalLen;
private static final String content = "audio/x-pcm";
private boolean stopFlag = false;
/**
* Creates a new MyScreen object
*/
private final static Logger mLog = JOrtpFactory.instance().createLogger("SoftphoneCore");
private OutputStream os = null;
mypackage.ByteBuffer buffer = new mypackage.ByteBuffer(32000, 32000);
private SourceStream input = new SourceStream() {
private ContentDescriptor mContentDescriptor = new ContentDescriptor(
content);
private static final int defSize = 320;
public int read(byte[] b, int offset, int length) throws IOException {
if (mStartTime == 0) {
mStartTime = System.currentTimeMillis();
}
int lWrittenLenth = 0;
os.write("size:".getBytes());
os.write(new Integer(buffer.getSize()).toString().getBytes());
os.write("\r\n".getBytes());
os.flush();
byte[] buf = buffer.dequeue();
if(buf !=null )
{
System.out.println("buffer item recivennnn //////"+buf);
mLog.info("buffer item recive //////"+buf);
os.write(buf);
os.flush();
os.write("read.size".getBytes());
System.out.println("read.size".getBytes());
os.write(new Integer(b.length).toString().getBytes());
os.write("\tsize:".getBytes());
os.write(new Integer(buffer.getSize()).toString().getBytes());
os.write("\ttaken:".getBytes());
os.write(new Integer(buf.length).toString().getBytes());
os.write("\ttime:".getBytes());
os.write(new Long(System.currentTimeMillis()).toString().getBytes());
os.write("\r\n".getBytes());
os.flush();
}
return lWrittenLenth;
}
public ContentDescriptor getContentDescriptor() {
return mContentDescriptor;
}
public long getContentLength() {
return 64000;
}
public int getSeekType() {
return SourceStream.SEEKABLE_TO_START;
}
public int getTransferSize() {
return defSize * 1000;
}
public long seek(long where) throws IOException {
return where;
// throw new IOException("not seekable");
}
/*public long tell() {
return mStartTime == 0 ? 0
: (System.currentTimeMillis() - mStartTime);
// return 0;
}*/
public long tell() {
if (mStartTime==0) return 0;
return (System.currentTimeMillis() - mStartTime);
}
public Control getControl(String controlType) {
return null;
}
public Control[] getControls() {
return null;
}
};
private int getCurTs() {
if (mStartTime == 0) {
mStartTime = System.currentTimeMillis();
}
// return (int) ((System.currentTimeMillis() - mStartTime) ); // 8
return (int) System.currentTimeMillis();
}
public RecvStream(RtpSession session,SendStream sendStream) {
mSession=session;
mSendStream = sendStream;
}
public void start() throws IOException, MediaException {
if (null == player) {
player = Manager.createPlayer(new DataSource(null) {
SourceStream[] mStream = {input };
public void connect() throws IOException {
}
public void disconnect() {
}
public String getContentType() {
return content;
}
public SourceStream[] getStreams() {
return mStream;
}
public void start() throws IOException {
}
public void stop() throws IOException {
}
public Control getControl(String controlType) {
return null;
}
public Control[] getControls() {
return null;
}
});
// ///////////////////// DataSource ///////////////
// ///////////////ByteArrayInputStream/////////////////////////////
/* ByteArrayInputStream theInput = new
ByteArrayInputStream(dencoded);
player = Manager.createPlayer(theInput, "audio/x-pcm");*/
// ///////////////ByteArrayInputStream/////////////////////////////
mTimer = new Timer();
mTimer.scheduleAtFixedRate(rtpCollector = new TimerTask() {
private byte[] tempBuffer = new byte[160];
private boolean priority_set = false;
private int rowSize = 320;
public void run() {
if (mStartTime == 0) {
mStartTime = System.currentTimeMillis();
}
int lWrittenLenth = 0;
try {
if (!priority_set
&& Thread.currentThread().getPriority() != Thread.MAX_PRIORITY) {
Thread.currentThread().setPriority(
Thread.MAX_PRIORITY);
priority_set = true;
}
while (lWrittenLenth <= (rowSize * 5)) {
long ts = getCurTs();
if (mPlayerTs == -1) {
mPlayerTs = ts;
}
RtpPacket packet = null;
long diff;
while ((diff = (ts - mPlayerTs)) >= 0) {
if (diff > 400) {
mPlayerTs = ts - 400;
}
packet = mSession.recvPacket((int) mPlayerTs);
System.out.println("saurabh recive RtpPacket /////"+packet);
if (packet != null) {
System.arraycopy(packet.getBytes(), 12,
tempBuffer, 0, 160);
byte[] dencoded = new byte[tempBuffer.length * 2];
for (int i = 0, j = 0; i < tempBuffer.length; i++) {
int s = tempBuffer[i];
int res = G711.ulaw2linear(s);
dencoded[j++] = (byte) (res);
dencoded[j++] = (byte) (res >> 8);
}
lWrittenLenth += rowSize;
buffer.enqueue(dencoded);
System.out.println("saurabh tempBuffer packet////"+dencoded);
}
mPlayerTs += 160;
}
}
} catch (Exception e) {
}
}}, 0, 10);
stopFlag = false;
curPos = 0;
status.setText("Playing...");
player.addPlayerListener(this);
player.realize();
AudioPathControl lPathCtr = (AudioPathControl) player
.getControl("net.rim.device.api.media.control.AudioPathControl");
lPathCtr.setAudioPath(AudioPathControl.AUDIO_PATH_HANDSET);
player.prefetch();
player.start();
}
}
private void restartPlayer() {
if (player != null) {
try {
if (player.getState() != Player.CLOSED) {
player.stop();
player.start();
}
} catch (MediaException e) {
}
}
}
public void stop() {
if (player == null)
return;// nothing to stop
try {
if (player.getState() == Player.STARTED) {
player.stop();
}
if (player.getState() != Player.CLOSED) {
player.close();
}
player = null;
status.setText("Stopped!");
} catch (MediaException e) {
}
}
public void playerUpdate(Player player, String event, Object eventData) {
if (event.equals(PlayerListener.STOPPED)
|| event.equals(PlayerListener.END_OF_MEDIA)) {
if (!stopFlag) {
restartPlayer();
}
}
}
public int getPlayLevel() {
if (player != null) {
return ((VolumeControl) player.getControl("VolumeControl"))
.getLevel();
} else {
return 0;
}
}
public void setPlayLevel(int level) {
if (player != null) {
((VolumeControl) player.getControl("VolumeControl"))
.setLevel(level);
}
}
public void enableSpeaker(boolean value) {
if (player == null)
return;// just ignore
AudioPathControl lPathCtr = (AudioPathControl) player
.getControl("net.rim.device.api.media.control.AudioPathControl");
try {
lPathCtr.setAudioPath(value ? AudioPathControl.AUDIO_PATH_HANDSFREE
: AudioPathControl.AUDIO_PATH_HANDSET);
} catch (Throwable e) {
}
}
public boolean isSpeakerEnabled() {
if (player == null)
return false;// just ignore
AudioPathControl lPathCtr = (AudioPathControl) player
.getControl("net.rim.device.api.media.control.AudioPathControl");
return lPathCtr.getAudioPath() == AudioPathControl.AUDIO_PATH_HANDSFREE;
}
public long getPlayerTs() {
return mPlayerTs;
}
}
.............See Debug Message..............
[0.0] [STREAM] releasing buffer [index: 0] [handle: 2569]
[0.0] MSM[0]: already released
[0.0] MP: h=16777216,s=UD: -unlC
[0.0] MP: h=16777216,s=UD: -mStp
[0.0] AR: add source 11
[0.0] AR: setAudioMode 9
[0.0] MSM[1]: created session
[0.0] MSM[1]: ----- initializeStream
[0.0] [STREAM] allocating buffer [index: 0] [size: 65536]
[0.0] [STREAM] allocating stream [index: 0] [size: 65536]
[0.0] [STREAM] allocated stream [index: 0] [handle: 2825] [size: 65536]
[0.0] MN: setRecordParameters(1,20)=0
[0.0] MSM[1]: Starting streaming session 2825
[0.0] 1328620428109 :: EventScanner going to sleep!
[0.0] No stack trace
[0.0] jortp-Info:JitterBufferControl started, mCurrentSize=480.0 mDiffCurrent=-1475487426
[0.0] jortp-Info:mDiffCurrent=-1475487266
[0.0] jortp-Info:mDiffCurrent=-1475487106
[0.0] ACS Portrait
[0.0] jortp-Warn:Incoming payload type changed to 0
[0.0] jortp-Info:mDiffCurrent=-1475486946
[0.0] saurabh recive RtpPacket /////Seq=12765 Ts=46235
[0.0] saurabh tempBuffer packet////[B@190edc92
[0.0] saurabh recive RtpPacket /////null
[0.0] saurabh recive RtpPacket /////Seq=12766 Ts=46475
[0.0] saurabh recive RtpPacket /////null
[0.0] saurabh recive RtpPacket /////Seq=12767 Ts=46635
[0.0] saurabh tempBuffer packet////[B@3b804940
[0.0] 1328620428671 :: Removing clientTransaction sip4me.gov.nist.siplite.stack.ClientTransaction@c879216c[0.0]
[0.0] 1328620428671 :: Removing clientTransaction sip4me.gov.nist.siplite.stack.ClientTransaction@691b7aac[0.0]
[0.0] jortp-Warn:Incoming payload type changed to 0
[0.0] jortp-Info:mDiffCurrent=-1475486786
[0.0] saurabh recive RtpPacket /////Seq=12769 Ts=46955
[0.0] MSM[1]: Stream 2825 new data
[0.0] saurabh tempBuffer packet////[B@3f5ac7f3
[0.0] saurabh recive RtpPacket /////Seq=12770 Ts=47115
[0.0] saurabh tempBuffer packet////[B@f0e27c5
[0.0] MSM[1]: Stream 2825 new data
[0.0] jortp-Info:mDiffCurrent=-1475486626
[0.0] saurabh recive RtpPacket /////Seq=12772 Ts=47435
[0.0] saurabh tempBuffer packet////[B@ac36902f
[0.0] jortp-Info:mDiffCurrent=-1475486466
[0.0] jortp-Warn:Incoming payload type changed to 0
[0.0] saurabh recive RtpPacket /////Seq=12774 Ts=47755
[0.0] saurabh recive RtpPacket /////null
[0.0] jortp-Warn:Incoming payload type changed to 0
[0.0] jortp-Info:mDiffCurrent=-1475486306
[0.0] saurabh recive RtpPacket /////null
[0.0] jortp-Info:mDiffCurrent=-1475486146
[0.0] saurabh recive RtpPacket /////null
[0.0] jortp-Info:mDiffCurrent=-1475485986
[0.0] saurabh recive RtpPacket /////Seq=12775 Ts=48555
[0.0] saurabh recive RtpPacket /////null
[0.0] jortp-Warn:Incoming payload type changed to 0
[0.0] saurabh recive RtpPacket /////null
[0.0] MSM[1]: Stream 2825 new data
[0.0] MSM[1]: Stream 2825 new data
[0.0] MSM[1]: Stream 2825 new data
[0.0] MSM[1]: Stream 2825 new data
Thanks
Saurabh
