- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for rawbuffer (0.14 sec)
-
src/encoding/csv/reader.go
func (r *Reader) readLine() ([]byte, error) { line, err := r.r.ReadSlice('\n') if err == bufio.ErrBufferFull { r.rawBuffer = append(r.rawBuffer[:0], line...) for err == bufio.ErrBufferFull { line, err = r.r.ReadSlice('\n') r.rawBuffer = append(r.rawBuffer, line...) } line = r.rawBuffer } readSize := len(line) if readSize > 0 && err == io.EOF { err = nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:32:28 UTC 2024 - 14.2K bytes - Viewed (0) -
istioctl/pkg/writer/compare/testdata/configdump_diff.json
} ], "transport_socket": { "name": "raw_buffer", "typed_config": { "@type": "type.googleapis.com/envoy.extensions.transport_sockets.raw_buffer.v3.RawBuffer" } } } }, "metadata": { "filter_metadata": {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 10:02:09 UTC 2024 - 51.6K bytes - Viewed (0) -
istioctl/pkg/writer/compare/testdata/configdump.json
} ], "transport_socket": { "name": "raw_buffer", "typed_config": { "@type": "type.googleapis.com/envoy.extensions.transport_sockets.raw_buffer.v3.RawBuffer" } } } }, "metadata": { "filter_metadata": {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 10:02:09 UTC 2024 - 52K 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) -
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) -
src/bytes/buffer_test.go
} s += string(fub) check(t, testname+" (fill 4)", buf, s) } return s } func TestNewBuffer(t *testing.T) { buf := NewBuffer(testBytes) check(t, "NewBuffer", buf, testString) } var buf Buffer // Calling NewBuffer and immediately shallow copying the Buffer struct // should not result in any allocations. // This can be used to reset the underlying []byte of an existing Buffer.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:31:36 UTC 2024 - 18.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/framer/framer_test.go
data := []byte{ 0x00, 0x00, 0x00, 0x04, 0x01, 0x02, 0x03, 0x04, 0x00, 0x00, 0x00, 0x03, 0x05, 0x06, 0x07, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x08, } b := bytes.NewBuffer(data) r := NewLengthDelimitedFrameReader(io.NopCloser(b)) buf := make([]byte, 1) if n, err := r.Read(buf); err != io.ErrShortBuffer && n != 1 && bytes.Equal(buf, []byte{0x01}) { t.Fatalf("unexpected: %v %d %v", err, n, buf)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 13:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/SocketConnection.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 11.8K bytes - Viewed (0) -
operator/pkg/util/progress/progress_test.go
// limitations under the License. package progress import ( "bytes" "io" "testing" "istio.io/istio/operator/pkg/name" ) func TestProgressLog(t *testing.T) { buf := bytes.NewBuffer(nil) testBuf := io.Writer(buf) testWriter = &testBuf expected := "" expect := func(e string) { t.Helper() // In buffer mode we don't overwrite old data, so we are constantly appending to the expected
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 2.1K bytes - Viewed (0) -
src/runtime/pprof/protomem_test.go
}() for _, sz := range []int{128, 256} { genericAllocFunc[uint32](sz / 4) } for _, sz := range []int{32, 64} { genericAllocFunc[uint64](sz / 8) } runtime.GC() buf := bytes.NewBuffer(nil) if err := WriteHeapProfile(buf); err != nil { t.Fatalf("writing profile: %v", err) } p, err := profile.Parse(buf) if err != nil { t.Fatalf("profile.Parse: %v", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 14:38:45 UTC 2024 - 6.7K bytes - Viewed (0)