socket.java

kaffe是一个java虚拟机的源代码。里面包含了一些java例程和标准的java包。

/*
 * Java core library component.
 *
 * Copyright (c) 1997, 1998
 *      Transvirtual Technologies, Inc.  All rights reserved.
 *
 * See the file "license.terms" for information on usage and redistribution
 * of this file.
 */

package java.net;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import kaffe.net.DefaultSocketImplFactory;

public class Socket {

private static SocketImplFactory factory = new DefaultSocketImplFactory();

SocketImpl impl;

public Socket(InetAddress address, int port) throws IOException {
	this(address, port, true);
}

public Socket(String host, int port) throws UnknownHostException, IOException {
	this(InetAddress.getByName(host), port, true);
}

public Socket(InetAddress address, int port, InetAddress localAddr, int localPort) throws IOException {
    throw new kaffe.util.NotImplemented();
}
    
public Socket(String host, int port, InetAddress localAddr, int localPort) throws IOException {
    throw new kaffe.util.NotImplemented();
}

/**
 * @deprecated.
 */
public Socket(String host, int port, boolean stream) throws IOException {
	this(InetAddress.getByName(host), port, stream);
}

/**
 * @deprecated.
 */
public Socket(InetAddress address, int port, boolean stream) throws IOException {
	impl = factory.createSocketImpl();
	try {
		impl.create(stream);
		impl.connect(address, port);
	} catch (IOException ioe) {
		try {
			impl.close();
		}
		catch (IOException _) {
		}
		throw ioe;
	}
}

protected Socket(SocketImpl simpl) throws SocketException {
	impl = simpl;
}

protected Socket() {
	impl = factory.createSocketImpl();
}

public synchronized void close() throws IOException {
	impl.close();
}

public InetAddress getInetAddress() {
	return impl.getInetAddress();
}

public InputStream getInputStream() throws IOException {
	return impl.getInputStream();
}

public int getLocalPort() {
	return impl.getLocalPort();
}

public OutputStream getOutputStream() throws IOException {
	return impl.getOutputStream();
}

public int getPort() {
	return impl.getPort();
}

public InetAddress getLocalAddress() {
	try {
		return (InetAddress)impl.getOption(SocketOptions.SO_BINDADDR); 
	} catch (SocketException e) { }
	try {
		return InetAddress.getByName("0.0.0.0");
	} catch (UnknownHostException e2) { }
	return null;
}

public static synchronized void setSocketImplFactory(SocketImplFactory fac) throws IOException {
	factory = fac;
}

public void setSoLinger(boolean on, int timeout) throws SocketException {
	if (on) {
		impl.setOption(SocketOptions.SO_LINGER, new Integer(timeout));
	}
	else {
		impl.setOption(SocketOptions.SO_LINGER, new Boolean(on));
	}
}

public int getSoLinger() throws SocketException {
	return ((Integer) impl.getOption(SocketOptions.SO_LINGER)).intValue();
}

public void setSoTimeout(int timeout) throws SocketException {
	impl.setOption(SocketOptions.SO_TIMEOUT, new Integer(timeout));
}

public int getSoTimeout() throws SocketException {
	return ((Integer) impl.getOption(SocketOptions.SO_TIMEOUT)).intValue();
}

public void setSendBufferSize(int size) throws SocketException {
	impl.setOption(SocketOptions.SO_SNDBUF, new Integer(size));
}

public int getSendBufferSize() throws SocketException {
	return ((Integer) impl.getOption(SocketOptions.SO_SNDBUF)).intValue();
}

public void setReceiveBufferSize(int size) throws SocketException {
	impl.setOption(SocketOptions.SO_RCVBUF, new Integer(size));
}

public int getReceiveBufferSize() throws SocketException {
	return ((Integer) impl.getOption(SocketOptions.SO_RCVBUF)).intValue();
}

public void setTcpNoDelay(boolean on) throws SocketException {
	impl.setOption(SocketOptions.TCP_NODELAY, new Boolean(on));
}

public boolean getTcpNoDelay() throws SocketException {
	return ((Boolean) impl.getOption(SocketOptions.TCP_NODELAY)).booleanValue();
}

public String toString() {
	return impl.toString();
}
}