- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 178 for rawbuffer (0.29 sec)
-
test/fixedbugs/issue7921.go
} func bufferNoEscape2(xs []string) int { // ERROR "xs does not escape$" b := bytes.NewBuffer(make([]byte, 0, 64)) // ERROR "&bytes.Buffer{...} does not escape$" "make\(\[\]byte, 0, 64\) does not escape$" "inlining call to bytes.NewBuffer$" for _, x := range xs { b.WriteString(x) } return b.Len() // ERROR "inlining call to bytes.\(\*Buffer\).Len$" }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 14 19:43:26 UTC 2023 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/AbstractStreamingHasher.java
@CanIgnoreReturnValue public final Hasher putBytes(ByteBuffer readBuffer) { ByteOrder order = readBuffer.order(); try { readBuffer.order(ByteOrder.LITTLE_ENDIAN); return putBytesInternal(readBuffer); } finally { readBuffer.order(order); } } @CanIgnoreReturnValue private Hasher putBytesInternal(ByteBuffer readBuffer) { // If we have room for all of it, this is easy
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jun 15 20:59:00 UTC 2022 - 7.1K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/tcp.go
return msgBuilder.String(), err } var resBuffer bytes.Buffer buf := make([]byte, 1024+len(message)) for { n, err := conn.Read(buf) if err != nil && err != io.EOF { fwLog.Warnf("TCP read failed (already read %d bytes): %v", len(resBuffer.String()), err) return msgBuilder.String(), err } resBuffer.Write(buf[:n])
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 19:13:32 UTC 2023 - 4.9K bytes - Viewed (0) -
internal/ioutil/ioutil_test.go
src io.Reader skipLen int64 expected string }{ {bytes.NewBuffer([]byte("")), 0, ""}, {bytes.NewBuffer([]byte("")), 1, ""}, {bytes.NewBuffer([]byte("abc")), 0, "abc"}, {bytes.NewBuffer([]byte("abc")), 1, "bc"}, {bytes.NewBuffer([]byte("abc")), 2, "c"}, {bytes.NewBuffer([]byte("abc")), 3, ""}, {bytes.NewBuffer([]byte("abc")), 4, ""}, } for i, testCase := range testCases {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
src/compress/gzip/fuzz_test.go
} } f.Add(b) } f.Fuzz(func(t *testing.T, b []byte) { for _, multistream := range []bool{true, false} { r, err := NewReader(bytes.NewBuffer(b)) if err != nil { continue } r.Multistream(multistream) decompressed := bytes.NewBuffer(nil) if _, err := io.Copy(decompressed, r); err != nil { continue } if err := r.Close(); err != nil { continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 13 18:06:33 UTC 2022 - 2.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/udp.go
fwLog.Warnf("UDP write failed: %v", err) return msgBuilder.String(), err } var resBuffer bytes.Buffer buf := make([]byte, 1024+len(message)) n, err := conn.Read(buf) if err != nil && err != io.EOF { fwLog.Warnf("UDP read failed (already read %d bytes): %v", len(resBuffer.String()), err) return msgBuilder.String(), err } resBuffer.Write(buf[:n]) // format the output for forwarder response
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 17:19:22 UTC 2022 - 3.4K bytes - Viewed (0) -
src/archive/tar/fuzz_test.go
if err != nil { return } buf := bytes.NewBuffer(nil) if _, err := io.Copy(buf, r); err != nil { continue } files = append(files, file{header: hdr, content: buf.Bytes()}) } // If we were unable to read anything out of the archive don't // bother trying to roundtrip it. if len(files) == 0 { return } out := bytes.NewBuffer(nil) w := NewWriter(out) for _, f := range files {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 13 18:06:33 UTC 2022 - 2.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/stream_test.go
"fmt" "io" "net/http" "reflect" "strings" "testing" "time" "golang.org/x/net/websocket" ) func TestStream(t *testing.T) { input := "some random text" r := NewReader(bytes.NewBuffer([]byte(input)), true, NewDefaultReaderProtocols()) r.SetIdleTimeout(time.Second) data, err := readWebSocket(r, t, nil) if !reflect.DeepEqual(data, []byte(input)) { t.Errorf("unexpected server read: %v", data) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 7.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/caching_object_test.go
newMockEncoder("1", "result1", nil), newMockEncoder("2", "", fmt.Errorf("mock error")), newMockEncoder("3", "result3", nil), } for _, encoder := range encoders { buffer := bytes.NewBuffer(nil) err := object.CacheEncode(encoder.identifier, encoder.encode, buffer) if a, e := err, encoder.expectedError; e != a { t.Errorf("%s: unexpected error: %v, expected: %v", encoder.identifier, a, e) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 23 15:26:38 UTC 2022 - 5.1K bytes - Viewed (0)