Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for readStat (0.06 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)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. src/bytes/reader.go

    		return 0, io.EOF
    	}
    	r.prevRune = -1
    	n = copy(b, r.s[r.i:])
    	r.i += int64(n)
    	return
    }
    
    // ReadAt implements the [io.ReaderAt] interface.
    func (r *Reader) ReadAt(b []byte, off int64) (n int, err error) {
    	// cannot modify state - see io.ReaderAt
    	if off < 0 {
    		return 0, errors.New("bytes.Reader.ReadAt: negative offset")
    	}
    	if off >= int64(len(r.s)) {
    		return 0, io.EOF
    	}
    	n = copy(b, r.s[off:])
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. internal/deadlineconn/deadlineconn.go

    	net.Conn
    	readDeadline  time.Duration // sets the read deadline on a connection.
    	readSetAt     time.Time
    	writeDeadline time.Duration // sets the write deadline on a connection.
    	writeSetAt    time.Time
    }
    
    // Sets read deadline
    func (c *DeadlineConn) setReadDeadline() {
    	if c.readDeadline > 0 {
    		now := time.Now()
    		if now.Sub(c.readSetAt) > updateInterval {
    			c.Conn.SetReadDeadline(now.Add(c.readDeadline + updateInterval))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  5. cmd/bitrot_test.go

    	b := make([]byte, 10)
    	if _, err = reader.ReadAt(b, 0); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b, 10); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b, 20); err != nil {
    		t.Fatal(err)
    	}
    	if _, err = reader.ReadAt(b[:5], 30); err != nil {
    		t.Fatal(err)
    	}
    	if br, ok := reader.(io.Closer); ok {
    		br.Close()
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  6. cmd/bitrot.go

    	if algo == HighwayHash256S {
    		return newStreamingBitrotReader(disk, data, bucket, filePath, tillOffset, algo, shardSize)
    	}
    	return newWholeBitrotReader(disk, bucket, filePath, algo, tillOffset, sum)
    }
    
    // Close all the readers.
    func closeBitrotReaders(rs []io.ReaderAt) {
    	for _, r := range rs {
    		if r != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. src/bytes/reader_test.go

    	}{
    		{0, 10, "0123456789", nil},
    		{1, 10, "123456789", io.EOF},
    		{1, 9, "123456789", nil},
    		{11, 10, "", io.EOF},
    		{0, 0, "", nil},
    		{-1, 0, "", "bytes.Reader.ReadAt: negative offset"},
    	}
    	for i, tt := range tests {
    		b := make([]byte, tt.n)
    		rn, err := r.ReadAt(b, tt.off)
    		got := string(b[:rn])
    		if got != tt.want {
    			t.Errorf("%d. got %q; want %q", i, got, tt.want)
    		}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 8K bytes
    - Viewed (0)
  8. cmd/bitrot-streaming.go

    	}
    	return nil
    }
    
    func (b *streamingBitrotReader) ReadAt(buf []byte, offset int64) (int, error) {
    	var err error
    	if offset%b.shardSize != 0 {
    		// Offset should always be aligned to b.shardSize
    		// Can never happen unless there are programmer bugs
    		return 0, errUnexpected
    	}
    	if b.rc == nil {
    		// For the first ReadAt() call we need to open the stream for reading.
    		b.currOffset = offset
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. cmd/bitrot-whole.go

    	tillOffset int64           // Affects the length of data requested in disk.ReadFile depending on Read()'s offset
    	buf        []byte          // Holds bit-rot verified data
    }
    
    func (b *wholeBitrotReader) ReadAt(buf []byte, offset int64) (n int, err error) {
    	if b.buf == nil {
    		b.buf = make([]byte, b.tillOffset-offset)
    		if _, err := b.disk.ReadFile(context.TODO(), b.volume, b.filePath, offset, b.buf, b.verifier); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  10. api/go1.22.txt

    pkg go/version, func IsValid(string) bool #62039
    pkg go/version, func Lang(string) string #62039
    pkg html/template, const ErrJSTemplate //deprecated #61619
    pkg io, method (*SectionReader) Outer() (ReaderAt, int64, int64) #61870
    pkg log/slog, func SetLogLoggerLevel(Level) Level #62418
    pkg math/big, method (*Rat) FloatPrec() (int, bool) #50489
    pkg math/rand/v2, func ExpFloat64() float64 #61716
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jan 24 20:54:27 UTC 2024
    - 7.7K bytes
    - Viewed (0)
Back to top