/libcore/ojluni/src/main/java/sun/nio/fs/ |
H A D | AbstractPoller.java | 46 // 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 D | AsynchronousChannelGroupImpl.java | 67 // 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 D | AsynchronousSocketChannelImpl.java | 244 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 D | AsynchronousChannelGroup.java | 51 * 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 D | OldCookieHandlerTest.java | 43 server.shutdown();
|
H A D | FtpURLConnectionTest.java | 137 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 D | ExecutorService.java | 52 * 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 D | Executors.java | 86 * 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 D | HttpsURLConnectionTest.java | 151 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 D | AsynchronousChannelGroupTest.java | 92 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 D | SecureRandomTest.java | 91 executor.shutdown();
|
/libcore/benchmarks/src/benchmarks/regression/ |
H A D | URLConnectionBenchmark.java | 68 server.shutdown();
|
/libcore/support/src/test/java/libcore/javax/net/ssl/ |
H A D | TestSSLSocketPair.java | 98 executor.shutdown();
|
/libcore/support/src/test/java/tests/support/ |
H A D | Support_Exec.java | 113 executorService.shutdown();
|
/libcore/ojluni/src/main/java/java/net/ |
H A D | PlainSocketImpl.java | 238 * 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 D | AbstractExecutorServiceTest.java | 51 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 D | ScheduledExecutorSubclassTest.java | 312 * 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 D | ScheduledExecutorTest.java | 256 * 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 D | DoubleAccumulatorTest.java | 137 pool.shutdown();
|
H A D | DoubleAdderTest.java | 149 pool.shutdown();
|
H A D | LongAccumulatorTest.java | 137 pool.shutdown();
|
/libcore/luni/src/test/java/libcore/javax/net/ssl/ |
H A D | SSLSocketTest.java | 399 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 D | MockWebServer.java | 208 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 D | OutputStreamTesterTest.java | 141 executor.shutdown();
|
H A D | WriterTesterTest.java | 135 executor.shutdown();
|