- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 1,066 for readOp (0.1 sec)
-
cmd/object-api-interface.go
if etag != "" { header.Set("ETag", etag) } Range := &HTTPRangeSpec{Start: startOffset, End: startOffset + length} reader, err := api.GetObjectNInfo(ctx, bucket, object, Range, header, opts) if err != nil { return err } defer reader.Close() _, err = xioutil.Copy(writer, reader) return err
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 22 21:57:20 UTC 2024 - 17.3K bytes - Viewed (0) -
cmd/local-locker_gen.go
return } case "Writes": z.Writes, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Writes") return } case "Reads": z.Reads, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Reads") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 13.9K bytes - Viewed (0) -
cmd/metacache-stream_test.go
"src/compress/gzip/testdata/issue6550.gz.base64", "src/compress/lzw/", "src/compress/lzw/reader.go", "src/compress/lzw/reader_test.go", "src/compress/lzw/writer.go", "src/compress/lzw/writer_test.go", "src/compress/testdata/", "src/compress/testdata/e.txt", "src/compress/testdata/gettysburg.txt", "src/compress/testdata/pi.txt", "src/compress/zlib/", "src/compress/zlib/example_test.go", "src/compress/zlib/reader.go", "src/compress/zlib/reader_test.go", "src/compress/zlib/writer.go", "src/compress/z...
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 15K bytes - Viewed (0) -
cmd/dummy-data-generator_test.go
checkEq(readAll(r), readAll(NewDummyDataGen(100-int64(len(alphabets)), 0))) } // Compares all the bytes returned by the given readers. Any Read // errors cause a `false` result. A string describing the error is // also returned. func cmpReaders(r1, r2 io.Reader) (bool, string) { bufLen := 32 * 1024 b1, b2 := make([]byte, bufLen), make([]byte, bufLen) for i := 0; true; i++ { n1, e1 := io.ReadFull(r1, b1)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jul 02 15:13:05 UTC 2024 - 4.7K bytes - Viewed (0) -
src/bufio/bufio.go
// NewReaderSize returns a new [Reader] whose buffer has at least the specified // size. If the argument io.Reader is already a [Reader] with large enough // size, it returns the underlying [Reader]. func NewReaderSize(rd io.Reader, size int) *Reader { // Is it already a Reader? b, ok := rd.(*Reader) if ok && len(b.buf) >= size { return b } r := new(Reader) r.reset(make([]byte, max(size, minReadBufferSize)), rd)
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Thu Oct 12 14:39:08 UTC 2023 - 21.8K bytes - Viewed (0) -
docs/bucket/replication/sio-error.sh
done sleep 10 ./mc alias set myminio1 http://localhost:9001 minioadmin minioadmin ./mc alias set myminio2 http://localhost:9101 minioadmin minioadmin ./mc ready myminio1 ./mc ready myminio2 sleep 1 ./mc mb myminio1/testbucket/ --with-lock ./mc mb myminio2/testbucket/ --with-lock ./mc encrypt set sse-s3 my-minio-key myminio1/testbucket/
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat May 18 18:19:01 UTC 2024 - 1.7K bytes - Viewed (0) -
docs/bucket/replication/delete-replication.sh
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 09:42:21 UTC 2024 - 3.9K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") drwm2 := NewDRWMutex(ds, "simplelock") ctx2, cancel2 := context.WithCancel(context.Background()) if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
src/archive/tar/reader_test.go
} } } // testNonEmptyReader wraps an io.Reader and ensures that // Read is never called with an empty buffer. type testNonEmptyReader struct{ io.Reader } func (r testNonEmptyReader) Read(b []byte) (int, error) { if len(b) == 0 { return 0, errors.New("unexpected empty Read call") } return r.Reader.Read(b) } func TestFileReader(t *testing.T) { type (
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Thu Oct 03 15:48:09 UTC 2024 - 46.9K bytes - Viewed (0) -
internal/ioutil/read_file.go
_, err = io.ReadFull(f, dst) return dst, st, err } // ReadFile reads the named file and returns the contents. // A successful call returns err == nil, not err == EOF. // Because ReadFile reads the whole file, it does not treat an EOF from Read // as an error to be reported. // // passes NOATIME flag for reads on Unix systems to avoid atime updates. func ReadFile(name string) ([]byte, error) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Dec 09 18:17:51 UTC 2023 - 2.3K bytes - Viewed (0)