Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 426 for SENT (0.02 sec)

  1. cmd/metrics-v3-api.go

    		"Distribution of time to first byte across API calls", "name", "type", "le")
    
    	apiTrafficSentBytesMD = NewCounterMD(apiTrafficSentBytes,
    		"Total number of bytes sent", "type")
    	apiTrafficRecvBytesMD = NewCounterMD(apiTrafficRecvBytes,
    		"Total number of bytes received", "type")
    )
    
    // loadAPIRequestsHTTPMetrics - reads S3 HTTP metrics.
    //
    // This is a `MetricsLoaderFn`.
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/Cookie.kt

       *
       * The values of this attribute determine whether this cookie is sent for cross-site calls:
       *
       *  - "Strict": the cookie is omitted when the subject URL is an embedded resource or a
       *    potentially-destructive navigation.
       *
       *  - "Lax": the cookie is omitted when the subject URL is an embedded resource. It is sent for
       *    potentially-destructive navigation. This is the default value.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:12:05 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  3. internal/grid/benchmark_test.go

    						if debugReqs {
    							fmt.Println(err.Error())
    						}
    						b.Fatal(err.Error())
    					}
    					got := 0
    					sent := 0
    					go func() {
    						for i := 0; i < messages; i++ {
    							st.Requests <- append(GetByteBuffer()[:0], payload...)
    							if sent++; sent == messages {
    								close(st.Requests)
    								return
    							}
    						}
    					}()
    					err = st.Results(func(b []byte) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/cache/LoadingCache.java

       * Cache.asMap().putIfAbsent} after loading has completed; if another value was associated with
       * {@code key} while the new value was loading then a removal notification will be sent for the
       * new value.
       *
       * <p>If the cache loader associated with this cache is known not to throw checked exceptions,
       * then prefer {@link #getUnchecked} over this method.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Aug 06 17:12:03 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  5. internal/event/target/postgresql.go

    			}
    			return err
    		}
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData); err != nil {
    		if IsConnErr(err) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/RequestBody.kt

       *
       * With regular HTTP calls the request always completes sending before the response may begin
       * receiving. With duplex the request and response may be interleaved! That is, request body bytes
       * may be sent after response headers or body bytes have been received.
       *
       * Though any call may be initiated as a duplex call, only web servers that are specially
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jan 25 14:41:37 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  7. internal/event/target/redis.go

    		}
    		target.firstPing = true
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and would've been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt

          assertThat(expected.message)
            .isEqualTo("Client-sent frames must be masked.")
        }
      }
    
      @Test fun serverSentFramesMustNotBeMasked() {
        data.write("8180".decodeHex())
        assertFailsWith<ProtocolException> {
          clientReader.processNextFrame()
        }.also { expected ->
          assertThat(expected.message)
            .isEqualTo("Server-sent frames must not be masked.")
        }
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  9. docs/en/docs/tutorial/security/simple-oauth2.md

    But for the login *path operation*, we need to use these names to be compatible with the spec (and be able to, for example, use the integrated API documentation system).
    
    The spec also states that the `username` and `password` must be sent as form data (so, no JSON here).
    
    ### `scope`
    
    The spec also says that the client can send another form field "`scope`".
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  10. internal/logger/target/http/http.go

    }
    
    // Cancel - cancels the target.
    // All queued messages are flushed and the function returns afterwards.
    // All messages sent to the target after this function has been called will be dropped.
    func (h *Target) Cancel() {
    	h.status.Store(statusClosed)
    	h.storeCtxCancel()
    
    	// Wait for messages to be sent...
    	h.wg.Wait()
    
    	// Set logch to nil and close it.
    	// This will block all Send operations,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
Back to top