jdk-sandbox: src/java.base/share/classes/sun/nio/ch/SocketChannelImpl.java@ce06058197a4 (annotated)

2 90ce3da70b43 Initial load duke parents: diff changeset	1	/*
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	2	* Copyright (c) 2000, 2018, Oracle and/or its affiliates. All rights reserved.
2 90ce3da70b43 Initial load duke parents: diff changeset	3	* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
90ce3da70b43 Initial load duke parents: diff changeset	4	*
90ce3da70b43 Initial load duke parents: diff changeset	5	* This code is free software; you can redistribute it and/or modify it
90ce3da70b43 Initial load duke parents: diff changeset	6	* under the terms of the GNU General Public License version 2 only, as
5506 202f599c92aa 6943119: Rebrand source copyright notices ohair parents: 2446 diff changeset	7	* published by the Free Software Foundation. Oracle designates this
2 90ce3da70b43 Initial load duke parents: diff changeset	8	* particular file as subject to the "Classpath" exception as provided
5506 202f599c92aa 6943119: Rebrand source copyright notices ohair parents: 2446 diff changeset	9	* by Oracle in the LICENSE file that accompanied this code.
2 90ce3da70b43 Initial load duke parents: diff changeset	10	*
90ce3da70b43 Initial load duke parents: diff changeset	11	* This code is distributed in the hope that it will be useful, but WITHOUT
90ce3da70b43 Initial load duke parents: diff changeset	12	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
90ce3da70b43 Initial load duke parents: diff changeset	13	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
90ce3da70b43 Initial load duke parents: diff changeset	14	* version 2 for more details (a copy is included in the LICENSE file that
90ce3da70b43 Initial load duke parents: diff changeset	15	* accompanied this code).
90ce3da70b43 Initial load duke parents: diff changeset	16	*
90ce3da70b43 Initial load duke parents: diff changeset	17	* You should have received a copy of the GNU General Public License version
90ce3da70b43 Initial load duke parents: diff changeset	18	* 2 along with this work; if not, write to the Free Software Foundation,
90ce3da70b43 Initial load duke parents: diff changeset	19	* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
90ce3da70b43 Initial load duke parents: diff changeset	20	*
5506 202f599c92aa 6943119: Rebrand source copyright notices ohair parents: 2446 diff changeset	21	* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
202f599c92aa 6943119: Rebrand source copyright notices ohair parents: 2446 diff changeset	22	* or visit www.oracle.com if you need additional information or have any
202f599c92aa 6943119: Rebrand source copyright notices ohair parents: 2446 diff changeset	23	* questions.
2 90ce3da70b43 Initial load duke parents: diff changeset	24	*/
90ce3da70b43 Initial load duke parents: diff changeset	25
90ce3da70b43 Initial load duke parents: diff changeset	26	package sun.nio.ch;
90ce3da70b43 Initial load duke parents: diff changeset	27
90ce3da70b43 Initial load duke parents: diff changeset	28	import java.io.FileDescriptor;
90ce3da70b43 Initial load duke parents: diff changeset	29	import java.io.IOException;
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	30	import java.net.InetAddress;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	31	import java.net.InetSocketAddress;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	32	import java.net.ProtocolFamily;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	33	import java.net.Socket;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	34	import java.net.SocketAddress;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	35	import java.net.SocketOption;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	36	import java.net.StandardProtocolFamily;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	37	import java.net.StandardSocketOptions;
2 90ce3da70b43 Initial load duke parents: diff changeset	38	import java.nio.ByteBuffer;
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	39	import java.nio.channels.AlreadyBoundException;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	40	import java.nio.channels.AlreadyConnectedException;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	41	import java.nio.channels.AsynchronousCloseException;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	42	import java.nio.channels.ClosedChannelException;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	43	import java.nio.channels.ConnectionPendingException;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	44	import java.nio.channels.NoConnectionPendingException;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	45	import java.nio.channels.NotYetConnectedException;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	46	import java.nio.channels.SelectionKey;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	47	import java.nio.channels.SocketChannel;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	48	import java.nio.channels.spi.SelectorProvider;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	49	import java.util.Collections;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	50	import java.util.HashSet;
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	51	import java.util.Objects;
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	52	import java.util.Set;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	53	import java.util.concurrent.locks.ReentrantLock;
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	54
2446 07047237e4d4 4890703: Support SDP (sol) alanb parents: 2057 diff changeset	55	import sun.net.NetHooks;
37676 24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module chegar parents: 36115 diff changeset	56	import sun.net.ext.ExtendedSocketOptions;
2 90ce3da70b43 Initial load duke parents: diff changeset	57
90ce3da70b43 Initial load duke parents: diff changeset	58	/**
90ce3da70b43 Initial load duke parents: diff changeset	59	* An implementation of SocketChannels
90ce3da70b43 Initial load duke parents: diff changeset	60	*/
90ce3da70b43 Initial load duke parents: diff changeset	61
90ce3da70b43 Initial load duke parents: diff changeset	62	class SocketChannelImpl
90ce3da70b43 Initial load duke parents: diff changeset	63	extends SocketChannel
90ce3da70b43 Initial load duke parents: diff changeset	64	implements SelChImpl
90ce3da70b43 Initial load duke parents: diff changeset	65	{
90ce3da70b43 Initial load duke parents: diff changeset	66	// Used to make native read and write calls
90ce3da70b43 Initial load duke parents: diff changeset	67	private static NativeDispatcher nd;
90ce3da70b43 Initial load duke parents: diff changeset	68
90ce3da70b43 Initial load duke parents: diff changeset	69	// Our file descriptor object
90ce3da70b43 Initial load duke parents: diff changeset	70	private final FileDescriptor fd;
90ce3da70b43 Initial load duke parents: diff changeset	71	private final int fdVal;
90ce3da70b43 Initial load duke parents: diff changeset	72
90ce3da70b43 Initial load duke parents: diff changeset	73	// Lock held by current reading or connecting thread
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	74	private final ReentrantLock readLock = new ReentrantLock();
2 90ce3da70b43 Initial load duke parents: diff changeset	75
90ce3da70b43 Initial load duke parents: diff changeset	76	// Lock held by current writing or connecting thread
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	77	private final ReentrantLock writeLock = new ReentrantLock();
2 90ce3da70b43 Initial load duke parents: diff changeset	78
90ce3da70b43 Initial load duke parents: diff changeset	79	// Lock held by any thread that modifies the state fields declared below
90ce3da70b43 Initial load duke parents: diff changeset	80	// DO NOT invoke a blocking I/O operation while holding this lock!
90ce3da70b43 Initial load duke parents: diff changeset	81	private final Object stateLock = new Object();
90ce3da70b43 Initial load duke parents: diff changeset	82
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	83	// Input/Output closed
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	84	private volatile boolean isInputClosed;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	85	private volatile boolean isOutputClosed;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	86
2 90ce3da70b43 Initial load duke parents: diff changeset	87	// -- The following fields are protected by stateLock
90ce3da70b43 Initial load duke parents: diff changeset	88
18192 fa6bd0992104 7170730: Improve Windows network stack support. khazra parents: 16921 diff changeset	89	// set true when exclusive binding is on and SO_REUSEADDR is emulated
fa6bd0992104 7170730: Improve Windows network stack support. khazra parents: 16921 diff changeset	90	private boolean isReuseAddress;
fa6bd0992104 7170730: Improve Windows network stack support. khazra parents: 16921 diff changeset	91
2 90ce3da70b43 Initial load duke parents: diff changeset	92	// State, increases monotonically
90ce3da70b43 Initial load duke parents: diff changeset	93	private static final int ST_UNCONNECTED = 0;
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	94	private static final int ST_CONNECTIONPENDING = 1;
2 90ce3da70b43 Initial load duke parents: diff changeset	95	private static final int ST_CONNECTED = 2;
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	96	private static final int ST_CLOSING = 3;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	97	private static final int ST_KILLPENDING = 4;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	98	private static final int ST_KILLED = 5;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	99	private int state;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	100
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	101	// IDs of native threads doing reads and writes, for signalling
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	102	private long readerThread;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	103	private long writerThread;
2 90ce3da70b43 Initial load duke parents: diff changeset	104
90ce3da70b43 Initial load duke parents: diff changeset	105	// Binding
18212 22f8c33b0690 8001318: Socket.getLocalAddress not consistent with InetAddress.getLocalHost khazra parents: 18192 diff changeset	106	private InetSocketAddress localAddress;
22f8c33b0690 8001318: Socket.getLocalAddress not consistent with InetAddress.getLocalHost khazra parents: 18192 diff changeset	107	private InetSocketAddress remoteAddress;
2 90ce3da70b43 Initial load duke parents: diff changeset	108
90ce3da70b43 Initial load duke parents: diff changeset	109	// Socket adaptor, created on demand
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	110	private Socket socket;
2 90ce3da70b43 Initial load duke parents: diff changeset	111
90ce3da70b43 Initial load duke parents: diff changeset	112	// -- End of fields protected by stateLock
90ce3da70b43 Initial load duke parents: diff changeset	113
90ce3da70b43 Initial load duke parents: diff changeset	114
90ce3da70b43 Initial load duke parents: diff changeset	115	// Constructor for normal connecting sockets
90ce3da70b43 Initial load duke parents: diff changeset	116	//
90ce3da70b43 Initial load duke parents: diff changeset	117	SocketChannelImpl(SelectorProvider sp) throws IOException {
90ce3da70b43 Initial load duke parents: diff changeset	118	super(sp);
90ce3da70b43 Initial load duke parents: diff changeset	119	this.fd = Net.socket(true);
90ce3da70b43 Initial load duke parents: diff changeset	120	this.fdVal = IOUtil.fdVal(fd);
90ce3da70b43 Initial load duke parents: diff changeset	121	}
90ce3da70b43 Initial load duke parents: diff changeset	122
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	123	SocketChannelImpl(SelectorProvider sp, FileDescriptor fd, boolean bound)
6525 56be41b86ef8 6965072: Need API to create SDP sockets alanb parents: 6301 diff changeset	124	throws IOException
56be41b86ef8 6965072: Need API to create SDP sockets alanb parents: 6301 diff changeset	125	{
56be41b86ef8 6965072: Need API to create SDP sockets alanb parents: 6301 diff changeset	126	super(sp);
56be41b86ef8 6965072: Need API to create SDP sockets alanb parents: 6301 diff changeset	127	this.fd = fd;
56be41b86ef8 6965072: Need API to create SDP sockets alanb parents: 6301 diff changeset	128	this.fdVal = IOUtil.fdVal(fd);
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	129	if (bound) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	130	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	131	this.localAddress = Net.localAddress(fd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	132	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	133	}
6525 56be41b86ef8 6965072: Need API to create SDP sockets alanb parents: 6301 diff changeset	134	}
56be41b86ef8 6965072: Need API to create SDP sockets alanb parents: 6301 diff changeset	135
2 90ce3da70b43 Initial load duke parents: diff changeset	136	// Constructor for sockets obtained from server sockets
90ce3da70b43 Initial load duke parents: diff changeset	137	//
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	138	SocketChannelImpl(SelectorProvider sp, FileDescriptor fd, InetSocketAddress isa)
2 90ce3da70b43 Initial load duke parents: diff changeset	139	throws IOException
90ce3da70b43 Initial load duke parents: diff changeset	140	{
90ce3da70b43 Initial load duke parents: diff changeset	141	super(sp);
90ce3da70b43 Initial load duke parents: diff changeset	142	this.fd = fd;
90ce3da70b43 Initial load duke parents: diff changeset	143	this.fdVal = IOUtil.fdVal(fd);
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	144	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	145	this.localAddress = Net.localAddress(fd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	146	this.remoteAddress = isa;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	147	this.state = ST_CONNECTED;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	148	}
2 90ce3da70b43 Initial load duke parents: diff changeset	149	}
90ce3da70b43 Initial load duke parents: diff changeset	150
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	151	// @throws ClosedChannelException if channel is closed
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	152	private void ensureOpen() throws ClosedChannelException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	153	if (!isOpen())
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	154	throw new ClosedChannelException();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	155	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	156
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	157	@Override
2 90ce3da70b43 Initial load duke parents: diff changeset	158	public Socket socket() {
90ce3da70b43 Initial load duke parents: diff changeset	159	synchronized (stateLock) {
90ce3da70b43 Initial load duke parents: diff changeset	160	if (socket == null)
90ce3da70b43 Initial load duke parents: diff changeset	161	socket = SocketAdaptor.create(this);
90ce3da70b43 Initial load duke parents: diff changeset	162	return socket;
90ce3da70b43 Initial load duke parents: diff changeset	163	}
90ce3da70b43 Initial load duke parents: diff changeset	164	}
90ce3da70b43 Initial load duke parents: diff changeset	165
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	166	@Override
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	167	public SocketAddress getLocalAddress() throws IOException {
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	168	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	169	ensureOpen();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	170	return Net.getRevealedLocalAddress(localAddress);
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	171	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	172	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	173
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	174	@Override
2057 3acf8e5e2ca0 6781363: New I/O: Update socket-channel API to jsr203/nio2-b99 alanb parents: 1247 diff changeset	175	public SocketAddress getRemoteAddress() throws IOException {
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	176	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	177	ensureOpen();
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	178	return remoteAddress;
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	179	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	180	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	181
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	182	@Override
2057 3acf8e5e2ca0 6781363: New I/O: Update socket-channel API to jsr203/nio2-b99 alanb parents: 1247 diff changeset	183	public <T> SocketChannel setOption(SocketOption<T> name, T value)
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	184	throws IOException
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	185	{
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	186	Objects.requireNonNull(name);
2057 3acf8e5e2ca0 6781363: New I/O: Update socket-channel API to jsr203/nio2-b99 alanb parents: 1247 diff changeset	187	if (!supportedOptions().contains(name))
3acf8e5e2ca0 6781363: New I/O: Update socket-channel API to jsr203/nio2-b99 alanb parents: 1247 diff changeset	188	throw new UnsupportedOperationException("'" + name + "' not supported");
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	189
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	190	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	191	ensureOpen();
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	192
9679 d98ae8bc45fc 7042979: Rename StandardSocketOption and StandardWatchEventKind alanb parents: 7668 diff changeset	193	if (name == StandardSocketOptions.IP_TOS) {
25170 f58832169add 8029607: Type of Service (TOS) cannot be set in IPv6 header michaelm parents: 24969 diff changeset	194	ProtocolFamily family = Net.isIPv6Available() ?
f58832169add 8029607: Type of Service (TOS) cannot be set in IPv6 header michaelm parents: 24969 diff changeset	195	StandardProtocolFamily.INET6 : StandardProtocolFamily.INET;
f58832169add 8029607: Type of Service (TOS) cannot be set in IPv6 header michaelm parents: 24969 diff changeset	196	Net.setSocketOption(fd, family, name, value);
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	197	return this;
25170 f58832169add 8029607: Type of Service (TOS) cannot be set in IPv6 header michaelm parents: 24969 diff changeset	198	}
f58832169add 8029607: Type of Service (TOS) cannot be set in IPv6 header michaelm parents: 24969 diff changeset	199
f58832169add 8029607: Type of Service (TOS) cannot be set in IPv6 header michaelm parents: 24969 diff changeset	200	if (name == StandardSocketOptions.SO_REUSEADDR && Net.useExclusiveBind()) {
18192 fa6bd0992104 7170730: Improve Windows network stack support. khazra parents: 16921 diff changeset	201	// SO_REUSEADDR emulated when using exclusive bind
fa6bd0992104 7170730: Improve Windows network stack support. khazra parents: 16921 diff changeset	202	isReuseAddress = (Boolean)value;
fa6bd0992104 7170730: Improve Windows network stack support. khazra parents: 16921 diff changeset	203	return this;
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	204	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	205
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	206	// no options that require special handling
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	207	Net.setSocketOption(fd, Net.UNSPEC, name, value);
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	208	return this;
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	209	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	210	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	211
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	212	@Override
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	213	@SuppressWarnings("unchecked")
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	214	public <T> T getOption(SocketOption<T> name)
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	215	throws IOException
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	216	{
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	217	Objects.requireNonNull(name);
2057 3acf8e5e2ca0 6781363: New I/O: Update socket-channel API to jsr203/nio2-b99 alanb parents: 1247 diff changeset	218	if (!supportedOptions().contains(name))
3acf8e5e2ca0 6781363: New I/O: Update socket-channel API to jsr203/nio2-b99 alanb parents: 1247 diff changeset	219	throw new UnsupportedOperationException("'" + name + "' not supported");
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	220
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	221	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	222	ensureOpen();
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	223
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	224	if (name == StandardSocketOptions.SO_REUSEADDR && Net.useExclusiveBind()) {
18192 fa6bd0992104 7170730: Improve Windows network stack support. khazra parents: 16921 diff changeset	225	// SO_REUSEADDR emulated when using exclusive bind
fa6bd0992104 7170730: Improve Windows network stack support. khazra parents: 16921 diff changeset	226	return (T)Boolean.valueOf(isReuseAddress);
fa6bd0992104 7170730: Improve Windows network stack support. khazra parents: 16921 diff changeset	227	}
fa6bd0992104 7170730: Improve Windows network stack support. khazra parents: 16921 diff changeset	228
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	229	// special handling for IP_TOS: always return 0 when IPv6
9679 d98ae8bc45fc 7042979: Rename StandardSocketOption and StandardWatchEventKind alanb parents: 7668 diff changeset	230	if (name == StandardSocketOptions.IP_TOS) {
25170 f58832169add 8029607: Type of Service (TOS) cannot be set in IPv6 header michaelm parents: 24969 diff changeset	231	ProtocolFamily family = Net.isIPv6Available() ?
f58832169add 8029607: Type of Service (TOS) cannot be set in IPv6 header michaelm parents: 24969 diff changeset	232	StandardProtocolFamily.INET6 : StandardProtocolFamily.INET;
f58832169add 8029607: Type of Service (TOS) cannot be set in IPv6 header michaelm parents: 24969 diff changeset	233	return (T) Net.getSocketOption(fd, family, name);
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	234	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	235
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	236	// no options that require special handling
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	237	return (T) Net.getSocketOption(fd, Net.UNSPEC, name);
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	238	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	239	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	240
2057 3acf8e5e2ca0 6781363: New I/O: Update socket-channel API to jsr203/nio2-b99 alanb parents: 1247 diff changeset	241	private static class DefaultOptionsHolder {
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	242	static final Set<SocketOption<?>> defaultOptions = defaultOptions();
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	243
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	244	private static Set<SocketOption<?>> defaultOptions() {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	245	HashSet<SocketOption<?>> set = new HashSet<>();
9679 d98ae8bc45fc 7042979: Rename StandardSocketOption and StandardWatchEventKind alanb parents: 7668 diff changeset	246	set.add(StandardSocketOptions.SO_SNDBUF);
d98ae8bc45fc 7042979: Rename StandardSocketOption and StandardWatchEventKind alanb parents: 7668 diff changeset	247	set.add(StandardSocketOptions.SO_RCVBUF);
d98ae8bc45fc 7042979: Rename StandardSocketOption and StandardWatchEventKind alanb parents: 7668 diff changeset	248	set.add(StandardSocketOptions.SO_KEEPALIVE);
d98ae8bc45fc 7042979: Rename StandardSocketOption and StandardWatchEventKind alanb parents: 7668 diff changeset	249	set.add(StandardSocketOptions.SO_REUSEADDR);
36115 0676e37a0b9c 6432031: Add support for SO_REUSEPORT alanb parents: 34774 diff changeset	250	if (Net.isReusePortAvailable()) {
0676e37a0b9c 6432031: Add support for SO_REUSEPORT alanb parents: 34774 diff changeset	251	set.add(StandardSocketOptions.SO_REUSEPORT);
0676e37a0b9c 6432031: Add support for SO_REUSEPORT alanb parents: 34774 diff changeset	252	}
9679 d98ae8bc45fc 7042979: Rename StandardSocketOption and StandardWatchEventKind alanb parents: 7668 diff changeset	253	set.add(StandardSocketOptions.SO_LINGER);
d98ae8bc45fc 7042979: Rename StandardSocketOption and StandardWatchEventKind alanb parents: 7668 diff changeset	254	set.add(StandardSocketOptions.TCP_NODELAY);
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	255	// additional options required by socket adaptor
9679 d98ae8bc45fc 7042979: Rename StandardSocketOption and StandardWatchEventKind alanb parents: 7668 diff changeset	256	set.add(StandardSocketOptions.IP_TOS);
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	257	set.add(ExtendedSocketOption.SO_OOBINLINE);
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	258	set.addAll(ExtendedSocketOptions.getInstance().options());
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	259	return Collections.unmodifiableSet(set);
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	260	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	261	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	262
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	263	@Override
2057 3acf8e5e2ca0 6781363: New I/O: Update socket-channel API to jsr203/nio2-b99 alanb parents: 1247 diff changeset	264	public final Set<SocketOption<?>> supportedOptions() {
3acf8e5e2ca0 6781363: New I/O: Update socket-channel API to jsr203/nio2-b99 alanb parents: 1247 diff changeset	265	return DefaultOptionsHolder.defaultOptions;
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	266	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	267
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	268	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	269	* Marks the beginning of a read operation that might block.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	270	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	271	* @throws ClosedChannelException if the channel is closed
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	272	* @throws NotYetConnectedException if the channel is not yet connected
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	273	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	274	private void beginRead(boolean blocking) throws ClosedChannelException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	275	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	276	// set hook for Thread.interrupt
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	277	begin();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	278	}
2 90ce3da70b43 Initial load duke parents: diff changeset	279	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	280	ensureOpen();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	281	if (state != ST_CONNECTED)
2 90ce3da70b43 Initial load duke parents: diff changeset	282	throw new NotYetConnectedException();
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	283	if (blocking)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	284	readerThread = NativeThread.current();
2 90ce3da70b43 Initial load duke parents: diff changeset	285	}
90ce3da70b43 Initial load duke parents: diff changeset	286	}
90ce3da70b43 Initial load duke parents: diff changeset	287
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	288	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	289	* Marks the end of a read operation that may have blocked.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	290	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	291	* @throws AsynchronousCloseException if the channel was closed due to this
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	292	* thread being interrupted on a blocking read operation.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	293	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	294	private void endRead(boolean blocking, boolean completed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	295	throws AsynchronousCloseException
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	296	{
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	297	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	298	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	299	readerThread = 0;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	300	// notify any thread waiting in implCloseSelectableChannel
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	301	if (state == ST_CLOSING) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	302	stateLock.notifyAll();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	303	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	304	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	305	// remove hook for Thread.interrupt
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	306	end(completed);
2 90ce3da70b43 Initial load duke parents: diff changeset	307	}
90ce3da70b43 Initial load duke parents: diff changeset	308	}
90ce3da70b43 Initial load duke parents: diff changeset	309
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	310	@Override
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	311	public int read(ByteBuffer buf) throws IOException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	312	Objects.requireNonNull(buf);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	313
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	314	readLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	315	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	316	boolean blocking = isBlocking();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	317	int n = 0;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	318	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	319	beginRead(blocking);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	320
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	321	// check if input is shutdown
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	322	if (isInputClosed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	323	return IOStatus.EOF;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	324
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	325	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	326	do {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	327	n = IOUtil.read(fd, buf, -1, nd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	328	} while (n == IOStatus.INTERRUPTED && isOpen());
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	329	} else {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	330	n = IOUtil.read(fd, buf, -1, nd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	331	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	332	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	333	endRead(blocking, n > 0);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	334	if (n <= 0 && isInputClosed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	335	return IOStatus.EOF;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	336	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	337	return IOStatus.normalize(n);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	338	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	339	readLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	340	}
90ce3da70b43 Initial load duke parents: diff changeset	341	}
90ce3da70b43 Initial load duke parents: diff changeset	342
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	343	@Override
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	344	public long read(ByteBuffer[] dsts, int offset, int length)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	345	throws IOException
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	346	{
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	347	Objects.checkFromIndexSize(offset, length, dsts.length);
2 90ce3da70b43 Initial load duke parents: diff changeset	348
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	349	readLock.lock();
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	350	try {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	351	boolean blocking = isBlocking();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	352	long n = 0;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	353	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	354	beginRead(blocking);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	355
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	356	// check if input is shutdown
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	357	if (isInputClosed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	358	return IOStatus.EOF;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	359
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	360	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	361	do {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	362	n = IOUtil.read(fd, dsts, offset, length, nd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	363	} while (n == IOStatus.INTERRUPTED && isOpen());
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	364	} else {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	365	n = IOUtil.read(fd, dsts, offset, length, nd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	366	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	367	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	368	endRead(blocking, n > 0);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	369	if (n <= 0 && isInputClosed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	370	return IOStatus.EOF;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	371	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	372	return IOStatus.normalize(n);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	373	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	374	readLock.unlock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	375	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	376	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	377
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	378	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	379	* Marks the beginning of a write operation that might block.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	380	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	381	* @throws ClosedChannelException if the channel is closed or output shutdown
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	382	* @throws NotYetConnectedException if the channel is not yet connected
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	383	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	384	private void beginWrite(boolean blocking) throws ClosedChannelException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	385	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	386	// set hook for Thread.interrupt
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	387	begin();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	388	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	389	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	390	ensureOpen();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	391	if (isOutputClosed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	392	throw new ClosedChannelException();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	393	if (state != ST_CONNECTED)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	394	throw new NotYetConnectedException();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	395	if (blocking)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	396	writerThread = NativeThread.current();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	397	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	398	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	399
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	400	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	401	* Marks the end of a write operation that may have blocked.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	402	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	403	* @throws AsynchronousCloseException if the channel was closed due to this
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	404	* thread being interrupted on a blocking write operation.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	405	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	406	private void endWrite(boolean blocking, boolean completed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	407	throws AsynchronousCloseException
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	408	{
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	409	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	410	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	411	writerThread = 0;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	412	// notify any thread waiting in implCloseSelectableChannel
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	413	if (state == ST_CLOSING) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	414	stateLock.notifyAll();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	415	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	416	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	417	// remove hook for Thread.interrupt
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	418	end(completed);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	419	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	420	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	421
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	422	@Override
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	423	public int write(ByteBuffer buf) throws IOException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	424	Objects.requireNonNull(buf);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	425
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	426	writeLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	427	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	428	boolean blocking = isBlocking();
2 90ce3da70b43 Initial load duke parents: diff changeset	429	int n = 0;
90ce3da70b43 Initial load duke parents: diff changeset	430	try {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	431	beginWrite(blocking);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	432	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	433	do {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	434	n = IOUtil.write(fd, buf, -1, nd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	435	} while (n == IOStatus.INTERRUPTED && isOpen());
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	436	} else {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	437	n = IOUtil.write(fd, buf, -1, nd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	438	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	439	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	440	endWrite(blocking, n > 0);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	441	if (n <= 0 && isOutputClosed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	442	throw new AsynchronousCloseException();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	443	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	444	return IOStatus.normalize(n);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	445	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	446	writeLock.unlock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	447	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	448	}
2 90ce3da70b43 Initial load duke parents: diff changeset	449
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	450	@Override
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	451	public long write(ByteBuffer[] srcs, int offset, int length)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	452	throws IOException
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	453	{
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	454	Objects.checkFromIndexSize(offset, length, srcs.length);
2 90ce3da70b43 Initial load duke parents: diff changeset	455
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	456	writeLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	457	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	458	boolean blocking = isBlocking();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	459	long n = 0;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	460	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	461	beginWrite(blocking);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	462	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	463	do {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	464	n = IOUtil.write(fd, srcs, offset, length, nd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	465	} while (n == IOStatus.INTERRUPTED && isOpen());
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	466	} else {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	467	n = IOUtil.write(fd, srcs, offset, length, nd);
2 90ce3da70b43 Initial load duke parents: diff changeset	468	}
90ce3da70b43 Initial load duke parents: diff changeset	469	} finally {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	470	endWrite(blocking, n > 0);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	471	if (n <= 0 && isOutputClosed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	472	throw new AsynchronousCloseException();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	473	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	474	return IOStatus.normalize(n);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	475	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	476	writeLock.unlock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	477	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	478	}
2 90ce3da70b43 Initial load duke parents: diff changeset	479
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	480	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	481	* Writes a byte of out of band data.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	482	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	483	int sendOutOfBandData(byte b) throws IOException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	484	writeLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	485	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	486	boolean blocking = isBlocking();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	487	int n = 0;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	488	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	489	beginWrite(blocking);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	490	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	491	do {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	492	n = sendOutOfBandData(fd, b);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	493	} while (n == IOStatus.INTERRUPTED && isOpen());
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	494	} else {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	495	n = sendOutOfBandData(fd, b);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	496	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	497	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	498	endWrite(blocking, n > 0);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	499	if (n <= 0 && isOutputClosed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	500	throw new AsynchronousCloseException();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	501	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	502	return IOStatus.normalize(n);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	503	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	504	writeLock.unlock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	505	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	506	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	507
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	508	@Override
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	509	protected void implConfigureBlocking(boolean block) throws IOException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	510	readLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	511	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	512	writeLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	513	try {
2 90ce3da70b43 Initial load duke parents: diff changeset	514	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	515	ensureOpen();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	516	IOUtil.configureBlocking(fd, block);
2 90ce3da70b43 Initial load duke parents: diff changeset	517	}
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	518	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	519	writeLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	520	}
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	521	} finally {
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	522	readLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	523	}
90ce3da70b43 Initial load duke parents: diff changeset	524	}
90ce3da70b43 Initial load duke parents: diff changeset	525
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	526	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	527	* Returns the local address, or null if not bound
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	528	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	529	InetSocketAddress localAddress() {
2 90ce3da70b43 Initial load duke parents: diff changeset	530	synchronized (stateLock) {
90ce3da70b43 Initial load duke parents: diff changeset	531	return localAddress;
90ce3da70b43 Initial load duke parents: diff changeset	532	}
90ce3da70b43 Initial load duke parents: diff changeset	533	}
90ce3da70b43 Initial load duke parents: diff changeset	534
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	535	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	536	* Returns the remote address, or null if not connected
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	537	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	538	InetSocketAddress remoteAddress() {
2 90ce3da70b43 Initial load duke parents: diff changeset	539	synchronized (stateLock) {
90ce3da70b43 Initial load duke parents: diff changeset	540	return remoteAddress;
90ce3da70b43 Initial load duke parents: diff changeset	541	}
90ce3da70b43 Initial load duke parents: diff changeset	542	}
90ce3da70b43 Initial load duke parents: diff changeset	543
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	544	@Override
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	545	public SocketChannel bind(SocketAddress local) throws IOException {
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	546	readLock.lock();
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	547	try {
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	548	writeLock.lock();
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	549	try {
2 90ce3da70b43 Initial load duke parents: diff changeset	550	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	551	ensureOpen();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	552	if (state == ST_CONNECTIONPENDING)
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	553	throw new ConnectionPendingException();
2 90ce3da70b43 Initial load duke parents: diff changeset	554	if (localAddress != null)
90ce3da70b43 Initial load duke parents: diff changeset	555	throw new AlreadyBoundException();
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	556	InetSocketAddress isa = (local == null) ?
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	557	new InetSocketAddress(0) : Net.checkAddress(local);
22339 e91bfaf4360d 8011786: Better applet networking michaelm parents: 19607 diff changeset	558	SecurityManager sm = System.getSecurityManager();
e91bfaf4360d 8011786: Better applet networking michaelm parents: 19607 diff changeset	559	if (sm != null) {
e91bfaf4360d 8011786: Better applet networking michaelm parents: 19607 diff changeset	560	sm.checkListen(isa.getPort());
e91bfaf4360d 8011786: Better applet networking michaelm parents: 19607 diff changeset	561	}
2446 07047237e4d4 4890703: Support SDP (sol) alanb parents: 2057 diff changeset	562	NetHooks.beforeTcpBind(fd, isa.getAddress(), isa.getPort());
2 90ce3da70b43 Initial load duke parents: diff changeset	563	Net.bind(fd, isa.getAddress(), isa.getPort());
90ce3da70b43 Initial load duke parents: diff changeset	564	localAddress = Net.localAddress(fd);
90ce3da70b43 Initial load duke parents: diff changeset	565	}
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	566	} finally {
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	567	writeLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	568	}
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	569	} finally {
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	570	readLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	571	}
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	572	return this;
2 90ce3da70b43 Initial load duke parents: diff changeset	573	}
90ce3da70b43 Initial load duke parents: diff changeset	574
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	575	@Override
2 90ce3da70b43 Initial load duke parents: diff changeset	576	public boolean isConnected() {
90ce3da70b43 Initial load duke parents: diff changeset	577	synchronized (stateLock) {
90ce3da70b43 Initial load duke parents: diff changeset	578	return (state == ST_CONNECTED);
90ce3da70b43 Initial load duke parents: diff changeset	579	}
90ce3da70b43 Initial load duke parents: diff changeset	580	}
90ce3da70b43 Initial load duke parents: diff changeset	581
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	582	@Override
2 90ce3da70b43 Initial load duke parents: diff changeset	583	public boolean isConnectionPending() {
90ce3da70b43 Initial load duke parents: diff changeset	584	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	585	return (state == ST_CONNECTIONPENDING);
2 90ce3da70b43 Initial load duke parents: diff changeset	586	}
90ce3da70b43 Initial load duke parents: diff changeset	587	}
90ce3da70b43 Initial load duke parents: diff changeset	588
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	589	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	590	* Marks the beginning of a connect operation that might block.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	591	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	592	* @throws ClosedChannelException if the channel is closed
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	593	* @throws AlreadyConnectedException if already connected
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	594	* @throws ConnectionPendingException is a connection is pending
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	595	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	596	private void beginConnect(boolean blocking) throws ClosedChannelException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	597	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	598	// set hook for Thread.interrupt
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	599	begin();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	600	}
2 90ce3da70b43 Initial load duke parents: diff changeset	601	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	602	ensureOpen();
2 90ce3da70b43 Initial load duke parents: diff changeset	603	if (state == ST_CONNECTED)
90ce3da70b43 Initial load duke parents: diff changeset	604	throw new AlreadyConnectedException();
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	605	if (state == ST_CONNECTIONPENDING)
2 90ce3da70b43 Initial load duke parents: diff changeset	606	throw new ConnectionPendingException();
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	607	if (blocking)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	608	readerThread = NativeThread.current();
2 90ce3da70b43 Initial load duke parents: diff changeset	609	}
90ce3da70b43 Initial load duke parents: diff changeset	610	}
90ce3da70b43 Initial load duke parents: diff changeset	611
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	612	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	613	* Marks the end of a connect operation that may have blocked.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	614	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	615	* @throws AsynchronousCloseException if the channel was closed due to this
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	616	* thread being interrupted on a blocking connect operation.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	617	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	618	private void endConnect(boolean blocking, boolean completed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	619	throws AsynchronousCloseException
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	620	{
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	621	endRead(blocking, completed);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	622	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	623
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	624	@Override
2 90ce3da70b43 Initial load duke parents: diff changeset	625	public boolean connect(SocketAddress sa) throws IOException {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	626	InetSocketAddress isa = Net.checkAddress(sa);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	627	SecurityManager sm = System.getSecurityManager();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	628	if (sm != null)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	629	sm.checkConnect(isa.getAddress().getHostAddress(), isa.getPort());
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	630
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	631	readLock.lock();
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	632	try {
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	633	writeLock.lock();
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	634	try {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	635	// notify before-connect hook
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	636	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	637	if (state == ST_UNCONNECTED && localAddress == null) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	638	NetHooks.beforeTcpConnect(fd, isa.getAddress(), isa.getPort());
2 90ce3da70b43 Initial load duke parents: diff changeset	639	}
90ce3da70b43 Initial load duke parents: diff changeset	640	}
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	641
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	642	InetAddress ia = isa.getAddress();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	643	if (ia.isAnyLocalAddress())
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	644	ia = InetAddress.getLocalHost();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	645
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	646	int n = 0;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	647	boolean blocking = isBlocking();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	648	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	649	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	650	beginConnect(blocking);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	651	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	652	do {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	653	n = Net.connect(fd, ia, isa.getPort());
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	654	} while (n == IOStatus.INTERRUPTED && isOpen());
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	655	} else {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	656	n = Net.connect(fd, ia, isa.getPort());
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	657	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	658	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	659	endConnect(blocking, n > 0);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	660	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	661	} catch (IOException x) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	662	// connect failed, close socket
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	663	close();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	664	throw x;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	665	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	666
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	667	// connection may be established
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	668	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	669	if (!isOpen())
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	670	throw new AsynchronousCloseException();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	671	remoteAddress = isa;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	672	if (n > 0) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	673	// connected established
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	674	localAddress = Net.localAddress(fd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	675	state = ST_CONNECTED;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	676	return true;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	677	} else {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	678	// connection pending
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	679	assert !blocking;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	680	state = ST_CONNECTIONPENDING;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	681	return false;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	682	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	683	}
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	684	} finally {
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	685	writeLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	686	}
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	687	} finally {
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	688	readLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	689	}
90ce3da70b43 Initial load duke parents: diff changeset	690	}
90ce3da70b43 Initial load duke parents: diff changeset	691
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	692	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	693	* Marks the beginning of a finishConnect operation that might block.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	694	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	695	* @throws ClosedChannelException if the channel is closed
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	696	* @throws NoConnectionPendingException if no connection is pending
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	697	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	698	private void beginFinishConnect(boolean blocking) throws ClosedChannelException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	699	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	700	// set hook for Thread.interrupt
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	701	begin();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	702	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	703	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	704	ensureOpen();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	705	if (state != ST_CONNECTIONPENDING)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	706	throw new NoConnectionPendingException();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	707	if (blocking)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	708	readerThread = NativeThread.current();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	709	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	710	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	711
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	712	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	713	* Marks the end of a finishConnect operation that may have blocked.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	714	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	715	* @throws AsynchronousCloseException if the channel was closed due to this
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	716	* thread being interrupted on a blocking connect operation.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	717	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	718	private void endFinishConnect(boolean blocking, boolean completed)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	719	throws AsynchronousCloseException
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	720	{
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	721	endRead(blocking, completed);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	722	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	723
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	724	@Override
2 90ce3da70b43 Initial load duke parents: diff changeset	725	public boolean finishConnect() throws IOException {
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	726	readLock.lock();
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	727	try {
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	728	writeLock.lock();
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	729	try {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	730	// already connected?
2 90ce3da70b43 Initial load duke parents: diff changeset	731	synchronized (stateLock) {
90ce3da70b43 Initial load duke parents: diff changeset	732	if (state == ST_CONNECTED)
90ce3da70b43 Initial load duke parents: diff changeset	733	return true;
90ce3da70b43 Initial load duke parents: diff changeset	734	}
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	735
2 90ce3da70b43 Initial load duke parents: diff changeset	736	int n = 0;
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	737	boolean blocking = isBlocking();
2 90ce3da70b43 Initial load duke parents: diff changeset	738	try {
90ce3da70b43 Initial load duke parents: diff changeset	739	try {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	740	beginFinishConnect(blocking);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	741	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	742	do {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	743	n = checkConnect(fd, true);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	744	} while (n == 0 \|\| (n == IOStatus.INTERRUPTED) && isOpen());
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	745	} else {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	746	n = checkConnect(fd, false);
2 90ce3da70b43 Initial load duke parents: diff changeset	747	}
90ce3da70b43 Initial load duke parents: diff changeset	748	} finally {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	749	endFinishConnect(blocking, n > 0);
2 90ce3da70b43 Initial load duke parents: diff changeset	750	}
90ce3da70b43 Initial load duke parents: diff changeset	751	} catch (IOException x) {
90ce3da70b43 Initial load duke parents: diff changeset	752	close();
90ce3da70b43 Initial load duke parents: diff changeset	753	throw x;
90ce3da70b43 Initial load duke parents: diff changeset	754	}
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	755
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	756	// post finishConnect, connection may be established
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	757	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	758	if (!isOpen())
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	759	throw new AsynchronousCloseException();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	760	if (n > 0) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	761	// connection established
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	762	localAddress = Net.localAddress(fd);
2 90ce3da70b43 Initial load duke parents: diff changeset	763	state = ST_CONNECTED;
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	764	return true;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	765	} else {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	766	// connection still pending
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	767	assert !blocking;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	768	return false;
2 90ce3da70b43 Initial load duke parents: diff changeset	769	}
90ce3da70b43 Initial load duke parents: diff changeset	770	}
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	771	} finally {
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	772	writeLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	773	}
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	774	} finally {
ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	775	readLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	776	}
90ce3da70b43 Initial load duke parents: diff changeset	777	}
90ce3da70b43 Initial load duke parents: diff changeset	778
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	779	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	780	* Invoked by implCloseChannel to close the channel.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	781	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	782	* This method waits for outstanding I/O operations to complete. When in
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	783	* blocking mode, the socket is pre-closed and the threads in blocking I/O
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	784	* operations are signalled to ensure that the outstanding I/O operations
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	785	* complete quickly.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	786	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	787	* If the socket is connected then it is shutdown by this method. The
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	788	* shutdown ensures that the peer reads EOF for the case that the socket is
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	789	* not pre-closed or closed by this method.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	790	*
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	791	* The socket is closed by this method when it is not registered with a
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	792	* Selector. Note that a channel configured blocking may be registered with
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	793	* a Selector. This arises when a key is canceled and the channel configured
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	794	* to blocking mode before the key is flushed from the Selector.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	795	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	796	@Override
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	797	protected void implCloseSelectableChannel() throws IOException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	798	assert !isOpen();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	799
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	800	boolean blocking;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	801	boolean connected;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	802	boolean interrupted = false;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	803
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	804	// set state to ST_CLOSING
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	805	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	806	assert state < ST_CLOSING;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	807	blocking = isBlocking();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	808	connected = (state == ST_CONNECTED);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	809	state = ST_CLOSING;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	810	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	811
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	812	// wait for any outstanding I/O operations to complete
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	813	if (blocking) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	814	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	815	assert state == ST_CLOSING;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	816	long reader = readerThread;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	817	long writer = writerThread;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	818	if (reader != 0 \|\| writer != 0) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	819	nd.preClose(fd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	820	connected = false; // fd is no longer connected socket
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	821
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	822	if (reader != 0)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	823	NativeThread.signal(reader);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	824	if (writer != 0)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	825	NativeThread.signal(writer);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	826
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	827	// wait for blocking I/O operations to end
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	828	while (readerThread != 0 \|\| writerThread != 0) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	829	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	830	stateLock.wait();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	831	} catch (InterruptedException e) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	832	interrupted = true;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	833	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	834	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	835	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	836	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	837	} else {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	838	// non-blocking mode: wait for read/write to complete
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	839	readLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	840	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	841	writeLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	842	writeLock.unlock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	843	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	844	readLock.unlock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	845	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	846	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	847
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	848	// set state to ST_KILLPENDING
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	849	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	850	assert state == ST_CLOSING;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	851	// if connected, and the channel is registered with a Selector, we
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	852	// shutdown the output so that the peer reads EOF
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	853	if (connected && isRegistered()) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	854	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	855	Net.shutdown(fd, Net.SHUT_WR);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	856	} catch (IOException ignore) { }
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	857	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	858	state = ST_KILLPENDING;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	859	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	860
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	861	// close socket if not registered with Selector
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	862	if (!isRegistered())
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	863	kill();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	864
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	865	// restore interrupt status
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	866	if (interrupted)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	867	Thread.currentThread().interrupt();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	868	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	869
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	870	@Override
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	871	public void kill() throws IOException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	872	synchronized (stateLock) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	873	if (state == ST_KILLPENDING) {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	874	state = ST_KILLED;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	875	nd.close(fd);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	876	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	877	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	878	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	879
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	880	@Override
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	881	public SocketChannel shutdownInput() throws IOException {
2 90ce3da70b43 Initial load duke parents: diff changeset	882	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	883	ensureOpen();
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	884	if (!isConnected())
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	885	throw new NotYetConnectedException();
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	886	if (!isInputClosed) {
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	887	Net.shutdown(fd, Net.SHUT_RD);
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	888	long thread = readerThread;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	889	if (thread != 0)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	890	NativeThread.signal(thread);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	891	isInputClosed = true;
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	892	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	893	return this;
2 90ce3da70b43 Initial load duke parents: diff changeset	894	}
90ce3da70b43 Initial load duke parents: diff changeset	895	}
90ce3da70b43 Initial load duke parents: diff changeset	896
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	897	@Override
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	898	public SocketChannel shutdownOutput() throws IOException {
2 90ce3da70b43 Initial load duke parents: diff changeset	899	synchronized (stateLock) {
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	900	ensureOpen();
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	901	if (!isConnected())
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	902	throw new NotYetConnectedException();
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	903	if (!isOutputClosed) {
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	904	Net.shutdown(fd, Net.SHUT_WR);
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	905	long thread = writerThread;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	906	if (thread != 0)
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	907	NativeThread.signal(thread);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	908	isOutputClosed = true;
1152 29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	909	}
29d6145d1097 4640544: New I/O: Complete socket-channel functionality alanb parents: 2 diff changeset	910	return this;
2 90ce3da70b43 Initial load duke parents: diff changeset	911	}
90ce3da70b43 Initial load duke parents: diff changeset	912	}
90ce3da70b43 Initial load duke parents: diff changeset	913
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	914	boolean isInputOpen() {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	915	return !isInputClosed;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	916	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	917
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	918	boolean isOutputOpen() {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	919	return !isOutputClosed;
2 90ce3da70b43 Initial load duke parents: diff changeset	920	}
90ce3da70b43 Initial load duke parents: diff changeset	921
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	922	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	923	* Poll this channel's socket for reading up to the given timeout.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	924	* @return {@code true} if the socket is polled
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	925	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	926	boolean pollRead(long timeout) throws IOException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	927	boolean blocking = isBlocking();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	928	assert Thread.holdsLock(blockingLock()) && blocking;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	929
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	930	readLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	931	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	932	boolean polled = false;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	933	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	934	beginRead(blocking);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	935	int n = Net.poll(fd, Net.POLLIN, timeout);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	936	polled = (n > 0);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	937	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	938	endRead(blocking, polled);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	939	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	940	return polled;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	941	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	942	readLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	943	}
90ce3da70b43 Initial load duke parents: diff changeset	944	}
90ce3da70b43 Initial load duke parents: diff changeset	945
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	946	/**
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	947	* Poll this channel's socket for a connection, up to the given timeout.
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	948	* @return {@code true} if the socket is polled
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	949	*/
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	950	boolean pollConnected(long timeout) throws IOException {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	951	boolean blocking = isBlocking();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	952	assert Thread.holdsLock(blockingLock()) && blocking;
2 90ce3da70b43 Initial load duke parents: diff changeset	953
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	954	readLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	955	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	956	writeLock.lock();
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	957	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	958	boolean polled = false;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	959	try {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	960	beginFinishConnect(blocking);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	961	int n = Net.poll(fd, Net.POLLCONN, timeout);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	962	polled = (n > 0);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	963	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	964	endFinishConnect(blocking, polled);
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	965	}
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	966	return polled;
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	967	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	968	writeLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	969	}
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	970	} finally {
ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	971	readLock.unlock();
2 90ce3da70b43 Initial load duke parents: diff changeset	972	}
90ce3da70b43 Initial load duke parents: diff changeset	973	}
90ce3da70b43 Initial load duke parents: diff changeset	974
90ce3da70b43 Initial load duke parents: diff changeset	975	/**
90ce3da70b43 Initial load duke parents: diff changeset	976	* Translates native poll revent ops into a ready operation ops
90ce3da70b43 Initial load duke parents: diff changeset	977	*/
90ce3da70b43 Initial load duke parents: diff changeset	978	public boolean translateReadyOps(int ops, int initialOps,
90ce3da70b43 Initial load duke parents: diff changeset	979	SelectionKeyImpl sk) {
90ce3da70b43 Initial load duke parents: diff changeset	980	int intOps = sk.nioInterestOps(); // Do this just once, it synchronizes
90ce3da70b43 Initial load duke parents: diff changeset	981	int oldOps = sk.nioReadyOps();
90ce3da70b43 Initial load duke parents: diff changeset	982	int newOps = initialOps;
90ce3da70b43 Initial load duke parents: diff changeset	983
22604 9b394795e216 8031997: PPC64: Make the various POLL constants system dependant simonis parents: 19607 diff changeset	984	if ((ops & Net.POLLNVAL) != 0) {
2 90ce3da70b43 Initial load duke parents: diff changeset	985	// This should only happen if this channel is pre-closed while a
90ce3da70b43 Initial load duke parents: diff changeset	986	// selection operation is in progress
90ce3da70b43 Initial load duke parents: diff changeset	987	// ## Throw an error if this channel has not been pre-closed
90ce3da70b43 Initial load duke parents: diff changeset	988	return false;
90ce3da70b43 Initial load duke parents: diff changeset	989	}
90ce3da70b43 Initial load duke parents: diff changeset	990
22604 9b394795e216 8031997: PPC64: Make the various POLL constants system dependant simonis parents: 19607 diff changeset	991	if ((ops & (Net.POLLERR \| Net.POLLHUP)) != 0) {
2 90ce3da70b43 Initial load duke parents: diff changeset	992	newOps = intOps;
90ce3da70b43 Initial load duke parents: diff changeset	993	sk.nioReadyOps(newOps);
90ce3da70b43 Initial load duke parents: diff changeset	994	return (newOps & ~oldOps) != 0;
90ce3da70b43 Initial load duke parents: diff changeset	995	}
90ce3da70b43 Initial load duke parents: diff changeset	996
22604 9b394795e216 8031997: PPC64: Make the various POLL constants system dependant simonis parents: 19607 diff changeset	997	if (((ops & Net.POLLIN) != 0) &&
2 90ce3da70b43 Initial load duke parents: diff changeset	998	((intOps & SelectionKey.OP_READ) != 0) &&
90ce3da70b43 Initial load duke parents: diff changeset	999	(state == ST_CONNECTED))
90ce3da70b43 Initial load duke parents: diff changeset	1000	newOps \|= SelectionKey.OP_READ;
90ce3da70b43 Initial load duke parents: diff changeset	1001
22604 9b394795e216 8031997: PPC64: Make the various POLL constants system dependant simonis parents: 19607 diff changeset	1002	if (((ops & Net.POLLCONN) != 0) &&
2 90ce3da70b43 Initial load duke parents: diff changeset	1003	((intOps & SelectionKey.OP_CONNECT) != 0) &&
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	1004	((state == ST_UNCONNECTED) \|\| (state == ST_CONNECTIONPENDING))) {
2 90ce3da70b43 Initial load duke parents: diff changeset	1005	newOps \|= SelectionKey.OP_CONNECT;
90ce3da70b43 Initial load duke parents: diff changeset	1006	}
90ce3da70b43 Initial load duke parents: diff changeset	1007
22604 9b394795e216 8031997: PPC64: Make the various POLL constants system dependant simonis parents: 19607 diff changeset	1008	if (((ops & Net.POLLOUT) != 0) &&
2 90ce3da70b43 Initial load duke parents: diff changeset	1009	((intOps & SelectionKey.OP_WRITE) != 0) &&
90ce3da70b43 Initial load duke parents: diff changeset	1010	(state == ST_CONNECTED))
90ce3da70b43 Initial load duke parents: diff changeset	1011	newOps \|= SelectionKey.OP_WRITE;
90ce3da70b43 Initial load duke parents: diff changeset	1012
90ce3da70b43 Initial load duke parents: diff changeset	1013	sk.nioReadyOps(newOps);
90ce3da70b43 Initial load duke parents: diff changeset	1014	return (newOps & ~oldOps) != 0;
90ce3da70b43 Initial load duke parents: diff changeset	1015	}
90ce3da70b43 Initial load duke parents: diff changeset	1016
90ce3da70b43 Initial load duke parents: diff changeset	1017	public boolean translateAndUpdateReadyOps(int ops, SelectionKeyImpl sk) {
90ce3da70b43 Initial load duke parents: diff changeset	1018	return translateReadyOps(ops, sk.nioReadyOps(), sk);
90ce3da70b43 Initial load duke parents: diff changeset	1019	}
90ce3da70b43 Initial load duke parents: diff changeset	1020
90ce3da70b43 Initial load duke parents: diff changeset	1021	public boolean translateAndSetReadyOps(int ops, SelectionKeyImpl sk) {
90ce3da70b43 Initial load duke parents: diff changeset	1022	return translateReadyOps(ops, 0, sk);
90ce3da70b43 Initial load duke parents: diff changeset	1023	}
90ce3da70b43 Initial load duke parents: diff changeset	1024
90ce3da70b43 Initial load duke parents: diff changeset	1025	/**
90ce3da70b43 Initial load duke parents: diff changeset	1026	* Translates an interest operation set into a native poll event set
90ce3da70b43 Initial load duke parents: diff changeset	1027	*/
90ce3da70b43 Initial load duke parents: diff changeset	1028	public void translateAndSetInterestOps(int ops, SelectionKeyImpl sk) {
90ce3da70b43 Initial load duke parents: diff changeset	1029	int newOps = 0;
90ce3da70b43 Initial load duke parents: diff changeset	1030	if ((ops & SelectionKey.OP_READ) != 0)
22604 9b394795e216 8031997: PPC64: Make the various POLL constants system dependant simonis parents: 19607 diff changeset	1031	newOps \|= Net.POLLIN;
2 90ce3da70b43 Initial load duke parents: diff changeset	1032	if ((ops & SelectionKey.OP_WRITE) != 0)
22604 9b394795e216 8031997: PPC64: Make the various POLL constants system dependant simonis parents: 19607 diff changeset	1033	newOps \|= Net.POLLOUT;
2 90ce3da70b43 Initial load duke parents: diff changeset	1034	if ((ops & SelectionKey.OP_CONNECT) != 0)
22604 9b394795e216 8031997: PPC64: Make the various POLL constants system dependant simonis parents: 19607 diff changeset	1035	newOps \|= Net.POLLCONN;
2 90ce3da70b43 Initial load duke parents: diff changeset	1036	sk.selector.putEventOps(sk, newOps);
90ce3da70b43 Initial load duke parents: diff changeset	1037	}
90ce3da70b43 Initial load duke parents: diff changeset	1038
90ce3da70b43 Initial load duke parents: diff changeset	1039	public FileDescriptor getFD() {
90ce3da70b43 Initial load duke parents: diff changeset	1040	return fd;
90ce3da70b43 Initial load duke parents: diff changeset	1041	}
90ce3da70b43 Initial load duke parents: diff changeset	1042
90ce3da70b43 Initial load duke parents: diff changeset	1043	public int getFDVal() {
90ce3da70b43 Initial load duke parents: diff changeset	1044	return fdVal;
90ce3da70b43 Initial load duke parents: diff changeset	1045	}
90ce3da70b43 Initial load duke parents: diff changeset	1046
18212 22f8c33b0690 8001318: Socket.getLocalAddress not consistent with InetAddress.getLocalHost khazra parents: 18192 diff changeset	1047	@Override
2 90ce3da70b43 Initial load duke parents: diff changeset	1048	public String toString() {
24969 afa6934dd8e8 8041679: Replace uses of StringBuffer with StringBuilder within core library classes psandoz parents: 23879 diff changeset	1049	StringBuilder sb = new StringBuilder();
2 90ce3da70b43 Initial load duke parents: diff changeset	1050	sb.append(this.getClass().getSuperclass().getName());
90ce3da70b43 Initial load duke parents: diff changeset	1051	sb.append('[');
90ce3da70b43 Initial load duke parents: diff changeset	1052	if (!isOpen())
90ce3da70b43 Initial load duke parents: diff changeset	1053	sb.append("closed");
90ce3da70b43 Initial load duke parents: diff changeset	1054	else {
90ce3da70b43 Initial load duke parents: diff changeset	1055	synchronized (stateLock) {
90ce3da70b43 Initial load duke parents: diff changeset	1056	switch (state) {
90ce3da70b43 Initial load duke parents: diff changeset	1057	case ST_UNCONNECTED:
90ce3da70b43 Initial load duke parents: diff changeset	1058	sb.append("unconnected");
90ce3da70b43 Initial load duke parents: diff changeset	1059	break;
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	1060	case ST_CONNECTIONPENDING:
2 90ce3da70b43 Initial load duke parents: diff changeset	1061	sb.append("connection-pending");
90ce3da70b43 Initial load duke parents: diff changeset	1062	break;
90ce3da70b43 Initial load duke parents: diff changeset	1063	case ST_CONNECTED:
90ce3da70b43 Initial load duke parents: diff changeset	1064	sb.append("connected");
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	1065	if (isInputClosed)
2 90ce3da70b43 Initial load duke parents: diff changeset	1066	sb.append(" ishut");
49001 ce06058197a4 8198562: (ch) Separate blocking and non-blocking code paths (part 1) alanb parents: 48761 diff changeset	1067	if (isOutputClosed)
2 90ce3da70b43 Initial load duke parents: diff changeset	1068	sb.append(" oshut");
90ce3da70b43 Initial load duke parents: diff changeset	1069	break;
90ce3da70b43 Initial load duke parents: diff changeset	1070	}
18212 22f8c33b0690 8001318: Socket.getLocalAddress not consistent with InetAddress.getLocalHost khazra parents: 18192 diff changeset	1071	InetSocketAddress addr = localAddress();
22f8c33b0690 8001318: Socket.getLocalAddress not consistent with InetAddress.getLocalHost khazra parents: 18192 diff changeset	1072	if (addr != null) {
2 90ce3da70b43 Initial load duke parents: diff changeset	1073	sb.append(" local=");
18212 22f8c33b0690 8001318: Socket.getLocalAddress not consistent with InetAddress.getLocalHost khazra parents: 18192 diff changeset	1074	sb.append(Net.getRevealedLocalAddressAsString(addr));
2 90ce3da70b43 Initial load duke parents: diff changeset	1075	}
90ce3da70b43 Initial load duke parents: diff changeset	1076	if (remoteAddress() != null) {
90ce3da70b43 Initial load duke parents: diff changeset	1077	sb.append(" remote=");
90ce3da70b43 Initial load duke parents: diff changeset	1078	sb.append(remoteAddress().toString());
90ce3da70b43 Initial load duke parents: diff changeset	1079	}
90ce3da70b43 Initial load duke parents: diff changeset	1080	}
90ce3da70b43 Initial load duke parents: diff changeset	1081	}
90ce3da70b43 Initial load duke parents: diff changeset	1082	sb.append(']');
90ce3da70b43 Initial load duke parents: diff changeset	1083	return sb.toString();
90ce3da70b43 Initial load duke parents: diff changeset	1084	}
90ce3da70b43 Initial load duke parents: diff changeset	1085
90ce3da70b43 Initial load duke parents: diff changeset	1086
90ce3da70b43 Initial load duke parents: diff changeset	1087	// -- Native methods --
90ce3da70b43 Initial load duke parents: diff changeset	1088
48750 ffbb784a8873 8196787: (ch) Moving network channels to use j.u.c locks alanb parents: 47216 diff changeset	1089	private static native int checkConnect(FileDescriptor fd, boolean block)
2 90ce3da70b43 Initial load duke parents: diff changeset	1090	throws IOException;
90ce3da70b43 Initial load duke parents: diff changeset	1091
6117 471ae95609d5 6963907: (so) Socket adapter need to implement sendUrgentData alanb parents: 5506 diff changeset	1092	private static native int sendOutOfBandData(FileDescriptor fd, byte data)
471ae95609d5 6963907: (so) Socket adapter need to implement sendUrgentData alanb parents: 5506 diff changeset	1093	throws IOException;
471ae95609d5 6963907: (so) Socket adapter need to implement sendUrgentData alanb parents: 5506 diff changeset	1094
2 90ce3da70b43 Initial load duke parents: diff changeset	1095	static {
19607 bee007586d06 8022594: Potential deadlock in <clinit> of sun.nio.ch.Util/IOUtil alanb parents: 18212 diff changeset	1096	IOUtil.load();
2 90ce3da70b43 Initial load duke parents: diff changeset	1097	nd = new SocketDispatcher();
90ce3da70b43 Initial load duke parents: diff changeset	1098	}
90ce3da70b43 Initial load duke parents: diff changeset	1099
90ce3da70b43 Initial load duke parents: diff changeset	1100	}

author	alanb
	Wed, 28 Feb 2018 09:54:38 +0000
changeset 49001	ce06058197a4
parent 48761	74c1fa26435a
child 49141	ac95c7a76132
permissions	-rw-r--r--