Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 218 for ShutDown (0.09 sec)

  1. cmd/erasure-server-pool.go

    }
    
    func (z *erasureServerPools) Shutdown(ctx context.Context) error {
    	g := errgroup.WithNErrs(len(z.serverPools))
    
    	for index := range z.serverPools {
    		index := index
    		g.Go(func() error {
    			return z.serverPools[index].Shutdown(ctx)
    		}, index)
    	}
    
    	for _, err := range g.Wait() {
    		if err != nil {
    			storageLogIf(ctx, err)
    		}
    		// let's the rest shutdown
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        assertFailsWith<IOException> {
          getResponse(request)
        }
      }
    
      @Test
      fun connectRetriesUntilConnectedOrFailed() {
        val request = newRequest("/foo")
        server.shutdown()
        assertFailsWith<IOException> {
          getResponse(request)
        }
      }
    
      @Test
      fun requestBodySurvivesRetriesWithFixedLength() {
        testRequestBodySurvivesRetries(TransferKind.FIXED_LENGTH)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  3. docs/en/docs/alternatives.md

    It is very simple and intuitive. It's designed to be easily extensible, and have modular components.
    
    It has:
    
    * Seriously impressive performance.
    * WebSocket support.
    * In-process background tasks.
    * Startup and shutdown events.
    * Test client built on HTTPX.
    * CORS, GZip, Static Files, Streaming responses.
    * Session and Cookie support.
    * 100% test coverage.
    * 100% type annotated codebase.
    * Few hard dependencies.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

          else break;
        }
      }
    
      /** Waits out termination of a thread pool or fails doing so. */
      void joinPool(ExecutorService exec) throws InterruptedException {
        try {
          exec.shutdown();
          assertTrue(
              "ExecutorService did not terminate in a timely manner",
              exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS));
        } catch (SecurityException ok) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/SmbSessionImpl.java

                             * server will return "Access denied" even if a logoff is
                             * sent. Unfortunately calling disconnect() doesn't always
                             * actually shutdown the connection before other threads
                             * have committed themselves (e.g. InterruptTest example).
                             */
                            try {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:41:04 UTC 2021
    - 49K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/CacheTest.kt

        val cached = cacheGet(cache, request)
        if (shouldWriteToCache) {
          assertThat(cached).isNotNull()
          cached!!.body.close()
        } else {
          assertThat(cached).isNull()
        }
        server.shutdown() // tearDown() isn't sufficient; this test starts multiple servers
      }
    
      private fun assertSubsequentResponseCached(
        initialResponseCode: Int,
        finalResponseCode: Int,
      ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 108.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

          else break;
        }
      }
    
      /** Waits out termination of a thread pool or fails doing so. */
      void joinPool(ExecutorService exec) throws InterruptedException {
        try {
          exec.shutdown();
          assertTrue(
              "ExecutorService did not terminate in a timely manner",
              exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS));
        } catch (SecurityException ok) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  8. docs/en/docs/deployment/docker.md

    ```
    
    ⛔️ **Shell** form:
    
    ```Dockerfile
    # ⛔️ Don't do this
    CMD fastapi run app/main.py --port 80
    ```
    
    Make sure to always use the **exec** form to ensure that FastAPI can shutdown gracefully and [lifespan events](../advanced/events.md){.internal-link target=_blank} are triggered.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/EventListenerTest.kt

        listener.forbidLock(get(client.connectionPool))
        listener.forbidLock(client.dispatcher)
      }
    
      @AfterEach
      fun tearDown() {
        if (socksProxy != null) {
          socksProxy!!.shutdown()
        }
        if (cache != null) {
          cache!!.delete()
        }
      }
    
      @Test
      fun successfulCallEventSequence() {
        server.enqueue(
          MockResponse.Builder()
            .body("abc")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.16.md

    * The kube-apiserver has improved behavior for both startup and shutdown sequences and also now exposes `/readyz` for readiness checking. Readyz includes all existing healthz checks but also adds a shutdown check. When a cluster admin initiates a shutdown, the kube-apiserver will try to process existing requests (for the duration of request timeout) before killing the apiserver process.   ([#78458](https://...
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Feb 11 10:00:57 UTC 2021
    - 345.2K bytes
    - Viewed (0)
Back to top