Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 218 for ShutDown (0.09 sec)

  1. okhttp/src/test/java/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 {
        return shutdown
      }
    
      override fun isTerminated(): Boolean {
        throw UnsupportedOperationException()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  2. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt

        delegate.start(inetAddress, port)
      }
    
      @Synchronized
      @Throws(IOException::class)
      fun shutdown() {
        delegate.shutdown()
      }
    
      @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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. internal/http/server.go

    		return srv.Server.Serve(l)
    	}
    
    	return
    }
    
    // Shutdown - shuts down HTTP server.
    func (srv *Server) Shutdown() error {
    	srv.listenerMutex.Lock()
    	if srv.listener == nil {
    		srv.listenerMutex.Unlock()
    		return http.ErrServerClosed
    	}
    	srv.listenerMutex.Unlock()
    
    	if atomic.AddUint32(&srv.inShutdown, 1) > 1 {
    		// shutdown in progress
    		return http.ErrServerClosed
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

        task: Task,
        delayNanos: Long = 0L,
      ) {
        taskRunner.lock.withLock {
          if (shutdown) {
            if (task.cancelable) {
              taskRunner.logger.taskLog(task, this) { "schedule canceled (queue is shutdown)" }
              return
            }
            taskRunner.logger.taskLog(task, this) { "schedule failed (queue is shutdown)" }
            throw RejectedExecutionException()
          }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  5. cmd/signals.go

    		cancelGlobalContext()
    
    		if httpServer := newHTTPServerFn(); httpServer != nil {
    			if err := httpServer.Shutdown(); err != nil && !errors.Is(err, http.ErrServerClosed) {
    				shutdownLogIf(context.Background(), err)
    			}
    		}
    
    		if objAPI := newObjectLayerFn(); objAPI != nil {
    			shutdownLogIf(context.Background(), objAPI.Shutdown(context.Background()))
    		}
    
    		if globalBrowserEnabled {
    			if srv := newConsoleServerFn(); srv != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. okhttp/src/main/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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  8. impl/maven-core/src/main/java/org/apache/maven/internal/aether/ResolverLifecycle.java

            this.repositorySystemProvider = requireNonNull(repositorySystemProvider);
        }
    
        @PreDestroy
        public void shutdown() {
            repositorySystemProvider.get().shutdown();
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

            .build()
        url =
          serverIpv4.url("/")
            .newBuilder()
            .host("localhost")
            .build()
      }
    
      @AfterEach
      internal fun tearDown() {
        serverIpv4.shutdown()
        serverIpv6.shutdown()
      }
    
      @Test
      fun callIpv6FirstEvenWhenIpv4IpIsListedFirst() {
        dnsResults =
          listOf(
            localhostIpv4,
            localhostIpv6,
          )
        serverIpv4.enqueue(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/MoreExecutors.java

                        // following code, but unfortunately the behavior of logging
                        // is undefined in shutdown hooks.
                        // This is because the logging code installs a shutdown hook of its
                        // own. See Cleaner class inside {@link LogManager}.
                        service.shutdown();
                        service.awaitTermination(terminationTimeout, timeUnit);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
Back to top