- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 88 for readArg (0.24 sec)
-
cmd/xl-storage_test.go
w := newStreamingBitrotWriter(storage, "", volName, fileName, size, algo, shardSize) reader := bytes.NewReader(data) for { // Using io.Copy instead of this loop will not work for us as io.Copy // will use bytes.Reader.WriteTo() which will not do shardSize'ed writes // causing error. n, err := reader.Read(shard) w.Write(shard[:n]) if err == nil { continue } if err == io.EOF {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 11 17:45:28 UTC 2024 - 66.7K bytes - Viewed (0) -
cmd/test-utils_test.go
var priv interface{} var err error priv, err = rsa.GenerateKey(crand.Reader, rsaBits) if err != nil { return nil, nil, fmt.Errorf("failed to generate private key: %w", err) } notBefore := time.Now() notAfter := notBefore.Add(validFor) serialNumberLimit := new(big.Int).Lsh(big.NewInt(1), 128) serialNumber, err := crand.Int(crand.Reader, serialNumberLimit) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
cmd/xl-storage-format-v2_gen.go
package cmd // Code generated by github.com/tinylib/msgp DO NOT EDIT. import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *ChecksumAlgo) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint8 zb0001, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err) return } (*z) = ChecksumAlgo(zb0001) } return } // EncodeMsg implements msgp.Encodable
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 29 19:14:09 UTC 2024 - 53.8K bytes - Viewed (0) -
cmd/bucket-replication-utils_gen.go
import ( "github.com/minio/minio/internal/bucket/replication" "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BucketReplicationResyncStatus) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001--
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 61.1K bytes - Viewed (0) -
cmd/bucket-handlers.go
apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, err) writeErrorResponse(ctx, w, apiErr, r.URL) return } const mapEntryOverhead = 200 var ( reader io.Reader fileSize int64 = -1 fileName string fanOutEntries = make([]minio.PutObjectFanOutEntry, 0, 100) ) maxParts := 1000 // Canonicalize the form values into http.Header.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
src/net/http/client_test.go
// Its Read returns readErr and increments *readCalls atomically. // Its Close returns nil and increments *closeCalls atomically. type issue18239Body struct { readCalls *int32 closeCalls *int32 readErr error } func (b issue18239Body) Read([]byte) (int, error) { atomic.AddInt32(b.readCalls, 1) return 0, b.readErr } func (b issue18239Body) Close() error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/optimizing-performance/configuration_cache.adoc
==== include::sample[dir="snippets/configurationCache/problemsFixedReuse/kotlin",files="build.gradle.kts[tags=fixed-reuse]"] include::sample[dir="snippets/configurationCache/problemsFixedReuse/groovy",files="build.gradle[tags=fixed-reuse]"] ==== <1> We wired the system property provider directly, without reading it at configuration time.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 29 16:24:12 UTC 2024 - 71.1K bytes - Viewed (0) -
src/debug/elf/file_test.go
if err != nil { t.Fatal(err) } reader := dwarf.Reader() idx := 0 for _, testEntry := range test.entries { if testEntry.entryNumber < idx { t.Fatalf("internal test error: %d < %d", testEntry.entryNumber, idx) } for ; idx < testEntry.entryNumber; idx++ { entry, err := reader.Next() if entry == nil || err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 22 16:22:42 UTC 2023 - 60.1K bytes - Viewed (0) -
src/net/http/transport.go
port = portMap[url.Scheme] } return net.JoinHostPort(idnaASCIIFromURL(url), port) } // bodyEOFSignal is used by the HTTP/1 transport when reading response // bodies to make sure we see the end of a response body before // proceeding and reading on the connection again. // // It wraps a ReadCloser but runs fn (if non-nil) at most // once, right before its final (error-producing) Read or Close call
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
t.Errorf("Unexpected failure during deletion: %v", err) } if err := store.Get(ctx, key, storage.GetOptions{}, &example.Pod{}); !storage.IsNotFound(err) { t.Errorf("Unexpected error on reading object: %v", err) } } func RunTestDeleteWithSuggestionAndConflict(ctx context.Context, t *testing.T, store storage.Interface) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0)