serval-dna/java/org/servalproject/servaldna/MdpSocket.java

package org.servalproject.servaldna;

import java.io.IOException;
import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.UnknownHostException;
import java.nio.channels.DatagramChannel;
import java.nio.channels.SelectableChannel;

/**
 * Created by jeremy on 17/02/14.
 */
public class MdpSocket{
	private DatagramChannel channel = null;
	private SubscriberId sid = null;
	private int port;

	private static final InetAddress loopback;
	public static int loopbackMdpPort =0;
	static {
		InetAddress local=null;
		try {
			local = Inet4Address.getByAddress(new byte[]{127, 0, 0, 1});
		} catch (UnknownHostException e) {
			e.printStackTrace();
		}
		loopback = local;
	}

	/* Create an unbound socket, may be used for other information requests before binding */
	public MdpSocket() throws IOException {
	}
	public MdpSocket(int port) throws IOException {
		bind(SubscriberId.ANY, port);
	}
	public MdpSocket(SubscriberId sid, int port) throws IOException {
		bind(sid, port);
	}

	public void bind() throws IOException {
		bind(SubscriberId.ANY, 0);
	}
	public void bind(int port) throws IOException {
		bind(SubscriberId.ANY, port);
	}
	public synchronized void bind(SubscriberId sid, int port) throws IOException {
		if (loopbackMdpPort==0)
			throw new IOException("Loopback MDP port has not been set");
		if (sid.equals(this.sid) && this.port == port)
			return;
		if (this.sid!=null)
			throw new IOException("Socket is already bound");
		getChannel();
		if (!channel.isBlocking())
			throw new IOException("Cannot bind a non-blocking socket");
		MdpPacket packet = new MdpPacket();
		packet.setLocalSid(sid);
		packet.setLocalPort(port);
		packet.setFlags(MdpPacket.MDP_FLAG_BIND);
		packet.payload.flip();
		packet.send(channel);
		channel.socket().setSoTimeout(5000);
		// should throw MdpError on bind failures
		receive(packet);
		try {
			this.sid = packet.getLocalSid();
		} catch (AbstractId.InvalidBinaryException e) {
			e.printStackTrace();
			throw new MdpError(e);
		}
		this.port = packet.getLocalPort();
	}

	public SelectableChannel getChannel() throws IOException {
		if (channel == null){
			channel = DatagramChannel.open();
			channel.connect(new InetSocketAddress(loopback, loopbackMdpPort));
		}
		return channel;
	}

	public void send(MdpPacket packet) throws IOException {
		if (sid==null)
			bind(SubscriberId.ANY, 0);
		packet.setLocalSid(this.sid);
		packet.setLocalPort(this.port);
		packet.send(channel);
	}

	public void receive(MdpPacket packet) throws IOException {
		packet.receive(channel);
		if ((packet.getFlags() & MdpPacket.MDP_FLAG_ERROR)!=0)
			throw new MdpError("Unspecified error reported by server");
	}

	public void close() {
		if (sid!=null){
			try {
				MdpPacket p = new MdpPacket();
				p.payload.flip();
				p.setFlags(MdpPacket.MDP_FLAG_CLOSE);
				send(p);
			} catch (IOException e) {
				// ignore errors due to servald stopping.
				e.printStackTrace();
			}
		}
		if (channel!=null){
			try {
				channel.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

	public static class MdpError extends IOException{
		public MdpError(String msg){
			super(msg);
		}
		public MdpError(String msg, Throwable cause){
			super(msg);
			this.initCause(cause);
		}
		public MdpError(Throwable cause){
			super();
			this.initCause(cause);
		}
	}
}