Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for doDisconnect (0.28 sec)

  1. cmd/metrics.go

    		w.Header().Set("Content-Type", string(contentType))
    
    		enc := expfmt.NewEncoder(w, contentType)
    		for _, mf := range mfs {
    			if err := enc.Encode(mf); err != nil {
    				// client may disconnect for any reasons
    				// we do not have to log this.
    				return
    			}
    		}
    		if closer, ok := enc.(expfmt.Closer); ok {
    			closer.Close()
    		}
    	})
    }
    
    // NoAuthMiddleware no auth middle ware.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  2. cmd/metacache-server-pool.go

    		o.Create = false
    		o.ID = ""
    		o.Transient = true
    		return entries, errDiskFull
    	}
    	o.set = z.serverPools[o.pool].getHashedSetIndex(o.ID)
    	saver := z.serverPools[o.pool].sets[o.set]
    
    	// Disconnect from call above, but cancel on exit.
    	listCtx, cancel := context.WithCancel(GlobalContext)
    	saveCh := make(chan metaCacheEntry, metacacheBlockSize)
    	inCh := make(chan metaCacheEntry, metacacheBlockSize)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  3. cmd/admin-handlers-site-replication.go

    // [POST] /minio/admin/v3/site-replication/devnull
    func (a adminAPIHandlers) SiteReplicationDevNull(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	globalSiteNetPerfRX.Connect()
    	defer globalSiteNetPerfRX.Disconnect()
    
    	connectTime := time.Now()
    	for {
    		n, err := io.CopyN(xioutil.Discard, r.Body, 128*humanize.KiByte)
    		atomic.AddUint64(&globalSiteNetPerfRX.RX, uint64(n))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 09:40:39 GMT 2024
    - 19.4K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

              suppressTlsFallbackClientSocketFactory(),
              handshakeCertificates.trustManager,
            )
            .build()
        assertContent("abc", getResponse(newRequest("/")))
    
        // Give the server time to disconnect.
        Thread.sleep(500)
        assertContent("def", getResponse(newRequest("/")))
        val tlsVersions: Set<TlsVersion?> =
          EnumSet.of(
            TlsVersion.TLS_1_0,
            TlsVersion.TLS_1_2,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 131.7K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

        protocol: Protocol,
        mockWebServer: MockWebServer,
      ) {
        setUp(protocol, mockWebServer)
        server.enqueue(MockResponse(body = "abc"))
        server.enqueue(MockResponse(body = "def"))
    
        // Disconnect before the stream is created. A connection is still established!
        val call1 = client.newCall(Request(server.url("/")))
        val response = call1.execute()
        call1.cancel()
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  6. cmd/peer-rest-server.go

    	if !s.IsValid(w, r) {
    		s.writeErrorResponse(w, errors.New("invalid request"))
    		return
    	}
    
    	globalNetPerfRX.Connect()
    	defer globalNetPerfRX.Disconnect()
    
    	connectTime := time.Now()
    	ctx := newContext(r, w, "DevNull")
    	for {
    		n, err := io.CopyN(xioutil.Discard, r.Body, 128*humanize.KiByte)
    		atomic.AddUint64(&globalNetPerfRX.RX, uint64(n))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/EventListenerTest.kt

      }
    
      @Test
      fun responseBodyFailHttp() {
        responseBodyFail(Protocol.HTTP_1_1)
      }
    
      private fun responseBodyFail(expectedProtocol: Protocol?) {
        // Use a 2 MiB body so the disconnect won't happen until the client has read some data.
        val responseBodySize = 2 * 1024 * 1024 // 2 MiB
        server.enqueue(
          MockResponse.Builder()
            .body(Buffer().write(ByteArray(responseBodySize)))
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 56.9K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/CacheTest.kt

      }
    
      @Test
      fun serverDisconnectsPrematurelyWithNoLengthHeaders() {
        // Intentionally empty. This case doesn't make sense because there's no
        // such thing as a premature disconnect when the disconnect itself
        // indicates the end of the data stream.
      }
    
      private fun testServerPrematureDisconnect(transferKind: TransferKind) {
        val mockResponse = MockResponse.Builder()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 108.6K bytes
    - Viewed (0)
  9. cmd/metrics-v2.go

    		w.Header().Set("Content-Type", string(contentType))
    
    		enc := expfmt.NewEncoder(w, contentType)
    		for _, mf := range mfs {
    			if err := enc.Encode(mf); err != nil {
    				// client may disconnect for any reasons
    				// we do not have to log this.
    				return
    			}
    		}
    		if closer, ok := enc.(expfmt.Closer); ok {
    			closer.Close()
    		}
    	})
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
Back to top