Commit 9fd64790 by Michael Koch Committed by Michael Koch

2003-09-18 Michael Koch <konqueror@gmx.de>

	* java/net/DatagramSocket.java
	(ch): Removed.
	(receive): Use getChannel() instead of ch.
	(send): Likewise.
	(getChannel): Return null.
	* java/net/ServerSocket.java
	(ch): Removed.
	(setChannel): Removed.
	(implAccept): Use getChannel() instead of ch.
	(close): Likewise.
	(getChannel): Return null.
	* java/net/Socket.java
	(ch): Removed.
	(connect): Use getChannel() instead of ch.
	(setChannel): Removed.
	(getChannel): Return null.

From-SVN: r71516
parent 780071b5
2003-09-18 Michael Koch <konqueror@gmx.de>
* java/net/DatagramSocket.java
(ch): Removed.
(receive): Use getChannel() instead of ch.
(send): Likewise.
(getChannel): Return null.
* java/net/ServerSocket.java
(ch): Removed.
(setChannel): Removed.
(implAccept): Use getChannel() instead of ch.
(close): Likewise.
(getChannel): Return null.
* java/net/Socket.java
(ch): Removed.
(connect): Use getChannel() instead of ch.
(setChannel): Removed.
(getChannel): Return null.
2003-09-18 Mark Wielaard <mark@klomp.org> 2003-09-18 Mark Wielaard <mark@klomp.org>
Reported by Guilhem Lavaux and Julian Dolby Reported by Guilhem Lavaux and Julian Dolby
......
...@@ -75,12 +75,6 @@ public class DatagramSocket ...@@ -75,12 +75,6 @@ public class DatagramSocket
DatagramSocketImpl impl; DatagramSocketImpl impl;
/** /**
* The unique DatagramChannel object associated with this datagram socket,
* or null.
*/
DatagramChannel ch;
/**
* This is the address we are "connected" to * This is the address we are "connected" to
*/ */
private InetAddress remoteAddress; private InetAddress remoteAddress;
...@@ -519,7 +513,8 @@ public class DatagramSocket ...@@ -519,7 +513,8 @@ public class DatagramSocket
throw new IOException ( throw new IOException (
"Socket connected to a multicast address my not receive"); "Socket connected to a multicast address my not receive");
if (ch != null && !ch.isBlocking ()) if (getChannel() != null
&& !getChannel().isBlocking ())
throw new IllegalBlockingModeException (); throw new IllegalBlockingModeException ();
impl.receive(p); impl.receive(p);
...@@ -568,7 +563,8 @@ public class DatagramSocket ...@@ -568,7 +563,8 @@ public class DatagramSocket
// FIXME: if this is a subclass of MulticastSocket, // FIXME: if this is a subclass of MulticastSocket,
// use getTimeToLive for TTL val. // use getTimeToLive for TTL val.
if (ch != null && !ch.isBlocking ()) if (getChannel() != null
&& !getChannel().isBlocking ())
throw new IllegalBlockingModeException (); throw new IllegalBlockingModeException ();
impl.send(p); impl.send(p);
...@@ -618,7 +614,7 @@ public class DatagramSocket ...@@ -618,7 +614,7 @@ public class DatagramSocket
*/ */
public DatagramChannel getChannel() public DatagramChannel getChannel()
{ {
return ch; return null;
} }
/** /**
......
...@@ -73,12 +73,6 @@ public class ServerSocket ...@@ -73,12 +73,6 @@ public class ServerSocket
*/ */
private SocketImpl impl; private SocketImpl impl;
/**
* ServerSocketChannel of this ServerSocket. This channel only exists
* when the socket is created by ServerSocketChannel.open().
*/
private ServerSocketChannel ch;
private boolean closed = false; private boolean closed = false;
/** /**
...@@ -160,14 +154,6 @@ public class ServerSocket ...@@ -160,14 +154,6 @@ public class ServerSocket
bind (new InetSocketAddress (bindAddr, port), backlog); bind (new InetSocketAddress (bindAddr, port), backlog);
} }
/*
* This method may only be used by java.nio.channels.ServerSocketChannel.open.
*/
void setChannel (ServerSocketChannel ch)
{
this.ch = ch;
}
/** /**
* Binds the server socket to a specified socket address * Binds the server socket to a specified socket address
* *
...@@ -318,7 +304,8 @@ public class ServerSocket ...@@ -318,7 +304,8 @@ public class ServerSocket
protected final void implAccept (Socket s) protected final void implAccept (Socket s)
throws IOException throws IOException
{ {
if (ch != null && !ch.isBlocking()) if (getChannel() != null
&& !getChannel().isBlocking())
throw new IllegalBlockingModeException(); throw new IllegalBlockingModeException();
impl.accept(s.impl); impl.accept(s.impl);
...@@ -334,8 +321,8 @@ public class ServerSocket ...@@ -334,8 +321,8 @@ public class ServerSocket
if (impl != null) if (impl != null)
impl.close (); impl.close ();
if (ch != null) if (getChannel() != null)
ch.close (); getChannel().close ();
closed = true; closed = true;
} }
...@@ -351,7 +338,7 @@ public class ServerSocket ...@@ -351,7 +338,7 @@ public class ServerSocket
*/ */
public ServerSocketChannel getChannel() public ServerSocketChannel getChannel()
{ {
return ch; return null;
} }
/** /**
......
...@@ -87,8 +87,6 @@ public class Socket ...@@ -87,8 +87,6 @@ public class Socket
private boolean inputShutdown = false; private boolean inputShutdown = false;
private boolean outputShutdown = false; private boolean outputShutdown = false;
SocketChannel ch; // this field must have been set if created by SocketChannel
private boolean closed = false; private boolean closed = false;
/** /**
...@@ -298,15 +296,6 @@ public class Socket ...@@ -298,15 +296,6 @@ public class Socket
// that default. JDK 1.2 doc infers not to do a bind. // that default. JDK 1.2 doc infers not to do a bind.
} }
/*
* This method may only be used by java.nio.channels.ServerSocketChannel.accept and
* java.nio.channels.SocketChannel.open.
*/
void setChannel (SocketChannel ch)
{
this.ch = ch;
}
/** /**
* Binds the socket to the givent local address/port * Binds the socket to the givent local address/port
* *
...@@ -401,7 +390,8 @@ public class Socket ...@@ -401,7 +390,8 @@ public class Socket
if (! (endpoint instanceof InetSocketAddress)) if (! (endpoint instanceof InetSocketAddress))
throw new IllegalArgumentException ("Address type not supported"); throw new IllegalArgumentException ("Address type not supported");
if (ch != null && !ch.isBlocking ()) if (getChannel() != null
&& !getChannel().isBlocking ())
throw new IllegalBlockingModeException (); throw new IllegalBlockingModeException ();
if (!isBound ()) if (!isBound ())
...@@ -882,8 +872,8 @@ public class Socket ...@@ -882,8 +872,8 @@ public class Socket
if (impl != null) if (impl != null)
impl.close(); impl.close();
if (ch != null) if (getChannel() != null)
ch.close(); getChannel().close();
closed = true; closed = true;
} }
...@@ -970,7 +960,7 @@ public class Socket ...@@ -970,7 +960,7 @@ public class Socket
*/ */
public SocketChannel getChannel() public SocketChannel getChannel()
{ {
return ch; return null;
} }
/** /**
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment