Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 355 for Uint64N (0.05 sec)

  1. cmd/storage-interface.go

    	ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error)
    	AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error)
    	CreateFile(ctx context.Context, origvolume, olume, path string, size int64, reader io.Reader) error
    	ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  2. cmd/erasure-metadata_test.go

    	for _, partNum := range []int{1, 2, 4, 5, 7} {
    		partNumString := strconv.Itoa(partNum)
    		fi.AddObjectPart(partNum, "etag."+partNumString, int64(partNum+humanize.MiByte), ActualSize, UTCNow(), nil, nil)
    	}
    
    	testCases := []struct {
    		offset         int64
    		expectedIndex  int
    		expectedOffset int64
    		expectedErr    error
    	}{
    		{0, 0, 0, nil},
    		{1 * humanize.MiByte, 0, 1 * humanize.MiByte, nil},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  3. docs/distributed/DESIGN.md

            serverPools := z.getServerPoolsAvailableSpace(ctx)
            total := serverPools.TotalAvailable()
            // choose when we reach this many
            choose := rand.Uint64() % total
            atTotal := uint64(0)
            for _, pool := range serverPools {
                    atTotal += pool.Available
                    if atTotal > choose && pool.Available > 0 {
                            return pool.Index
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Feb 26 09:25:50 UTC 2025
    - 8K bytes
    - Viewed (2)
  4. cmd/test-utils_test.go

    func calculateSignedChunkLength(chunkDataSize int64) int64 {
    	return int64(len(fmt.Sprintf("%x", chunkDataSize))) +
    		17 + // ";chunk-signature="
    		64 + // e.g. "f2ca1bb6c7e907d06dafe4687e579fce76b37e4e93b7605022da52e6ccc26fd2"
    		2 + // CRLF
    		chunkDataSize +
    		2 // CRLF
    }
    
    func mustGetPutObjReader(t TestErrHandler, data io.Reader, size int64, md5hex, sha256hex string) *PutObjReader {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  5. cmd/server_test.go

    	c.Assert(err, nil)
    	c.Assert(response.StatusCode, http.StatusOK)
    	c.Assert(response.ContentLength, int64(len([]byte("hello world"))))
    	var buffer2 bytes.Buffer
    	// retrieve the contents of response body.
    	n, err := io.Copy(&buffer2, response.Body)
    	c.Assert(err, nil)
    	c.Assert(n, int64(len([]byte("hello world"))))
    	// asserted the contents of the fetched object with the expected result.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118.1K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-decom.go

    	Object string `json:"-" msg:"obj"`
    
    	// Verbose information
    	ItemsDecommissioned     int64 `json:"objectsDecommissioned" msg:"id"`
    	ItemsDecommissionFailed int64 `json:"objectsDecommissionedFailed" msg:"idf"`
    	BytesDone               int64 `json:"bytesDecommissioned" msg:"bd"`
    	BytesFailed             int64 `json:"bytesDecommissionedFailed" msg:"bf"`
    }
    
    // Clone make a copy of PoolDecommissionInfo
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  7. logger/slog.go

    	if l.LogLevel <= Silent {
    		return
    	}
    
    	elapsed := time.Since(begin)
    	sql, rows := fc()
    	fields := []slog.Attr{
    		slog.String("duration", fmt.Sprintf("%.3fms", float64(elapsed.Nanoseconds())/1e6)),
    		slog.String("sql", sql),
    	}
    
    	if rows != -1 {
    		fields = append(fields, slog.Int64("rows", rows))
    	}
    
    	switch {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Jul 28 09:34:58 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  8. src/bytes/compare_test.go

    		}
    	}
    	b.SetBytes(int64(len(b1)))
    }
    
    func BenchmarkCompareBytesBigIdentical(b *testing.B) {
    	b.StopTimer()
    	b1 := make([]byte, 0, 1<<20)
    	for len(b1) < 1<<20 {
    		b1 = append(b1, "Hello Gophers!"...)
    	}
    	b2 := b1
    	b.StartTimer()
    	for i := 0; i < b.N; i++ {
    		if Compare(b1, b2) != 0 {
    			b.Fatal("b1 != b2")
    		}
    	}
    	b.SetBytes(int64(len(b1)))
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Jul 13 23:11:42 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  9. cmd/bucket-targets.go

    	lastmin lastMinuteLatency
    	curr    time.Duration
    	avg     time.Duration
    	peak    time.Duration
    	N       int64
    }
    
    func (l *latencyStat) update(d time.Duration) {
    	l.lastmin.add(d)
    	l.N++
    	if d > l.peak {
    		l.peak = d
    	}
    	l.curr = l.lastmin.getTotal().avg()
    	l.avg = time.Duration((int64(l.avg)*(l.N-1) + int64(l.curr)) / l.N)
    }
    
    // epHealth struct represents health of a replication target endpoint.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  10. cmd/utils_test.go

    	"errors"
    	"fmt"
    	"net/http"
    	"net/url"
    	"reflect"
    	"strings"
    	"testing"
    )
    
    // Tests maximum object size.
    func TestMaxObjectSize(t *testing.T) {
    	sizes := []struct {
    		isMax bool
    		size  int64
    	}{
    		// Test - 1 - maximum object size.
    		{
    			true,
    			globalMaxObjectSize + 1,
    		},
    		// Test - 2 - not maximum object size.
    		{
    			false,
    			globalMaxObjectSize - 1,
    		},
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 10.2K bytes
    - Viewed (0)
Back to top