multicastmessagesocket.java

Java SIP

/*
 * This file was derived from libdissipate, an open source SIP library. The original file 
 * was modified on 1/23/2001.  Please see
 * http://www.div8.net/dissipate for more information.
 *
 * Copyright (c) 2000 Billy Biggs <[e-mail]>
 *
 *
 * This library is free software; you can redistribute it and/or modify it
 * under the terms of the GNU Library General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or (at your
 * option) any later version.
 * 
 * This library 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 Library General Public
 * License for more details.
 * 
 * You should have received a copy of the GNU Library General Public License
 * along with this library; see the file COPYING.LIB.  If not, write to the
 * Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
 * MA 02111-1307, USA.
 *
 */
/**
 * class MulticastMessageSocket
 * 
 * This is the Multicast implementation of the MessageSocket class.  It is used
 * to allow the client to register using a multicast address (sip.mcast.net).
 *
 * This code has been generated using C2J++
 * C2J++ is based on Chris Laffra's C2J ([e-mail])
 * Read general disclaimer distributed with C2J++ before using this code
 * For information about C2J++, send mail to [e-mail]
 */
package org.mitre.jsip;

import java.net.SocketException;
import java.net.MulticastSocket;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.io.IOException;

public class MulticastMessageSocket extends MessageSocket
{

    /**
     * MulticastMessageSocket
     */
    public MulticastMessageSocket()
    {
	type = MCAST;

	didcomplain = false;

    }

    /**
     * connect
     * @param portnum
     * @return int
     */
    public int connect(String hostname, int portnum)
    {
	fSendPort = portnum;
	if (hostname == null)
	    hostname = "224.0.1.75";
	
	sendSocket = null;
	try {
	    InetAddress raddr = InetAddress.getByName( hostname );
	    sendSocket = new MulticastSocket();
	    sendSocket.connect( raddr, portnum );
	} catch (UnknownHostException uhe) {
	    System.err.println("Unable to connect to host: " + hostname);
	    return -1;
	} catch (IOException ioe) {
	    System.err.println("Unable to set up socket to remote host: " + ioe);
	    didcomplain =  true;
	    return -1;
	}

	return 0;
    }

    /**
     * Connect to the socket
     *
     */
    public int connect( InetAddress host, int portnum ) 
    {
	InetAddress sendAddr;
	fSendPort = portnum;
	
	try {
	    if ( host == null ) {
		sendAddr = InetAddress.getByName( "224.0.1.75" );
	    } else {
		sendAddr = host;
	    }

	    sendSocket = new MulticastSocket();
	    sendSocket.connect( sendAddr, portnum );
	} catch (UnknownHostException uhe) {
	    System.err.println("Unable to connect to host: " + host);
	    return -1;
	} catch (IOException ioe) {
	    System.err.println("Unable to set up socket to remote host: " + ioe);
	    didcomplain =  true;
	    return -1;
	}

	return 0;
    }

		

    /**
     * send
     * @param sendbuffer
     * @param length
     * @return int
     */
    public int send(String sendbuffer, int length)
    {
	int numbytes;
	int retries = 0;

	DatagramPacket dp = new DatagramPacket(sendbuffer.getBytes(), sendbuffer.length());

	fSendThread = new DatagramSendThread( dp, sendSocket, fRetryTimer );
	fSendThread.start();

	return 0;
    }

    /**
     * Not implemented in this class
     * @param recvbuffer
     * @param maxlength
     * @return int
     */
    public int receive(byte[] recvbuffer, int maxlength)
    {
	return 0;
    }

    /**
     * Not implemented in this class
     * @param portnum
     * @return int
     */
    public int listen(MessageQueue queue)
    {
	return 0;
    }

    /**
     * Not implemented in this class
     * @return int
     */
    public void accept()
    {
    }

    /**
     * Not implemented in this class
     * @return int
     */
    public int listenOnEvenPort()
    {
	return 0;
    }
    
    public void close() {
	if ( fSocket != null ) fSocket.close();
	if ( sendSocket != null ) sendSocket.close();

	fSocket = null;
	sendSocket = null;
    }

    // class variables
    protected boolean didcomplain;

    protected MulticastSocket fSocket, sendSocket;
    protected DatagramPacket fSendDatagram;

    protected int fSendPort;        
    protected DatagramSendThread fSendThread;

    protected int fRetryTimer = 5000;
    protected int fRetryCount = 0;

    public final static int DEFAULT_MAX_DATAGRAM_SIZE = 1024;
    public final static int DEFAULT_MAX_RETRIES = 5;
}

// ***********************************************************************************************

/**
 * a class for dealing with the problems of sending a datagrams
 */
class MulticastSendThread extends Thread
{
    
    protected final static boolean fDebugOn = true;
    
    DatagramPacket fSendPacket;
    MulticastSocket fSendSocket;
    public  int fSendState = 0;//neither received nor failed
    protected int fRetryInterval; //in msec
    
    /**
     * @param sendPacket
     */
    public MulticastSendThread(DatagramPacket sendPacket,
			      MulticastSocket sendSocket,
			      int retryTime)
    {
	fSendPacket = sendPacket;
	fSendSocket = sendSocket;
	fRetryInterval = retryTime;
	
    }//DatagramSendThread
    
    
    /**
     * proceed with all of the time-consuming stuff here
     */
    public void run()
    {
	if (fDebugOn)
	    System.out.println("MulticastSendThread running...");
	
	try {
	    if (fDebugOn)
		System.out.println("MulticastSendThread sending...");
	    byte ttl = 15;
	    fSendSocket.send(fSendPacket, ttl);
	    fSendState = 0;//sent OK!
	    if (fDebugOn)
     	        System.out.println("DatagramSendThread sent ok!");
	    
	    try {this.sleep(fRetryInterval);}
	    catch (InterruptedException iEx) {
		if (fDebugOn)
		    System.err.println("DatagramSendThread sleep interrupted!");
		fSendState = -1;
	    }
	}
	catch (IOException sendEx) {
	    if (fDebugOn)
		System.err.println("send failed! " + sendEx);
	    fSendState = -1;
	} 
	finally {
	    if (fSendSocket != null) fSendSocket.close();
	}
    } // run
    
    
}/* class DatagramSendThread */