- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 67 for rawbuffer (0.16 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) -
pilot/pkg/xds/filters/filters.go
}, } RawBufferTransportSocket = &core.TransportSocket{ Name: wellknown.TransportSocketRawBuffer, ConfigType: &core.TransportSocket_TypedConfig{ TypedConfig: protoconv.MessageToAny(&rawbuffer.RawBuffer{}), }, } Cors = &hcm.HttpFilter{ Name: wellknown.CORS, ConfigType: &hcm.HttpFilter_TypedConfig{ TypedConfig: protoconv.MessageToAny(&cors.Cors{}), }, } Fault = &hcm.HttpFilter{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 09 09:24:25 UTC 2024 - 15.5K bytes - Viewed (0) -
istioctl/pkg/describe/testdata/describe/http_config.json
"match": {}, "transport_socket": { "name": "envoy.transport_sockets.raw_buffer", "typed_config": { "@type": "type.googleapis.com/envoy.extensions.transport_sockets.raw_buffer.v3.RawBuffer" } } } ] } } ] }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 13.7K 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) -
staging/src/k8s.io/apiserver/pkg/endpoints/audit_test.go
}{ { "get", func(server string) (*http.Request, error) { return http.NewRequest("GET", server+"/"+prefix+"/"+testGroupVersion.Group+"/"+testGroupVersion.Version+"/namespaces/other/simple/c", bytes.NewBuffer(simpleFooJSON)) }, 200, 2, []eventCheck{ noRequestBody(1), responseBodyMatches(1, `{.*"name":"c".*}`),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 14 23:04:34 UTC 2022 - 12.1K 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/api/apitesting/roundtrip/compatibility.go
jsonBytes := bytes.NewBuffer(nil) if err := c.JSON.Encode(obj, jsonBytes); err != nil { t.Fatalf("error encoding json: %v", err) } yamlBytes := bytes.NewBuffer(nil) if err := c.YAML.Encode(obj, yamlBytes); err != nil { t.Fatalf("error encoding yaml: %v", err) } protoBytes := bytes.NewBuffer(nil) if err := c.Proto.Encode(obj, protoBytes); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 16:38:32 UTC 2023 - 17.8K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/printers/tableprinter_test.go
for _, test := range tests { // Create the table from the columns and rows. table := &metav1.Table{ ColumnDefinitions: test.columns, Rows: test.rows, } // Print the table out := bytes.NewBuffer([]byte{}) printer := NewTablePrinter(test.options) printer.PrintObj(table, out) // Validate the printed table is empty. if len(out.String()) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Oct 30 15:08:43 UTC 2022 - 24.4K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/NGramSynonymTokenizer.java
int readCharFromBuffer() throws IOException { if (readBufferIndex >= readBufferLen) { readBufferLen = input.read(readBuffer); if (readBufferLen == -1) { return -1; } readBufferIndex = 0; } final int c = readBuffer[readBufferIndex++]; nextBlkStart++; return c; } boolean isDelimiter(final int c) {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 17K 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)