incomingrtpreader.java

Peers is a very minimalistic SIP User-Agent. It s a softphone, written in java, and it has been test

/*
    This file is part of Peers.

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    Copyright 2007, 2008 Yohann Martineau 
*/

package net.sourceforge.peers.media;

import gov.nist.jrtp.RtpErrorEvent;
import gov.nist.jrtp.RtpException;
import gov.nist.jrtp.RtpListener;
import gov.nist.jrtp.RtpPacket;
import gov.nist.jrtp.RtpPacketEvent;
import gov.nist.jrtp.RtpSession;
import gov.nist.jrtp.RtpStatusEvent;
import gov.nist.jrtp.RtpTimeoutEvent;

import java.io.IOException;

import javax.sound.sampled.AudioFormat;
import javax.sound.sampled.AudioSystem;
import javax.sound.sampled.DataLine;
import javax.sound.sampled.LineUnavailableException;
import javax.sound.sampled.SourceDataLine;

import net.sourceforge.peers.Logger;

public class IncomingRtpReader implements RtpListener {

    private RtpSession rtpSession;
    private SourceDataLine line;

    public IncomingRtpReader(RtpSession rtpSession) throws IOException { 
        super();
        this.rtpSession = rtpSession;
        rtpSession.addRtpListener(this);
    }
    
    public void start() throws IOException, RtpException {
        AudioFormat format = new AudioFormat((float)8000, 16, 1, true, false);
        
        DataLine.Info info = new DataLine.Info(SourceDataLine.class, format);
        try {
            line = (SourceDataLine) AudioSystem.getLine(info);
            line.open(format);
        } catch (LineUnavailableException ex) {
            // Handle the error ... 
            ex.printStackTrace();
            return;
        }
        line.start();
        
        rtpSession.receiveRTPPackets();
    }
    
    public void stop() {
        rtpSession.stopRtpPacketReceiver();
        rtpSession.shutDown();
        line.drain();
        line.stop();
        line.close();
        line = null;
    }

    public void handleRtpErrorEvent(RtpErrorEvent arg0) {
        // TODO Auto-generated method stub
        Logger.getInstance().debug("IncomingRtpReader.handleRtpErrorEvent()");
    }

    public void handleRtpPacketEvent(RtpPacketEvent rtpEvent) {
        RtpPacket rtpPacket = rtpEvent.getRtpPacket();

        byte[] data = new byte[rtpPacket.getData().length - 12];
        //remove RTP header: rtpPacket.getData() returns raw
        //packet bytes (with headers)
        System.arraycopy(rtpPacket.getData(), 12, data, 0,
                rtpPacket.getData().length - 12);

		byte[] rawBuf = new byte[data.length * 2];
		for (int i = 0; i < data.length; ++i) {
			short decoded = AudioUlawEncodeDecode02.decode(data[i]);
			rawBuf[2 * i] = (byte)(decoded & 0xFF);
			rawBuf[2 * i + 1] = (byte)(decoded >>> 8);
		}
		line.write(rawBuf, 0, rawBuf.length);
        
    }

    public void handleRtpStatusEvent(RtpStatusEvent arg0) {
        // TODO Auto-generated method stub
        Logger.getInstance().debug("IncomingRtpReader.handleRtpStatusEvent()");
    }

    public void handleRtpTimeoutEvent(RtpTimeoutEvent arg0) {
        // TODO Auto-generated method stub
        Logger.getInstance().debug("IncomingRtpReader.handleRtpTimeoutEvent()");
    }
}