| /libcore/ojluni/src/main/java/java/nio/channels/spi/ |
| D | AbstractInterruptibleChannel.java | 93 private volatile boolean open = true; field in AbstractInterruptibleChannel
113 if (!open) in close()
115 open = false; in close()
139 return open; in isOpen()
161 if (!open) in begin()
163 open = false; in begin()
205 if (!completed && !open) in end()
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| D | SelectorTest.java | 36 Selector selector = Selector.open(); in testNonBlockingConnect_immediate()
37 ServerSocketChannel ssc = ServerSocketChannel.open(); in testNonBlockingConnect_immediate()
42 SocketChannel sc = SocketChannel.open(); in testNonBlockingConnect_immediate()
57 Selector selector = Selector.open(); in testInterrupted()
72 final Selector selector = Selector.open(); in testManyWakeupCallsTriggerOnlyOneWakeup()
105 Selector selector = Selector.open(); in testLeakingPipes()
111 Selector selector = Selector.open(); in test_57456()
112 ServerSocketChannel ssc = ServerSocketChannel.open(); in test_57456()
118 SocketChannel sc = SocketChannel.open(); in test_57456()
143 Selector selector = Selector.open(); in test_80785()
[all …]
|
| D | DatagramChannelTest.java | 50 DatagramChannel dc = DatagramChannel.open()) { in test_read_intoReadOnlyByteArrays()
72 DatagramChannel dc = DatagramChannel.open(); in testNonBlockingRecv()
84 DatagramChannel dc = DatagramChannel.open(); in testInitialState()
106 DatagramChannel dc = DatagramChannel.open(); in test_bind_unresolvedAddress()
128 DatagramChannel dc = DatagramChannel.open(); in test_bind_any()
160 try (DatagramChannel dc = DatagramChannel.open()) { in test_bind()
170 DatagramChannel dc = DatagramChannel.open(); in test_setOption()
190 try (DatagramSocket socket = DatagramChannel.open().socket()) { in test_getFileDescriptor()
198 DatagramChannel channel = DatagramChannel.open(); in test_bind()
212 try (DatagramChannel dc = DatagramChannel.open()){ in test_bind()
[all …]
|
| D | AsynchronousServerSocketChannelTest.java | 53 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(); in test_bind()
68 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(); in test_bind_null()
83 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(); in test_bind_unresolvedAddress()
95 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(); in test_bind_used()
108 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(); in test_futureAccept()
130 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(); in test_completionHandlerAccept()
157 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(); in test_completionHandlerAccept_attachment()
181 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(); in test_completionHandlerAccept_nyb()
194 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(); in test_completionHandlerAccept_npe()
207 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(); in test_options()
[all …]
|
| D | SocketChannelTest.java | 52 SocketChannel sc = SocketChannel.open(ss.getLocalSocketAddress())) { in test_read_intoReadOnlyByteArrays()
75 SocketChannel sc = SocketChannel.open(); in test_56684()
78 Selector selector = Selector.open(); in test_56684()
104 SocketChannel sc = SocketChannel.open(ss.getLocalSocketAddress()); in test_channelSocketOutputStreamClosureState()
125 SocketChannel sc = SocketChannel.open(ss.getLocalSocketAddress()); in test_channelSocketInputStreamClosureState()
144 SocketChannel sc = SocketChannel.open(); in test_open_initialState()
167 SocketChannel sc = SocketChannel.open(); in test_bind_unresolvedAddress()
183 SocketChannel sc = SocketChannel.open(); in test_bind_socketStateSync()
211 SocketChannel sc = SocketChannel.open(); in test_bind_socketObjectCreationAfterBind()
238 SocketChannel sc = SocketChannel.open(); in test_connect_blocking()
[all …]
|
| D | AsynchronousFileChannelTest.java | 59 AsynchronousFileChannel channel = AsynchronousFileChannel.open(newFile, in testOpen_create()
73 AsynchronousFileChannel channel = AsynchronousFileChannel.open(newFile, in testOpen_existing()
78 AsynchronousFileChannel.open(newFile, StandardOpenOption.CREATE_NEW); in testOpen_existing()
81 AsynchronousFileChannel.open(newFile, StandardOpenOption.CREATE_NEW, in testOpen_existing()
88 channel = AsynchronousFileChannel.open(newFile, StandardOpenOption.CREATE, in testOpen_existing()
99 AsynchronousFileChannel.open(nonExistent, StandardOpenOption.READ); in testOpen_nonexistent()
105 AsynchronousFileChannel.open(nonExistent, StandardOpenOption.WRITE); in testOpen_nonexistent()
116 AsynchronousFileChannel.open(nonExistent, StandardOpenOption.CREATE); in testOpen_nonexistent()
122 AsynchronousFileChannel.open(nonExistent, StandardOpenOption.CREATE, in testOpen_nonexistent()
129 AsynchronousFileChannel.open(nonExistent, StandardOpenOption.CREATE_NEW); in testOpen_nonexistent()
[all …]
|
| D | AsynchronousChannelGroupTest.java | 89 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(acg); in test_shutdown()
101 AsynchronousServerSocketChannel.open(acg); in test_shutdown()
120 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(acg); in test_shutdownNow()
130 AsynchronousServerSocketChannel.open(acg); in test_shutdownNow()
143 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(acg); in test_isTerminated()
160 AsynchronousServerSocketChannel assc = AsynchronousServerSocketChannel.open(acg); in test_awaitTermination()
|
| D | ServerSocketChannelTest.java | 54 try (ServerSocketChannel ssc = ServerSocketChannel.open()) { in testNonBlockingAccept()
65 try (ServerSocketChannel ssc = ServerSocketChannel.open()) { in open_initialState()
82 ServerSocketChannel ssc = ServerSocketChannel.open(); in bind_unresolvedAddress()
97 ServerSocketChannel ssc = ServerSocketChannel.open(); in bind_nullBindsToAll()
169 ServerSocketChannel ssc = ServerSocketChannel.open(); in bind_loopback()
213 ServerSocketChannel ssc = ServerSocketChannel.open(); in bind_socketAddress()
227 ServerSocketChannel ssc1 = ServerSocketChannel.open(); in bind_socketAddress()
243 ServerSocketChannel sc = ServerSocketChannel.open(); in set_option()
267 SocketChannel socketChannel = SocketChannel.open(address); in canConnect()
|
| D | OldSocketChannelTest.java | 57 this.channel1 = SocketChannel.open(); in setUp()
58 this.channel2 = SocketChannel.open(); in setUp()
96 channel = SocketChannel.open(); in testConstructor()
116 SocketChannel testSChannel = MockSocketChannel.open(); in testOpen()
181 this.channel1 = SocketChannel.open(localAddr1); in testOpenSocketAddress()
186 this.channel1 = SocketChannel.open(newTypeAddress); in testOpenSocketAddress()
195 this.channel1 = SocketChannel.open(unresolvedAddress); in testOpenSocketAddress()
202 SocketChannel.open(null); in testOpenSocketAddress()
283 final ServerSocketChannel ssc = ServerSocketChannel.open(); in test_socketChannel_read_DirectByteBuffer()
302 SocketChannel sc = SocketChannel.open(); in test_socketChannel_read_DirectByteBuffer()
[all …]
|
| D | AsynchronousSocketChannelTest.java | 57 AsynchronousSocketChannel asc = AsynchronousSocketChannel.open(); in test_connect()
83 AsynchronousSocketChannel asc = AsynchronousSocketChannel.open(); in test_bind()
103 AsynchronousSocketChannel asc = AsynchronousSocketChannel.open(); in test_bind_unsupportedAddress()
119 AsynchronousSocketChannel asc = AsynchronousSocketChannel.open(); in test_bind_unresolvedAddress()
134 AsynchronousSocketChannel asc = AsynchronousSocketChannel.open(); in test_bind_usedAddress()
150 AsynchronousSocketChannel asc = AsynchronousSocketChannel.open(); in test_bind_null()
161 AsynchronousSocketChannel asc = AsynchronousSocketChannel.open(); in test_connect_unresolvedAddress()
174 AsynchronousSocketChannel asc = AsynchronousSocketChannel.open(); in test_close()
272 AsynchronousSocketChannel asc = AsynchronousSocketChannel.open(); in test_futureReadWrite()
321 AsynchronousSocketChannel asc = AsynchronousSocketChannel.open(); in test_completionHandlerReadWrite()
[all …]
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/ |
| D | UnixSelectorTest.java | 31 ServerSocketChannel serverChannel = ServerSocketChannel.open();
62 Selector sel0 = Selector.open(); in testSelectorAcceptAndRead()
63 Selector sel1 = Selector.open(); in testSelectorAcceptAndRead()
76 SocketChannel socketChannel = SocketChannel.open(); in testSelectorAcceptAndRead()
78 Selector sel2 = Selector.open(); in testSelectorAcceptAndRead()
93 SocketChannel socketChannel2 = SocketChannel.open(); in testSelectUnConnectedChannel()
95 Selector sel3 = Selector.open(); in testSelectUnConnectedChannel()
104 Selector sel4 = Selector.open(); in testSelectUnConnectedChannel()
110 Selector sel5 = Selector.open(); in testSelectUnConnectedChannel()
|
| D | PipeTest.java | 37 Pipe pipe = Pipe.open(); in test_open()
45 Pipe pipe = Pipe.open(); in test_sink()
54 Pipe pipe = Pipe.open(); in test_source()
|
| D | SelectorTest.java | 54 ssc = ServerSocketChannel.open(); in setUp()
59 selector = Selector.open(); in setUp()
116 SocketChannel sc = SocketChannel.open(); in test_keys()
151 SocketChannel sc = SocketChannel.open(); in test_selectedKeys()
251 selector = Selector.open(); in test_selectJ_SelectorClosed()
337 SocketChannel sc = SocketChannel.open();
361 final Pipe pipe = Pipe.open();
394 SocketChannel sc = SocketChannel.open();
442 channel = SocketChannel.open();
444 Selector selector = Selector.open();
[all …]
|
| /libcore/dalvik/src/test/java/libcore/dalvik/system/ |
| D | CloseGuardTest.java | 62 owner.open();
78 owner.open();
97 owner.open();
108 owner.open();
126 owner.open();
142 owner.open();
161 owner.open();
189 public void open() {
190 closeGuard.open("close");
|
| /libcore/ojluni/src/main/java/java/nio/channels/ |
| D | AsynchronousServerSocketChannel.java | 140 public static AsynchronousServerSocketChannel open(AsynchronousChannelGroup group) in open() method in AsynchronousServerSocketChannel
163 public static AsynchronousServerSocketChannel open() in open() method in AsynchronousServerSocketChannel
166 return open(null); in open()
|
| D | SocketChannel.java | 144 public static SocketChannel open() throws IOException { in open() method in SocketChannel
184 public static SocketChannel open(SocketAddress remote) in open() method in SocketChannel
187 SocketChannel sc = open(); in open()
|
| D | AsynchronousFileChannel.java | 241 public static AsynchronousFileChannel open(Path file, in open() method in AsynchronousFileChannel
296 public static AsynchronousFileChannel open(Path file, OpenOption... options) in open() method in AsynchronousFileChannel
301 return open(file, set, null, NO_ATTRIBUTES); in open()
|
| D | FileChannel.java | 281 public static FileChannel open(Path path, in open() method in FileChannel
330 public static FileChannel open(Path path, OpenOption... options) in open() method in FileChannel
335 return open(path, set, NO_ATTRIBUTES); in open()
|
| D | AsynchronousSocketChannel.java | 164 public static AsynchronousSocketChannel open(AsynchronousChannelGroup group) in open() method in AsynchronousSocketChannel
187 public static AsynchronousSocketChannel open() in open() method in AsynchronousSocketChannel
190 return open(null); in open()
|
| /libcore/ojluni/src/main/java/sun/nio/fs/ |
| D | UnixChannelFactory.java | 106 return FileChannelImpl.open(fdObj, path, reading, writing, null); in newFileChannel()
136 FileDescriptor fdObj = open(dfd, path, pathForPermissionCheck, flags, mode); in newFileChannel()
137 … return FileChannelImpl.open(fdObj, path.toString(), flags.read, flags.write, flags.append, null); in newFileChannel()
172 FileDescriptor fdObj = open(-1, path, null, flags, mode); in newAsynchronousFileChannel()
173 return SimpleAsynchronousFileChannelImpl.open(fdObj, flags.read, flags.write, pool); in newAsynchronousFileChannel()
180 protected static FileDescriptor open(int dfd, in open() method in UnixChannelFactory
257 fd = UnixNativeDispatcher.open(path, oflags, mode); in open()
|
| /libcore/dalvik/test-rules/src/test/java/libcore/dalvik/system/ |
| D | CloseGuardSupportTest.java | 46 closeGuard.open("test resource"); in test()
61 closeGuard.open("test resource"); in test()
79 closeGuard.open("test resource"); in test()
97 closeGuard.open("test resource"); in test()
163 guard.open("test resource"); in test()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/spi/ |
| D | AbstractSelectableChannelTest.java | 112 SocketChannel sc = SocketChannel.open(); in test_register_LSelectorILObject()
126 SocketChannel channel = SocketChannel.open(); in test_register_LSelectorILObject()
128 Selector selector = Selector.open(); in test_register_LSelectorILObject()
211 SocketChannel sc = SocketChannel.open(); in test_register_LSelectorILObject_IllegalArgument()
235 SocketChannel sc = SocketChannel.open(); in test_keyfor_LSelector()
257 SocketChannel sc = SocketChannel.open(); in test_configureBlocking_Z_IllegalBlockingMode()
|
| /libcore/luni/src/test/java/libcore/java/io/ |
| D | InterruptedStreamTest.java | 90 testInterruptReadableChannel(Pipe.open().source()); in testInterruptReadablePipeChannel()
94 testInterruptWritableChannel(Pipe.open().sink()); in testInterruptWritablePipeChannel()
111 ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(); in newSocketChannelPair()
113 SocketChannel clientSocketChannel = SocketChannel.open(); in newSocketChannelPair()
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | AsynchronousServerSocketChannelImpl.java | 61 private volatile boolean open = true; field in AsynchronousServerSocketChannelImpl
76 return open; in isOpen()
105 if (!open) in close()
107 open = false; in close()
|
| /libcore/dalvik/src/main/java/dalvik/system/ |
| D | CloseGuard.java | 229 public void open(String closer) { in open() method in CloseGuard
262 tracker.open(stack); in openWithCallSite()
321 void open(Throwable allocationSite); in open() method
|