Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 398 for readDir (0.19 seconds)

  1. cmd/erasure-server-pool.go

    // Errors are ignored, only errors from the callback are returned.
    // For now only direct file paths are supported.
    func (z *erasureServerPools) GetRawData(ctx context.Context, volume, file string, fn func(r io.Reader, host string, disk string, filename string, info StatInfo) error) error {
    	found := 0
    	for _, s := range z.serverPools {
    		for _, set := range s.sets {
    			for _, disk := range set.getDisks() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  2. cmd/erasure-object_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	bucket := "bucket"
    	object := "object"
    	opts := ObjectOptions{}
    	buf := make([]byte, smallFileThreshold*16)
    	if _, err = io.ReadFull(crand.Reader, buf); err != nil {
    		t.Fatal(err)
    	}
    
    	// Test use case 1: All disks are online, xl.meta are present, but data are missing
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.3K bytes
    - Click Count (0)
  3. doc/go_spec.html

    [<a href="#Go_1.18">Go 1.18</a>].
    </p>
    
    <pre>
    type Reader interface {
    	Read(p []byte) (n int, err error)
    	Close() error
    }
    
    type Writer interface {
    	Write(p []byte) (n int, err error)
    	Close() error
    }
    
    // ReadWriter's methods are Read, Write, and Close.
    type ReadWriter interface {
    	Reader  // includes methods of Reader in ReadWriter's method set
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Dec 02 23:07:19 GMT 2025
    - 286.5K bytes
    - Click Count (1)
  4. cmd/batch-handlers.go

    						humanize.Ordinal(attempts), res.UploadID, tgtBucket, tgtObject, aerr))
    				attempts++
    				time.Sleep(time.Second)
    			}
    		}
    	}()
    
    	var (
    		hr    *hash.Reader
    		pInfo PartInfo
    	)
    
    	for i := range partsCount {
    		gopts := minio.GetObjectOptions{
    			VersionID:  srcObjInfo.VersionID,
    			PartNumber: i + 1,
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  5. api/go1.3.txt

    pkg archive/tar, const TypeGNUSparse = 83
    pkg archive/tar, const TypeGNUSparse ideal-char
    pkg archive/tar, type Header struct, Xattrs map[string]string
    pkg compress/gzip, method (*Reader) Reset(io.Reader) error
    pkg crypto/tls, const CurveP256 = 23
    pkg crypto/tls, const CurveP256 CurveID
    pkg crypto/tls, const CurveP384 = 24
    pkg crypto/tls, const CurveP384 CurveID
    pkg crypto/tls, const CurveP521 = 25
    pkg crypto/tls, const CurveP521 CurveID
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Jun 02 02:45:00 GMT 2014
    - 117K bytes
    - Click Count (0)
  6. cmd/sts-handlers_test.go

    	for k, v := range exportContentStrings {
    		exportContent[k] = []byte(v)
    	}
    
    	var importContent []byte
    	{
    		var b bytes.Buffer
    		zipWriter := zip.NewWriter(&b)
    		rawDataFn := func(r io.Reader, filename string, sz int) error {
    			header, zerr := zip.FileInfoHeader(dummyFileInfo{
    				name:    filename,
    				size:    int64(sz),
    				mode:    0o600,
    				modTime: time.Now(),
    				isDir:   false,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 103.4K bytes
    - Click Count (1)
  7. okhttp/api/jvm/okhttp.api

    	public fun <init> ()V
    	public final fun byteStream ()Ljava/io/InputStream;
    	public final fun byteString ()Lokio/ByteString;
    	public final fun bytes ()[B
    	public final fun charStream ()Ljava/io/Reader;
    	public fun close ()V
    	public abstract fun contentLength ()J
    	public abstract fun contentType ()Lokhttp3/MediaType;
    	public static final fun create (Ljava/lang/String;Lokhttp3/MediaType;)Lokhttp3/ResponseBody;
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 70.2K bytes
    - Click Count (0)
  8. cmd/xl-storage-format-v2.go

    	}
    }
    
    // readXLMetaNoData will load the metadata, but skip data segments.
    // This should only be used when data is never interesting.
    // If data is not xlv2, it is returned in full.
    func readXLMetaNoData(r io.Reader, size int64) ([]byte, error) {
    	initial := size
    	hasFull := true
    	if initial > metaDataReadDefault {
    		initial = metaDataReadDefault
    		hasFull = false
    	}
    
    	buf := metaDataPoolGet()[:initial]
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  9. cmd/object-handlers_test.go

    			}
    		}
    		off, length, err = rs.GetOffsetLength(objectLength(oi))
    		if err != nil {
    			t.Fatalf("Object: %s Case %d ByteRange: %s: Unexpected err: %v", object, i+1, byteRange, err)
    		}
    
    		readers := []io.Reader{}
    		cumulativeSum := int64(0)
    		for _, p := range oi.partLengths {
    			readers = append(readers, NewDummyDataGen(p, cumulativeSum))
    			cumulativeSum += p
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
  10. okhttp/api/android/okhttp.api

    	public fun <init> ()V
    	public final fun byteStream ()Ljava/io/InputStream;
    	public final fun byteString ()Lokio/ByteString;
    	public final fun bytes ()[B
    	public final fun charStream ()Ljava/io/Reader;
    	public fun close ()V
    	public abstract fun contentLength ()J
    	public abstract fun contentType ()Lokhttp3/MediaType;
    	public static final fun create (Ljava/lang/String;Lokhttp3/MediaType;)Lokhttp3/ResponseBody;
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 70.3K bytes
    - Click Count (0)
Back to Top