- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 83 for rawbuffer (0.13 sec)
-
pilot/pkg/networking/util/internal_upstream.go
TransportSocket: &core.TransportSocket{ Name: "raw_buffer", ConfigType: &core.TransportSocket_TypedConfig{TypedConfig: protoconv.MessageToAny(&rawbuffer.RawBuffer{})}, }, })}, } var TunnelHostInternalUpstreamTransportSocket = &core.TransportSocket{ Name: "internal_upstream",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Sep 22 21:35:52 UTC 2023 - 2.1K bytes - Viewed (0) -
pkg/wellknown/wellknown.go
// HTTPGRPCAccessLog sink for the HTTP gRPC access log service HTTPGRPCAccessLog = "envoy.access_loggers.http_grpc" ) // Transport socket names const ( // TransportSocket RawBuffer TransportSocketRawBuffer = "envoy.transport_sockets.raw_buffer" // TransportSocketTLS labels the "envoy.transport_sockets.tls" filter. TransportSocketTLS = "envoy.transport_sockets.tls" // TransportSocket Quic
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 11 15:29:30 UTC 2023 - 4K bytes - Viewed (0) -
src/cmd/go/internal/work/exec_test.go
} } } func TestEncodeDecodeFuzz(t *testing.T) { if testing.Short() { t.Skip("fuzz test is slow") } t.Parallel() nRunes := sys.ExecArgLengthLimit + 100 rBuffer := make([]rune, nRunes) buf := bytes.NewBuffer([]byte(string(rBuffer))) seed := time.Now().UnixNano() t.Logf("rand seed: %v", seed) rng := rand.New(rand.NewSource(seed)) for i := 0; i < 50; i++ { // Generate a random string of runes.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Oct 02 13:15:42 UTC 2021 - 1.8K bytes - Viewed (0) -
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) -
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) -
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)