Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 67 for rawbuffer (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

                }
    
                if (closed) {
                  throw IOException("stream closed")
                } else if (readBuffer.size > 0L) {
                  // Prepare to read bytes. Start by moving them to the caller's buffer.
                  readBytesDelivered = readBuffer.read(sink, minOf(byteCount, readBuffer.size))
                  readBytes.update(total = readBytesDelivered)
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/SocketConnection.java

                BufferCaster.cast(buffer).limit(0);
            }
    
            @Override
            public int read() throws IOException {
                int nread = read(readBuffer, 0, 1);
                if (nread <= 0) {
                    return nread;
                }
                return readBuffer[0];
            }
    
            @Override
            public int read(byte[] dest, int offset, int max) throws IOException {
                if (max == 0) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:37 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top