Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 620 for uint24 (0.05 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Feb 23 21:28:14 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. cmd/s3-zip-handlers.go

    func getFilesListFromZIPObject(ctx context.Context, objectAPI ObjectLayer, bucket, object string, opts ObjectOptions) (zipindex.Files, ObjectInfo, error) {
    	size := 1 << 20
    	var objSize int64
    	for {
    		rs := &HTTPRangeSpec{IsSuffixLength: true, Start: int64(-size)}
    		gr, err := objectAPI.GetObjectNInfo(ctx, bucket, object, rs, nil, opts)
    		if err != nil {
    			return nil, ObjectInfo{}, err
    		}
    		b, err := io.ReadAll(gr)
    		gr.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  4. cmd/handler-utils.go

    			globalHTTPStats.updateStats(api, tc.ResponseRecorder)
    			globalConnStats.incS3InputBytes(int64(tc.RequestRecorder.Size()))
    			globalConnStats.incS3OutputBytes(int64(tc.ResponseRecorder.Size()))
    
    			if countBktStat {
    				globalBucketConnStats.incS3InputBytes(bucket, int64(tc.RequestRecorder.Size()))
    				globalBucketConnStats.incS3OutputBytes(bucket, int64(tc.ResponseRecorder.Size()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (1)
  5. cmd/object-api-utils_test.go

    				i+1, test.result, got)
    		}
    	}
    }
    
    func TestGetCompressedOffsets(t *testing.T) {
    	testCases := []struct {
    		objInfo           ObjectInfo
    		offset            int64
    		startOffset       int64
    		snappyStartOffset int64
    		firstPart         int
    	}{
    		0: {
    			objInfo: ObjectInfo{
    				Parts: []ObjectPartInfo{
    					{
    						Size:       39235668,
    						ActualSize: 67108864,
    					},
    					{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  6. cmd/handler-utils_test.go

    	}
    
    	// Corrupted XML
    	malformedReq := &http.Request{
    		Body:          io.NopCloser(bytes.NewReader([]byte("<>"))),
    		ContentLength: int64(len("<>")),
    	}
    
    	// Not an XML
    	badRequest := &http.Request{
    		Body:          io.NopCloser(bytes.NewReader([]byte("garbage"))),
    		ContentLength: int64(len("garbage")),
    	}
    
    	// generates the input request with XML bucket configuration set to the request body.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  7. cmd/streaming-signature-v4.go

    func parseChunkSignature(chunk []byte) []byte {
    	chunkSplits := bytes.SplitN(chunk, []byte(s3ChunkSignatureStr), 2)
    	return chunkSplits[1]
    }
    
    // parse hex to uint64.
    func parseHexUint(v []byte) (n uint64, err error) {
    	for i, b := range v {
    		switch {
    		case '0' <= b && b <= '9':
    			b -= '0'
    		case 'a' <= b && b <= 'f':
    			b = b - 'a' + 10
    		case 'A' <= b && b <= 'F':
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  9. cmd/config-common.go

    	}
    	return err
    }
    
    func saveConfigWithOpts(ctx context.Context, store objectIO, configFile string, data []byte, opts ObjectOptions) error {
    	hashReader, err := hash.NewReader(ctx, bytes.NewReader(data), int64(len(data)), "", getSHA256Hash(data), int64(len(data)))
    	if err != nil {
    		return err
    	}
    
    	_, err = store.PutObject(ctx, minioMetaBucket, configFile, NewPutObjReader(hashReader), opts)
    	return err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  10. cmd/erasure-metadata.go

    // ShardFileSize - returns final erasure size from original size.
    func (e ErasureInfo) ShardFileSize(totalLength int64) int64 {
    	if totalLength == 0 {
    		return 0
    	}
    	if totalLength == -1 {
    		return -1
    	}
    	numShards := totalLength / e.BlockSize
    	lastBlockSize := totalLength % e.BlockSize
    	lastShardSize := ceilFrac(lastBlockSize, int64(e.DataBlocks))
    	return numShards*e.ShardSize() + lastShardSize
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
Back to top