- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 348 for readArg (0.24 sec)
-
cmd/erasure-healing.go
var found int var notFound int var foundNotEmpty int var otherFound int for _, readErr := range errs { switch { case readErr == nil: found++ case readErr == errFileNotFound || readErr == errVolumeNotFound: notFound++ case readErr == errVolumeNotEmpty: foundNotEmpty++ default: otherFound++ } } found = found + foundNotEmpty + otherFound
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.8K bytes - Viewed (0) -
src/net/textproto/reader_test.go
package textproto import ( "bufio" "bytes" "io" "net" "reflect" "runtime" "strings" "sync" "testing" ) func reader(s string) *Reader { return NewReader(bufio.NewReader(strings.NewReader(s))) } func TestReadLine(t *testing.T) { r := reader("line1\nline2\n") s, err := r.ReadLine() if s != "line1" || err != nil { t.Fatalf("Line 1: %s, %v", s, err) } s, err = r.ReadLine()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 05 18:31:56 UTC 2024 - 14.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go
} // getResponseCode reads a http response from the given reader, returns the response, // the bytes read from the reader, and any error encountered func getResponse(r io.Reader) (*http.Response, []byte, error) { rawResponse := bytes.NewBuffer(make([]byte, 0, 256)) // Save the bytes read while reading the response headers into the rawResponse buffer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/config/analysis/local/istiod_analyze.go
ResourceName string } // ReaderSource is a tuple of a io.Reader and filepath. type ReaderSource struct { // Name is the name of the source (commonly the path to a file, but can be "-" for sources read from stdin or "" if completely synthetic). Name string // Reader is the reader instance to use. Reader io.Reader
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 21:06:13 UTC 2024 - 21.6K bytes - Viewed (0) -
src/internal/trace/generation.go
if err != nil { return fmt.Errorf("reading frame %d's PC for stack %d: %w", i+1, id, err) } funcID, err := binary.ReadUvarint(r) if err != nil { return fmt.Errorf("reading frame %d's funcID for stack %d: %w", i+1, id, err) } fileID, err := binary.ReadUvarint(r) if err != nil { return fmt.Errorf("reading frame %d's fileID for stack %d: %w", i+1, id, err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 22:14:45 UTC 2024 - 12.1K bytes - Viewed (0) -
src/runtime/profbuf.go
// reader. If the writer is called to write a new record and finds that // the output buffer has room for both the pending overflow entry and the // new record, the writer emits the pending overflow entry and the new // record into the buffer. If the reader is called to read data and finds // that the output buffer is empty but that there is a pending overflow // entry, the reader will return a synthesized record for the pending
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 18.2K bytes - Viewed (0) -
src/encoding/base32/base32_test.go
// error is returned. {r: badReader{data: []byte("MY====="), errs: []error{badErr}}, res: "", err: badErr}, // Reader returns invalid input data (too short) but no error. Verify io.ErrUnexpectedEOF // is returned. {r: badReader{data: []byte("MY====="), errs: []error{nil}}, res: "", err: io.ErrUnexpectedEOF}, // Reader returns invalid input data and an error. Verify the reader and not the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 16:25:54 UTC 2024 - 26K bytes - Viewed (0) -
cmd/update.go
return resp.Body, nil } var updateInProgress atomic.Uint32 // Function to get the reader from an architecture func downloadBinary(u *url.URL, mode string) (binCompressed []byte, bin []byte, err error) { transport := getUpdateTransport(30 * time.Second) var reader io.ReadCloser if u.Scheme == "https" || u.Scheme == "http" { reader, err = getUpdateReaderFromURL(u, transport, mode) if err != nil { return nil, nil, err
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 18.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
// returned on the STDOUT buffer. randomSize := 1024 * 1024 randomData := make([]byte, randomSize) if _, err := rand.Read(randomData); err != nil { t.Errorf("unexpected error reading random data: %v", err) } var stdout bytes.Buffer options := &remotecommand.StreamOptions{ Stdin: bytes.NewReader(randomData), Stdout: &stdout, } errorChan := make(chan error) go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
if (this.errorCode == null) { this.errorCode = errorCode condition.signalAll() } } } /** * Returns true if read timeouts should be enforced while reading response headers or body bytes. * We always do timeouts in the HTTP server role. For clients, we only do timeouts after the * request is transmitted. This is only interesting for duplex calls where the request and
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0)