Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 210 for Read (0.13 sec)

  1. internal/ioutil/read_file.go

    )
    
    // ReadFileWithFileInfo 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.
    func ReadFileWithFileInfo(name string) ([]byte, fs.FileInfo, error) {
    	f, err := OsOpenFile(name, readMode, 0o666)
    	if err != nil {
    		return nil, nil, err
    	}
    	defer f.Close()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 09 18:17:51 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  2. buildscripts/minio-upgrade.sh

    		up -d --build
    
    	add_alias
    
    	mc mb minio/minio-test/
    	mc cp ./minio minio/minio-test/to-read/
    	mc cp /etc/hosts minio/minio-test/to-read/hosts
    	mc anonymous set download minio/minio-test
    
    	verify_checksum_mc ./minio minio/minio-test/to-read/minio
    
    	curl -s http://127.0.0.1:9000/minio-test/to-read/hosts | sha256sum
    
    	MINIO_VERSION=dev docker-compose -f "buildscripts/upgrade-tests/compose.yml" stop
    }
    
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 05 11:39:55 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  3. cmd/tier-journal.go

    		return nil
    	}
    
    	return errors.New("no local drive found")
    }
    
    // rotate rotates the journal. If a read-only journal already exists it does
    // nothing. Otherwise renames the active journal to a read-only journal and
    // opens a new active journal.
    func (jd *tierDiskJournal) rotate() error {
    	// Do nothing if a read-only journal file already exists.
    	if _, err := os.Stat(jd.ReadOnlyPath()); err == nil {
    		return nil
    	}
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    type diskHealthWrapper struct {
    	tracker *healthDiskCtxValue
    	r       io.Reader
    	w       io.Writer
    }
    
    func (d *diskHealthWrapper) Read(p []byte) (int, error) {
    	if d.r == nil {
    		return 0, fmt.Errorf("diskHealthWrapper: Read with no reader")
    	}
    	n, err := d.r.Read(p)
    	if err == nil || err == io.EOF && n > 0 {
    		d.tracker.logSuccess()
    	}
    	return n, err
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  5. internal/s3select/select.go

    	}
    	return rsc.offset, nil
    }
    
    // Read call to implement io.Reader
    func (rsc *ObjectReadSeekCloser) Read(p []byte) (n int, err error) {
    	if rsc.reader == nil {
    		rsc.reader, err = rsc.segmentReader(rsc.offset)
    		if err != nil {
    			return 0, err
    		}
    	}
    	return rsc.reader.Read(p)
    }
    
    // Close call to implement io.Closer. Calling Read/Seek after Close reopens the
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  6. cmd/erasure-common.go

    	}
    
    	ignoredErrs := []error{
    		errFileNotFound,
    		errVolumeNotFound,
    		errFileVersionNotFound,
    		io.ErrUnexpectedEOF, // some times we would read without locks, ignore these errors
    		io.EOF,              // some times we would read without locks, ignore these errors
    		context.DeadlineExceeded,
    		context.Canceled,
    	}
    	ignoredErrs = append(ignoredErrs, objectOpIgnoredErrs...)
    
    	errs := g.Wait()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    		ctx = lkctx.Context()
    
    		// Release lock when the metadata is verified, and reader
    		// is ready to be read.
    		//
    		// This is possible to be lock free because
    		// - xl.meta for inlined objects has already read the data
    		//   into memory, any mutation on xl.meta subsequently is
    		//   inconsequential to the overall read operation.
    		// - xl.meta metadata is still verified for quorum under lock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  8. .github/workflows/go-cross.yml

        branches:
          - master
          - next
    
    # This ensures that previous jobs for the PR are canceled when the PR is
    # updated.
    concurrency:
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      build:
        name: Build Tests with Go ${{ matrix.go-version }} on ${{ matrix.os }}
        runs-on: ${{ matrix.os }}
        strategy:
          matrix:
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 09:25:58 GMT 2024
    - 970 bytes
    - Viewed (0)
  9. internal/hash/checksum.go

    	h.Write(data)
    	raw := h.Sum(nil)
    	c := Checksum{Type: t, Encoded: base64.StdEncoding.EncodeToString(raw), Raw: raw}
    	if !c.Valid() {
    		return nil
    	}
    	return &c
    }
    
    // ReadCheckSums will read checksums from b and return them.
    func ReadCheckSums(b []byte, part int) map[string]string {
    	res := make(map[string]string, 1)
    	for len(b) > 0 {
    		t, n := binary.Uvarint(b)
    		if n < 0 {
    			break
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  10. .github/workflows/go-lint.yml

        branches:
        - master
        - next
    
    # This ensures that previous jobs for the PR are canceled when the PR is
    # updated.
    concurrency: 
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      build:
        name: Go ${{ matrix.go-version }} on ${{ matrix.os }}
        runs-on: ${{ matrix.os }}
        strategy:
          matrix:
            go-version: [1.21.x]
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 23:44:49 GMT 2024
    - 1.3K bytes
    - Viewed (0)
Back to top