Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for buffered (0.07 sec)

  1. cmd/admin-handlers.go

    		return
    	}
    	setEventStreamHeaders(w)
    
    	// Trace Publisher and peer-trace-client uses nonblocking send and hence does not wait for slow receivers.
    	// Keep 100k buffered channel.
    	// If receiver cannot keep up with that we drop events.
    	traceCh := make(chan []byte, 100000)
    	peers, _ := newPeerRestClients(globalEndpoints)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

      fun contentDisagreesWithChunkedHeaderBodyTooLong() {
        val builder =
          MockResponse
            .Builder()
            .chunkedBody("abc", 3)
        val buffer = Buffer()
        builder.body!!.writeTo(buffer)
        buffer.writeUtf8("\r\nYOU SHOULD NOT SEE THIS")
        builder.body(buffer)
        builder.clearHeaders()
        builder.addHeader("Transfer-encoding: chunked")
        server.enqueue(builder.build())
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  3. cmd/server_test.go

    	c.Assert(err, nil)
    	c.Assert(response.StatusCode, http.StatusOK)
    
    	var buffer bytes.Buffer
    	// data to be written into buffer.
    	data := "1234567890"
    	// seed the random number generator once.
    	rand.Seed(3)
    	// generate a random number between 13 and 200.
    	randInt := getRandomRange(13, 200, -1)
    	// write into buffer till length of the buffer is greater than the generated random number.
    	for i := 0; i <= randInt; i += 10 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118.1K bytes
    - Viewed (0)
  4. cmd/object-handlers_test.go

    	}{
    		{byteData: generateBytesData(6 * humanize.KiByte)},
    	}
    	h := md5.New()
    	h.Write(bytesData[0].byteData)
    	bytesData[0].md5sum = hex.EncodeToString(h.Sum(nil))
    
    	buffers := []*bytes.Buffer{
    		new(bytes.Buffer),
    		new(bytes.Buffer),
    	}
    	bucketInfo, err := obj.GetBucketInfo(context.Background(), bucketName, BucketOptions{})
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

            ).hostnameVerifier(RecordingHostnameVerifier())
            .build()
        server.useHttps(handshakeCertificates.sslSocketFactory())
      }
    
      private fun gzip(data: String): Buffer {
        val result = Buffer()
        val sink = GzipSink(result).buffer()
        sink.writeUtf8(data)
        sink.close()
        return result
      }
    
      private fun cancelLater(
        call: Call,
        delay: Long,
      ): Thread {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 146.6K bytes
    - Viewed (0)
  6. tensorflow/c/c_api.cc

        result = session->Run(run_options_proto, input_pairs, output_tensor_names,
                              target_oper_names, &outputs, &run_metadata_proto);
    
        // Serialize back to upstream client, who now owns the new buffer
        if (run_metadata != nullptr) {
          status->status = MessageToBuffer(run_metadata_proto, run_metadata);
          if (!status->status.ok()) return;
        }
      } else {
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Tue May 13 06:30:43 UTC 2025
    - 102.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/SmbFile.java

            }
            if (b == null || b.length == 0) {
                throw new IllegalArgumentException("Buffer array cannot be null or empty");
            }
            if (bsize <= 0) {
                throw new IllegalArgumentException("Buffer size must be positive");
            }
    
            try {
                if (isDirectory()) {
                    // Ensure destination exists as directory
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 103.2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/SmbFile.java

             * actual files has a smaller maxBufSize this could be
             * incorrect. To handle this properly it is necessary
             * to redirect the tree to the target server first before
             * establishing buffer size. These exists() calls facilitate
             * that.
             */
            resolveDfs(null);
    
            /* It is invalid for the source path to be a child of the destination
             * path or visa versa.
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 112.2K bytes
    - Viewed (0)
  9. cmd/sts-handlers_test.go

        }
    }
    `,
    	}
    	exportContent := map[string][]byte{}
    	for k, v := range exportContentStrings {
    		exportContent[k] = []byte(v)
    	}
    
    	var importContent []byte
    	{
    		var b bytes.Buffer
    		zipWriter := zip.NewWriter(&b)
    		rawDataFn := func(r io.Reader, filename string, sz int) error {
    			header, zerr := zip.FileInfoHeader(dummyFileInfo{
    				name:    filename,
    				size:    int64(sz),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 100.2K bytes
    - Viewed (1)
  10. android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

    later.
    
      However, this bottle was NOT marked `poison,' so Alice ventured
    to taste it, and finding it very nice, (it had, in fact, a sort
    of mixed flavour of cherry-tart, custard, pine-apple, roast
    turkey, toffee, and hot buttered toast,) she very soon finished
    it off.
    
         *       *       *       *       *       *       *
    
             *       *       *       *       *       *
    
         *       *       *       *       *       *       *
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Apr 21 02:27:51 UTC 2017
    - 145.2K bytes
    - Viewed (0)
Back to top