Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 426 for SENT (0.12 sec)

  1. android/guava/src/com/google/common/base/Ascii.java

      /**
       * Cancel: A control character used to indicate that the data with which it is sent is in error or
       * is to be disregarded.
       *
       * @since 8.0
       */
      public static final byte CAN = 24;
    
      /**
       * End of Medium: A control character associated with the sent data which may be used to identify
       * the physical end of the medium, or the end of the used, or wanted, portion of information
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

      }
    
      fun acceptFrame() {
        frameCount++
      }
    
      /** Maximum length of an outbound data frame.  */
      fun maxOutboundDataLength(): Int = writer.maxDataLength()
    
      /** Count of frames sent or received.  */
      fun frameCount(): Int = frameCount
    
      fun sendFrame(): Http2Writer {
        outFrames.add(OutFrame(frameCount++, bytesOut.size, false))
        return writer
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  3. docs/metrics/prometheus/grafana/minio-dashboard.json

              "expr": "sum by (server) (rate(minio_s3_traffic_sent_bytes{job=~\"$scrape_jobs\"}[$__rate_interval]))",
              "interval": "1m",
              "intervalFactor": 2,
              "legendFormat": "Data Sent [{{server}}]",
              "refId": "A"
            }
          ],
          "title": "S3 API Egress Rate ",
          "type": "timeseries"
        },
        {
          "datasource": {
            "type": "prometheus",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 14:51:03 UTC 2024
    - 93K bytes
    - Viewed (0)
  4. cmd/api-headers.go

    	"github.com/minio/minio/internal/crypto"
    	xhttp "github.com/minio/minio/internal/http"
    	xxml "github.com/minio/xxml"
    )
    
    // Returns a hexadecimal representation of time at the
    // time response is sent to the client.
    func mustGetRequestID(t time.Time) string {
    	return fmt.Sprintf("%X", t.UnixNano())
    }
    
    // setEventStreamHeaders to allow proxies to avoid buffering proxy responses
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

                  workerRunningState = IDLE;
                  return;
                }
              }
              // Remove the interrupt bit before each task. The interrupt is for the "current task" when
              // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
              // by a previous one in the queue being interrupted.
              interruptedDuringTask |= Thread.interrupted();
              try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

                  workerRunningState = IDLE;
                  return;
                }
              }
              // Remove the interrupt bit before each task. The interrupt is for the "current task" when
              // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
              // by a previous one in the queue being interrupted.
              interruptedDuringTask |= Thread.interrupted();
              try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  7. internal/store/queuestore.go

    	"github.com/valyala/bytebufferpool"
    )
    
    const (
    	defaultLimit = 100000 // Default store limit.
    	defaultExt   = ".unknown"
    	compressExt  = ".snappy"
    )
    
    // errLimitExceeded error is sent when the maximum limit is reached.
    var errLimitExceeded = errors.New("the maximum store limit reached")
    
    // QueueStore - Filestore for persisting items.
    type QueueStore[_ any] struct {
    	sync.RWMutex
    	entryLimit uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  8. docs/en/docs/tutorial/body-updates.md

    ///
    
    That would generate a `dict` with only the data that was set when creating the `item` model, excluding default values.
    
    Then you can use this to generate a `dict` with only the data that was set (sent in the request), omitting default values:
    
    //// tab | Python 3.10+
    
    ```Python hl_lines="32"
    {!> ../../docs_src/body_updates/tutorial002_py310.py!}
    ```
    
    ////
    
    //// tab | Python 3.9+
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Request.kt

        /**
         * Override the [Request.url] for caching, if it is either polluted with
         * transient query params, or has a canonical URL possibly for a CDN.
         *
         * Note that POST requests will not be sent to the server if this URL is set
         * and matches a cached response.
         */
        fun cacheUrlOverride(cacheUrlOverride: HttpUrl?) =
          apply {
            this.cacheUrlOverride = cacheUrlOverride
          }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:17:44 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/io/CharStreams.java

       * writer will close the target if it is {@link Closeable}, and flushing the writer will flush the
       * target if it is {@link java.io.Flushable}.
       *
       * @param target the object to which output will be sent
       * @return a new Writer object, unless target is a Writer, in which case the target is returned
       */
      public static Writer asWriter(Appendable target) {
        if (target instanceof Writer) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 10.9K bytes
    - Viewed (0)
Back to top