Searched refs:shutdown (Results 1 - 25 of 61) sorted by relevance

123

/libcore/ojluni/src/main/java/sun/nio/fs/
H A DAbstractPoller.java46 // set to true when shutdown
47 private boolean shutdown; field in class:AbstractPoller
51 this.shutdown = false;
88 * Executed by poller thread to shutdown and cancel all keys
215 if (shutdown) {
237 * @return true if poller thread should shutdown
244 // if in process of shutdown then reject request
245 if (shutdown) {
279 shutdown = true;
288 return shutdown;
[all...]
/libcore/ojluni/src/main/java/sun/nio/ch/
H A DAsynchronousChannelGroupImpl.java67 // group shutdown
68 private final AtomicBoolean shutdown = new AtomicBoolean(); field in class:AsynchronousChannelGroupImpl
214 return shutdown.get();
251 pool.executor().shutdown();
252 timeoutExecutor.shutdown();
259 public final void shutdown() { method in class:AsynchronousChannelGroupImpl
260 if (shutdown.getAndSet(true)) {
261 // already shutdown
264 // if there are channels in the group then shutdown will continue
282 shutdown
[all...]
H A DAsynchronousSocketChannelImpl.java244 boolean shutdown = false;
253 shutdown = true;
261 // immediately complete with -1 if shutdown for read
263 if (shutdown || !hasSpaceToRead) {
266 result = (shutdown) ? Long.valueOf(-1L) : Long.valueOf(0L);
268 result = (shutdown) ? -1 : 0;
364 // channel is closed or shutdown for write
465 throw new IOException("Connection has been shutdown for writing");
539 Net.shutdown(fd, Net.SHUT_RD);
557 Net.shutdown(f
[all...]
/libcore/ojluni/src/main/java/java/nio/channels/
H A DAsynchronousChannelGroup.java51 * shutdown of the associated thread pool.
106 * <a name="shutdown"></a><h2>Shutdown and Termination</h2>
108 * <p> The {@link #shutdown() shutdown} method is used to initiate an <em>orderly
109 * shutdown</em> of a group. An orderly shutdown marks the group as shutdown;
111 * {@link ShutdownChannelGroupException}. Whether or not a group is shutdown can
112 * be tested using the {@link #isShutdown() isShutdown} method. Once shutdown,
122 * <em>forceful shutdown</e
304 public abstract void shutdown(); method in class:AsynchronousChannelGroup
[all...]
/libcore/luni/src/test/java/libcore/java/net/
H A DOldCookieHandlerTest.java43 server.shutdown();
H A DFtpURLConnectionTest.java137 countingProxy.shutdown();
160 countingProxy.shutdown();
190 countingProxy.shutdown();
275 executor.shutdown();
345 * {@link #shutdown()}, a background server thread accepts and counts
372 // Signals that serverThread has gracefully completed shutdown (not crashed)
426 public void shutdown() throws IOException, InterruptedException { method in class:FtpURLConnectionTest.CountingProxy
/libcore/ojluni/src/main/java/java/util/concurrent/
H A DExecutorService.java52 * shutting down an {@code ExecutorService}. The {@link #shutdown}
96 * pool.shutdown();
110 * first by calling {@code shutdown} to reject incoming tasks, and then
115 * pool.shutdown(); // Disable new tasks from being submitted
145 * Initiates an orderly shutdown in which previously submitted
153 void shutdown(); method in interface:ExecutorService
183 * either {@code shutdown} or {@code shutdownNow} was called first.
190 * Blocks until all tasks have completed execution after a shutdown
H A DExecutors.java86 * prior to shutdown, a new one will take its place if needed to
88 * until it is explicitly {@link ExecutorService#shutdown shutdown}.
146 * execution prior to shutdown, a new one will take its place if
148 * exist until it is explicitly {@link ExecutorService#shutdown
149 * shutdown}.
168 * shutdown, a new one will take its place if needed to execute
249 * shutdown, a new one will take its place if needed to execute
266 * during execution prior to shutdown, a new one will take its
621 public void shutdown() { method in class:Executors.DelegatedExecutorService
[all...]
/libcore/luni/src/test/java/org/apache/harmony/luni/tests/internal/net/www/protocol/https/
H A DHttpsURLConnectionTest.java151 webServer.shutdown();
189 webServer.shutdown();
237 webServer.shutdown();
281 webServer.shutdown();
349 webServer.shutdown();
380 webServer.shutdown();
420 proxyAndWebServer.shutdown();
469 proxyAndWebServer.shutdown();
498 proxyAndWebServer1.shutdown();
515 proxyAndWebServer2.shutdown();
[all...]
/libcore/luni/src/test/java/libcore/java/nio/channels/
H A DAsynchronousChannelGroupTest.java92 acg.shutdown();
108 // Check invoking shutdown twice.
109 acg.shutdown();
162 // Timeout as the group hasn't yet shutdown.
/libcore/luni/src/test/java/tests/security/
H A DSecureRandomTest.java91 executor.shutdown();
/libcore/benchmarks/src/benchmarks/regression/
H A DURLConnectionBenchmark.java68 server.shutdown();
/libcore/support/src/test/java/libcore/javax/net/ssl/
H A DTestSSLSocketPair.java98 executor.shutdown();
/libcore/support/src/test/java/tests/support/
H A DSupport_Exec.java113 executorService.shutdown();
/libcore/ojluni/src/main/java/java/net/
H A DPlainSocketImpl.java238 * Create the marker file descriptor by establishing a loopback connection which we shutdown but
252 Libcore.os.shutdown(fd1, SHUT_RDWR);
265 Libcore.os.shutdown(fd, howto);
/libcore/jsr166-tests/src/test/java/jsr166/
H A DAbstractExecutorServiceTest.java51 public void shutdown() { shutdown = true; } method in class:AbstractExecutorServiceTest.DirectExecutorService
53 shutdown = true;
56 public boolean isShutdown() { return shutdown; }
61 private volatile boolean shutdown = false; field in class:AbstractExecutorServiceTest.DirectExecutorService
H A DScheduledExecutorSubclassTest.java312 * execute throws RejectedExecutionException if shutdown
318 p.shutdown();
328 * schedule throws RejectedExecutionException if shutdown
334 p.shutdown();
344 * schedule callable throws RejectedExecutionException if shutdown
350 p.shutdown();
360 * scheduleAtFixedRate throws RejectedExecutionException if shutdown
366 p.shutdown();
376 * scheduleWithFixedDelay throws RejectedExecutionException if shutdown
382 p.shutdown();
[all...]
H A DScheduledExecutorTest.java256 * execute throws RejectedExecutionException if shutdown
262 p.shutdown();
272 * schedule throws RejectedExecutionException if shutdown
278 p.shutdown();
288 * schedule callable throws RejectedExecutionException if shutdown
294 p.shutdown();
304 * scheduleAtFixedRate throws RejectedExecutionException if shutdown
310 p.shutdown();
320 * scheduleWithFixedDelay throws RejectedExecutionException if shutdown
326 p.shutdown();
[all...]
H A DDoubleAccumulatorTest.java137 pool.shutdown();
H A DDoubleAdderTest.java149 pool.shutdown();
H A DLongAccumulatorTest.java137 pool.shutdown();
/libcore/luni/src/test/java/libcore/javax/net/ssl/
H A DSSLSocketTest.java399 executor.shutdown();
461 executor.shutdown();
484 executor.shutdown();
513 executor.shutdown();
539 executor.shutdown();
559 executor.shutdown();
683 executor.shutdown();
760 executor.shutdown();
808 executor.shutdown();
852 executor.shutdown();
[all...]
/libcore/support/src/test/java/tests/http/
H A DMockWebServer.java208 executor.shutdown();
210 logger.log(Level.WARNING, "MockWebServer executor shutdown failed", e);
235 public void shutdown() throws IOException { method in class:MockWebServer
282 shutdown();
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/
H A DOutputStreamTesterTest.java141 executor.shutdown();
H A DWriterTesterTest.java135 executor.shutdown();

Completed in 1995 milliseconds

123