Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for isShutdown (0.23 sec)

  1. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

     * ```
     *
     * ## Shutdown Isn't Necessary
     *
     * The threads and connections that are held will be released automatically if they remain idle. But
     * if you are writing a application that needs to aggressively release unused resources you may do
     * so.
     *
     * Shutdown the dispatcher's executor service with [shutdown()][ExecutorService.shutdown]. This will
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

                }
              }
              return result
            }
    
            override fun peek(): MockResponse = queueDispatcher.peek()
    
            override fun shutdown() {
              queueDispatcher.shutdown()
            }
          }
        client =
          client.newBuilder()
            .proxy(server.toProxyAddress())
            .build()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    }
    
    // Deleting the temporary backend and stopping the server.
    func (testServer TestServer) Stop() {
    	testServer.cancel()
    	testServer.Server.Close()
    	testServer.Obj.Shutdown(context.Background())
    	os.RemoveAll(testServer.Root)
    	for _, ep := range testServer.Disks {
    		for _, disk := range ep.Endpoints {
    			os.RemoveAll(disk.Path)
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  4. docs/changelogs/changelog_3x.md

     *  Fix: When parsing HTTP authentication headers permit challenge parameters in any order.
    
    
    ## Version 3.4.2
    
    _2016-11-03_
    
     *  Fix: Recover gracefully when an HTTP/2 connection is shutdown. We had a
        bug where shutdown HTTP/2 connections were considered usable. This caused
        infinite loops when calls attempted to recover.
    
    
    ## Version 3.4.1
    
    _2016-07-10_
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  5. cmd/erasure-healing_test.go

    func TestHealing(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDirs, err := prepareErasure16(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer obj.Shutdown(context.Background())
    
    	// initialize the server and obtain the credentials and root.
    	// credentials are necessary to sign the HTTP request.
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        connection.withLock {
          if (!connection.isHealthy(System.nanoTime())) {
            throw ConnectionShutdownException()
          }
        }
        connection.writePing()
        connection.shutdown(ErrorCode.PROTOCOL_ERROR)
        assertThat(connection.openStreamCount()).isEqualTo(1)
        connection.awaitPong() // Prevent the peer from exiting prematurely.
    
        // Verify the peer received what was expected.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
Back to top