- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,081 for readArg (0.17 sec)
-
cmd/erasure-object.go
readers[index] = newBitrotReader(disk, metaArr[index].Data, bucket, partPath, tillOffset, checksumInfo.Algorithm, checksumInfo.Hash, erasure.ShardSize()) // Prefer local disks prefer[index] = disk.Hostname() == "" } written, err := erasure.Decode(ctx, writer, readers, partOffset, partLength, partSize, prefer)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K 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) -
src/compress/flate/inflate.go
// The actual read interface needed by [NewReader]. // If the passed in io.Reader does not also have ReadByte, // the [NewReader] will introduce its own buffering. type Reader interface { io.Reader io.ByteReader } // Decompress state. type decompressor struct { // Input source. r Reader rBuf *bufio.Reader // created if provided io.Reader does not implement io.ByteReader roffset int64
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 23:20:03 UTC 2023 - 20.4K 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) -
src/main/java/org/codelibs/fess/es/config/cbean/cq/bs/BsElevateWordCQ.java
if (opLambda != null) { opLambda.callback(builder); } } public void setReading_SpanTerm(String reading) { setReading_SpanTerm("reading", null); } public void setReading_SpanTerm(String reading, ConditionOptionCall<SpanTermQueryBuilder> opLambda) { SpanTermQueryBuilder builder = regSpanTermQ("reading", reading);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 64.2K 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) -
pkg/wasm/imagefetcher.go
func (k *wasmKeyChain) Resolve(target authn.Resource) (authn.Authenticator, error) { if bytes.Equal(k.data, []byte("null")) { // Filter out key chain with content "null" to prevent crash at underlying docker library. // Remove this check when https://github.com/docker/cli/pull/3434 is merged. return nil, fmt.Errorf("") } reader := bytes.NewReader(k.data)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Dec 10 05:44:51 UTC 2023 - 12K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/bsentity/BsElevateWord.java
this.permissions = value; } public String getReading() { checkSpecifiedProperty("reading"); return convertEmptyToNull(reading); } public void setReading(String value) { registerModifiedProperty("reading"); this.reading = value; } public String getSuggestWord() { checkSpecifiedProperty("suggestWord");
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.1K bytes - Viewed (0)