Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for readStat (0.17 sec)

  1. internal/disk/stat_linux.go

    	return readDriveStats(fmt.Sprintf("/sys/dev/block/%v:%v/stat", major, minor))
    }
    
    func readDriveStats(statsFile string) (iostats IOStats, err error) {
    	stats, err := readStat(statsFile)
    	if err != nil {
    		return IOStats{}, err
    	}
    	if len(stats) < 11 {
    		return IOStats{}, fmt.Errorf("found invalid format while reading %v", statsFile)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  2. cmd/erasure-decode.go

    type parallelReader struct {
    	readers       []io.ReaderAt
    	orgReaders    []io.ReaderAt
    	dataBlocks    int
    	offset        int64
    	shardSize     int64
    	shardFileSize int64
    	buf           [][]byte
    	readerToBuf   []int
    	stashBuffer   []byte
    }
    
    // newParallelReader returns parallelReader.
    func newParallelReader(readers []io.ReaderAt, e Erasure, offset, totalLength int64) *parallelReader {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  3. src/archive/zip/zip_test.go

    	w := NewWriter(ss)
    	f(w)
    	return suffixIsZip64(t, ss)
    }
    
    type sizedReaderAt interface {
    	io.ReaderAt
    	Size() int64
    }
    
    func suffixIsZip64(t *testing.T, zip sizedReaderAt) bool {
    	d := make([]byte, 1024)
    	if _, err := zip.ReadAt(d, zip.Size()-int64(len(d))); err != nil {
    		t.Fatalf("ReadAt: %v", err)
    	}
    
    	sigOff := findSignatureInBlock(d)
    	if sigOff == -1 {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Mar 27 18:23:49 GMT 2024
    - 19.5K bytes
    - Viewed (0)
  4. cmd/sftp-server-driver.go

    		return f.permissions.CriticalOptions[ldapUserN]
    	}
    	return f.permissions.CriticalOptions["accessKey"]
    }
    
    func (f *sftpDriver) Fileread(r *sftp.Request) (ra io.ReaderAt, err error) {
    	stopFn := globalSftpMetrics.log(r, f.AccessKey())
    	defer stopFn(err)
    
    	flags := r.Pflags()
    	if !flags.Read {
    		// sanity check
    		return nil, os.ErrInvalid
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  5. src/archive/zip/reader_test.go

    	}
    }
    
    func messWith(fileName string, corrupter func(b []byte)) (r io.ReaderAt, size int64) {
    	data, err := os.ReadFile(filepath.Join("testdata", fileName))
    	if err != nil {
    		panic("Error reading " + fileName + ": " + err.Error())
    	}
    	corrupter(data)
    	return bytes.NewReader(data), int64(len(data))
    }
    
    func returnCorruptCRC32Zip() (r io.ReaderAt, size int64) {
    	return messWith("go-with-datadesc-sig.zip", func(b []byte) {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Mar 27 18:23:49 GMT 2024
    - 55.3K bytes
    - Viewed (0)
  6. docs/debugging/xl-meta/main.go

    					return err
    				}
    				if st, err := f.Stat(); err == nil {
    					sz = st.Size()
    				}
    				defer f.Close()
    				r = f
    			}
    			if strings.HasSuffix(file, ".zip") {
    				zr, err := zip.NewReader(r.(io.ReaderAt), sz)
    				if err != nil {
    					return err
    				}
    				for _, file := range zr.File {
    					if !file.FileInfo().IsDir() && strings.HasSuffix(file.Name, "xl.meta") {
    						r, err := file.Open()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  7. cmd/erasure-healing.go

    			partIdx := latestMeta.Parts[partIndex].Index
    			partChecksums := latestMeta.Parts[partIndex].Checksums
    			tillOffset := erasure.ShardFileOffset(0, partSize, partSize)
    			readers := make([]io.ReaderAt, len(latestDisks))
    			prefer := make([]bool, len(latestDisks))
    			checksumAlgo := erasureInfo.GetChecksumInfo(partNumber).Algorithm
    			for i, disk := range latestDisks {
    				if disk == OfflineDisk {
    					continue
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    			partLength = length - totalBytesRead
    		}
    
    		tillOffset := erasure.ShardFileOffset(partOffset, partLength, partSize)
    		// Get the checksums of the current part.
    		readers := make([]io.ReaderAt, len(onlineDisks))
    		prefer := make([]bool, len(onlineDisks))
    		for index, disk := range onlineDisks {
    			if disk == OfflineDisk {
    				continue
    			}
    			if !metaArr[index].IsValid() {
    				continue
    			}
    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)
  9. cmd/xl-storage.go

    	}
    
    	// Verify it is a regular file, otherwise subsequent Seek is
    	// undefined.
    	if !st.Mode().IsRegular() {
    		return 0, errIsNotRegular
    	}
    
    	if verifier == nil {
    		n, err = file.ReadAt(buffer, offset)
    		return int64(n), err
    	}
    
    	h := verifier.algorithm.New()
    	if _, err = io.Copy(h, io.LimitReader(file, offset)); err != nil {
    		return 0, err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
Back to top