Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 192 for chunkOf (0.44 sec)

  1. src/strings/strings.go

    			chunkMax = len(s)
    		}
    	}
    
    	var b Builder
    	b.Grow(n)
    	b.WriteString(s)
    	for b.Len() < n {
    		chunk := n - b.Len()
    		if chunk > b.Len() {
    			chunk = b.Len()
    		}
    		if chunk > chunkMax {
    			chunk = chunkMax
    		}
    		b.WriteString(b.String()[:chunk])
    	}
    	return b.String()
    }
    
    // ToUpper returns s with all Unicode letters mapped to their upper case.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 16:48:16 UTC 2024
    - 31.2K bytes
    - Viewed (0)
  2. src/image/png/writer.go

    	}
    	e.writeChunk(e.tmp[:3*len(p)], "PLTE")
    	if last != -1 {
    		e.writeChunk(e.tmp[3*256:3*256+1+last], "tRNS")
    	}
    }
    
    // An encoder is an io.Writer that satisfies writes by writing PNG IDAT chunks,
    // including an 8-byte header and 4-byte CRC checksum per Write call. Such calls
    // should be relatively infrequent, since writeIDATs uses a [bufio.Writer].
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 11 17:08:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  3. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

              contentLength = header.substring(15).trim().toLong()
            }
            if (lowercaseHeader.startsWith("transfer-encoding:") &&
              lowercaseHeader.substring(18).trim() == "chunked"
            ) {
              chunked = true
            }
          }
    
          val peek = dispatcher.peek()
          for (response in peek.informationalResponses) {
            writeHttpResponse(socket, sink, response)
          }
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  4. src/runtime/arena_test.go

    		finalized.Store(true)
    	})
    
    	// Write three chunks worth of pointer data. Three gives us a
    	// high likelihood that when we write 2 later, we'll get the behavior
    	// we want.
    	a := NewUserArena()
    	for i := 0; i < int(UserArenaChunkBytes/goarch.PtrSize*3); i++ {
    		var x any
    		x = (*smallPointer)(nil)
    		a.New(&x)
    	}
    	a.Free()
    
    	// Recycle the arena chunks.
    	GC()
    	GC()
    
    	a = NewUserArena()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go

    		// write one chunk at a time
    		for i, chunk := range strings.Split(responseHeadersAndBody, "split") {
    			if i > 0 {
    				n, err := hic.Write([]byte("split"))
    				require.Equal(t, n, len("split"))
    				require.NoError(t, err)
    			}
    			n, err := hic.Write([]byte(chunk))
    			require.Equal(t, n, len(chunk))
    			require.NoError(t, err)
    		}
    		assert.True(t, hic.initialized)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 02:21:50 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  6. api/openapi-spec/v3/apis__networking.k8s.io__v1_openapi.json

                "in": "query",
                "name": "limit",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 324.8K bytes
    - Viewed (0)
  7. okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt

          .assertLogMatch(Regex("""Transfer-encoding: chunked"""))
          .assertLogEqual("<-- END HTTP (streaming)")
          .assertNoMoreLogs()
        applicationLogs
          .assertLogEqual("--> GET $url")
          .assertLogEqual("--> END GET")
          .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms\)"""))
          .assertLogEqual("Content-Type: text/event-stream")
          .assertLogMatch(Regex("""Transfer-encoding: chunked"""))
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 06 09:14:38 UTC 2024
    - 37.6K bytes
    - Viewed (0)
  8. src/net/http/serve_test.go

    	}
    	got := string(bs)
    	if got != "" {
    		t.Errorf("read %q from server; want nothing", got)
    	}
    }
    
    // Tests that chunked server responses that write 1 byte at a time are
    // buffered before chunk headers are added, not after chunk headers.
    func TestServerBufferedChunking(t *testing.T) {
    	conn := new(testConn)
    	conn.readBuf.Write([]byte("GET / HTTP/1.1\r\nHost: foo\r\n\r\n"))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 202K bytes
    - Viewed (0)
  9. src/internal/bytealg/compare_loong64.s

    	MOVV	R5, R14
    	JMP	entry
    r2_lt_r1:
    	MOVV	R7, R14	// R14 is min(R4, R5)
    entry:
    	ADDV	R4, R14, R12	// R6 start of a, R14 end of a
    	BEQ	R4, R12, samebytes // length is 0
    
    	SRLV	$4, R14		// R14 is number of chunks
    	BEQ	R0, R14, byte_loop
    
    	// make sure both a and b are aligned.
    	OR	R4, R6, R15
    	AND	$7, R15
    	BNE	R0, R15, byte_loop
    
    	PCALIGN	$16
    chunk16_loop:
    	BEQ	R0, R14, byte_loop
    	MOVV	(R4), R8
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 15:04:25 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  10. src/internal/zstd/zstd.go

    		r.blockOffset += int64(size)
    		return nil
    	}
    
    	var skip []byte
    	const chunk = 1 << 20 // 1M
    	for size >= chunk {
    		if len(skip) == 0 {
    			skip = make([]byte, chunk)
    		}
    		if _, err := io.ReadFull(r.r, skip); err != nil {
    			return r.wrapNonEOFError(relativeOffset, err)
    		}
    		relativeOffset += chunk
    		size -= chunk
    	}
    	if size > 0 {
    		if len(skip) == 0 {
    			skip = make([]byte, size)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jan 30 04:10:45 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top