Help Regarding Delay in Voice Conversation

[zaheer zuhrab]

HI Every one

I am working in JMF and i am faceing a problem in voice conversation that there is delay of almost one or two seconds in conversation but i am not able where i can set buffer length and threshold amount to reduce this delay in conversation followin code of transmiter(RTPServer) and receiver(RTPClient) Please guid me regarding this problem in code so i can reduce the delay


i already pasted a query but no reply to me i am waiting for reply i have another problem that when i execute this program the voice conversation is started but when i stop this conversation and starts it again then there is error which is given below i am really waiting for reply please reply me and who understand this problem

Thanks
Regards



javax.media.NotConfiguredError: setContentDescriptor cannot be called before configured
at com.sun.media.ProcessEngine.setContentDescriptor(ProcessEngine.java:342)
at com.sun.media.MediaProcessor.setContentDescriptor(MediaProcessor.java:123)
at RTPServer.RTPServerTranmsimter(RTPServer.java:66)
at SignalingServer.Receive(SignalingServer.java:44)
at SignalingServer.run(SignalingServer.java:142)
at java.lang.Thread.run(Thread.java:619)
Exception in thread "Thread-2" javax.media.NotConfiguredError: setContentDescriptor cannot be called before configured
at com.sun.media.ProcessEngine.setContentDescriptor(ProcessEngine.java:342)
at com.sun.media.MediaProcessor.setContentDescriptor(MediaProcessor.java:123)
at RTPServer.RTPServerTranmsimter(RTPServer.java:66)
at SignalingServer.Receive(SignalingServer.java:44)
at SignalingServer.run(SignalingServer.java:142)
at java.lang.Thread.run(Thread.java:619)

//import java.io.*;
import java.util.Vector;
import java.net.InetAddress;
import javax.media.rtp.*;
import javax.media.rtp.rtcp.*;
import javax.media.*;
import javax.media.format.*;
import javax.media.protocol.*;
import javax.media.control.*;
public class RTPServer implements ControllerListener
{
    private boolean realized = false;
    private boolean configured = false;
    CaptureDeviceInfo di =null;
    Processor processor = null;
    RTPManager rtpMgr;
    String ip;
    int port;
   // private String destUrl = "rtp://10.17.18.2:42050/audio/1";
    private String destUrl = "rtp://"+ip+":"+port+"/audio/1";
    private MediaLocator dest = new MediaLocator(destUrl);

    public  RTPServer(String IP, int Port)
    {
        this.ip = IP;
        this.port = Port;

        System.out.println("Begin to Capture Devices list");
        Vector deviceList = CaptureDeviceManager.getDeviceList(new AudioFormat("linear", 44100, 16, 2));
        if (deviceList.size() > 0)
        di = (CaptureDeviceInfo)deviceList.firstElement();
        else
        
          //  System.out.println("Unable to Capture Device at Element0");
            System.exit(-1);
        
         try {
                System.out.println(" Begin to Create processor");
                processor = Manager.createProcessor(di.getLocator());
                System.out.println("Processer is created");
                processor.addControllerListener(this);
                processor.configure();
                while (! configured)
                {
                    try
                    {
                        Thread.currentThread().sleep(100L);
                    } catch (InterruptedException e){
                    e.printStackTrace();
                    }
                }
                System.out.println("Begin to setting ContentDescriptor");
                processor.setContentDescriptor(new ContentDescriptor(ContentDescriptor.RAW_RTP));
                System.out.println("Processor is going to start");
                processor.start();
                System.out.println("Processor started");
                setTrackFormat(processor);
                processor.realize();
                while (! realized)
                {
                    try
                    {
                        Thread.currentThread().sleep(100L);;
                    } catch (InterruptedException e) {}
                }
                transmit(processor);
            } catch(Exception e)
            {
                e.printStackTrace();
                System.exit(1);
            }
 private void setTrackFormat(Processor processor)
    {
        TrackControl [] tracks = processor.getTrackControls();
        // Do we have atleast one track?
        if (tracks == null || tracks.length < 1)
        {
            System.out.println("Couldn't find tracks in processor");
            System.exit(1);
        }
        ContentDescriptor cd = new ContentDescriptor(ContentDescriptor.RAW_RTP);
        processor.setContentDescriptor(cd);
        Format supported[];
        Format chosen;
        boolean atLeastOneTrack = false;
        // Program the tracks.
        for (int i = 0; i < tracks.length; i++)
        {
            Format format = tracks[i].getFormat();
            if (tracks[i].isEnabled())
            {
            supported = tracks[i].getSupportedFormats();
                for (int n = 0; n < supported.length; n++)
                System.out.println("Supported format: " + supported[n]);

                if (supported.length > 0)
                {
                    chosen = supported[0];
                    tracks[i].setFormat(chosen);
                    System.err.println("Track " + i + " is set to transmit as:");
                    System.err.println("  " + chosen);
                    atLeastOneTrack = true;
                }
                else
                    tracks[i].setEnabled(false);
            }
            else
                tracks[i].setEnabled(false);
        }
    }
    private void transmit(Processor processor)
    {
        try {
                DataSource output = processor.getDataOutput();
                DataSource source =  processor.getDataOutput();
                RTPManager rtpMgr = RTPManager.newInstance();
                SessionAddress localAddr, destAddr;
                SendStream sendStream;
                //int port = 42050;
                SourceDescription srcDesList[];
                localAddr = new SessionAddress( InetAddress.getLocalHost(), port);
                InetAddress	ipAddr = InetAddress.getByName(ip);
                destAddr = new SessionAddress( ipAddr, port);
                rtpMgr.initialize(localAddr);
                rtpMgr.addTarget(destAddr);
                System.err.println( "Created RTP session: " + ipAddr + " " + port);
                sendStream = rtpMgr.createSendStream(source, 0);
                sendStream.start();
                System.out.println("Sending stream is  started");
                processor.start();
                System.out.println("Proccessor begin to start");
            }
        catch(Exception e)
        {
	    e.printStackTrace();
        }
    }
public synchronized void controllerUpdate(ControllerEvent evt)
    {
        if (evt instanceof RealizeCompleteEvent)
        {
	    realized = true;
        }
        else if (evt instanceof ConfigureCompleteEvent)
        {
            configured = true;
        } else if (evt instanceof EndOfMediaEvent)
        {
            System.exit(0);
        }
        else
        {
	    // System.out.println(evt.toString());
        }
    }            //

and code for Receiver is

//
import java.io.*;

import javax.media.*;
import javax.media.format.*;
import javax.media.protocol.*;
import javax.media.rtp.ReceiveStreamListener;
import javax.media.rtp.event.ReceiveStreamEvent;

public class RTPClient implements ControllerListener,ReceiveStreamListener {

////    public static void main(String [] args) {
////	new RTPClient();
////    }
    String IP;
    int RecPort;

    public RTPClient(String ip,int ReceivePort) {
        this.IP = ip;
        this.RecPort = ReceivePort;
	Player p;
        //ip of server on different pc
	//String srcUrl = "rtp://192.168.2.1:42050/audio/1";
    String srcUrl = "rtp://"+IP+":"+RecPort+"/audio/1";
	DataSink sink;
	MediaLocator src = new MediaLocator(srcUrl);

	try {
	    p = Manager.createPlayer(src);
	    p.addControllerListener(this);
	    p.start();
	} catch(Exception e) {
	    e.printStackTrace();
	    System.exit(1);
	}
    }

    public synchronized void controllerUpdate(ControllerEvent evt) {
	if (evt instanceof EndOfMediaEvent) {
	    System.exit(0);
	} else {
	    System.out.println(evt.toString());
	}
    }

    public void update(ReceiveStreamEvent event) {
        if(event instanceof ReceiveStreamEvent)
            System.out.println("A Stream is detected");
        throw new UnsupportedOperationException("Not supported yet.");
    }
}

//

[Rob Spoor]

Please Use Code Tags. I've added them for you this time, but next time you should do it yourself.