Class SocketEndpoint

src/main/java/core/packetproxy/common/SocketEndpoint.java:24–75

import java.net.Socket;

public class SocketEndpoint implements Endpoint {

	Socket socket;
	InputStream inputstream;

	public SocketEndpoint(Socket socket) throws Exception {
		this.socket = socket;
		inputstream = socket.getInputStream();
	}

	public SocketEndpoint(Socket socket, InputStream lookaheadBuffer) throws Exception {
		this.socket = socket;
		inputstream = new SequenceInputStream(lookaheadBuffer, socket.getInputStream());
	}

	public SocketEndpoint(InetSocketAddress addr) throws Exception {
		socket = new Socket();
		socket.connect(addr);
		inputstream = socket.getInputStream();
	}

	public SocketEndpoint(InetSocketAddress addr, int timeout) throws Exception {
		socket = new Socket();
		socket.connect(addr, timeout);
		inputstream = socket.getInputStream();
	}

	@Override
	public InetSocketAddress getAddress() {
		return new InetSocketAddress(socket.getInetAddress(), socket.getPort());
	}

	@Override
	public InputStream getInputStream() throws Exception {
		return inputstream;
	}

	@Override
	public OutputStream getOutputStream() throws Exception {
		return socket.getOutputStream();
	}

	@Override
	public int getLocalPort() {
		return socket.getLocalPort();
	}

	@Override
	public String getName() {
		return null;
	}
}