Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 142 for shutdowned (0.04 sec)

  1. CHANGELOG/CHANGELOG-1.10.md

    ## Changelog since v1.10.9
    
    ### Other notable changes
    
    * Do not remove shutdown nodes from api-server for vSphere. ([#70291](https://github.com/kubernetes/kubernetes/pull/70291), [@gnufied](https://github.com/gnufied))
        * Fixes volume detach from shutdown nodes.
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 341.8K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

        private volatile boolean shutdown;
    
        @Override
        public void shutdown() {
          shutdown = true;
        }
    
        @Override
        public List<Runnable> shutdownNow() {
          shutdown();
          return ImmutableList.of();
        }
    
        @Override
        public boolean isShutdown() {
          return shutdown;
        }
    
        @Override
        public boolean isTerminated() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt

            return
          }
        }
        throw AssertionError("No such job: $url")
      }
    
      override fun shutdown() {
        shutdown = true
      }
    
      override fun shutdownNow(): List<Runnable> = throw UnsupportedOperationException()
    
      override fun isShutdown(): Boolean = shutdown
    
      override fun isTerminated(): Boolean = throw UnsupportedOperationException()
    
      override fun awaitTermination(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

                      // which case we should skip right down to shutdown.
                      if (isRunning()) {
                        try {
                          AbstractExecutionThreadService.this.run();
                        } catch (Throwable t) {
                          restoreInterruptIfIsInterruptedException(t);
                          try {
                            shutDown();
                          } catch (Exception ignored) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  5. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

                  while (!shutdown.get()) {
                    interruptee.interrupt();
                    Thread.yield();
                  }
                }
              });
          this.shutdown = shutdown;
          start();
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        void shutdown() {
          shutdown.set(true);
          while (this.isAlive()) {
            Thread.yield();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  6. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt

        delegate.start(inetAddress, port)
      }
    
      @Synchronized
      @Throws(IOException::class)
      fun shutdown() {
        delegate.close()
      }
    
      @Synchronized override fun after() {
        try {
          shutdown()
        } catch (e: IOException) {
          logger.log(Level.WARNING, "MockWebServer shutdown failed", e)
        }
      }
    
      override fun toString(): String = delegate.toString()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 00:19:42 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * the "running" state need to perform a periodic task. Subclasses can implement {@link #startUp},
     * {@link #shutDown} and also a {@link #runOneIteration} method that will be executed periodically.
     *
     * <p>This class uses the {@link ScheduledExecutorService} returned from {@link #executor} to run
     * the {@link #startUp} and {@link #shutDown} methods and also uses that service to schedule the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

                      // which case we should skip right down to shutdown.
                      if (isRunning()) {
                        try {
                          AbstractExecutionThreadService.this.run();
                        } catch (Throwable t) {
                          restoreInterruptIfIsInterruptedException(t);
                          try {
                            shutDown();
                          } catch (Exception ignored) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * the "running" state need to perform a periodic task. Subclasses can implement {@link #startUp},
     * {@link #shutDown} and also a {@link #runOneIteration} method that will be executed periodically.
     *
     * <p>This class uses the {@link ScheduledExecutorService} returned from {@link #executor} to run
     * the {@link #startUp} and {@link #shutDown} methods and also uses that service to schedule the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt

       * message buffer (16 MiB) will be rejected and trigger a [graceful shutdown][close] of this web
       * socket. This method returns false in that case, and in any other case where this web socket is
       * closing, closed, or canceled.
       *
       * This method returns immediately.
       */
      fun send(bytes: ByteString): Boolean
    
      /**
       * Attempts to initiate a graceful shutdown of this web socket. Any already-enqueued messages will
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.3K bytes
    - Viewed (0)
Back to top