Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 419 for Int64 (0.51 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:02:50 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. cmd/http-stats.go

    	s3OutputBytes        uint64
    }
    
    // Increase internode total input bytes
    func (s *connStats) incInternodeInputBytes(n int64) {
    	atomic.AddUint64(&s.internodeInputBytes, uint64(n))
    }
    
    // Increase internode total output bytes
    func (s *connStats) incInternodeOutputBytes(n int64) {
    	atomic.AddUint64(&s.internodeOutputBytes, uint64(n))
    }
    
    // Return internode total input bytes
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. internal/rest/client.go

    	if body != nil {
    		switch v := body.(type) {
    		case *bytes.Buffer:
    			req.ContentLength = int64(v.Len())
    			buf := v.Bytes()
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := bytes.NewReader(buf)
    				return io.NopCloser(r), nil
    			}
    		case *bytes.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := snapshot
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  4. 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 Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 13 23:11:42 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  5. cmd/erasure-encode.go

    }
    
    // Encode reads from the reader, erasure-encodes the data and writes to the writers.
    func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) {
    	writer := &multiWriter{
    		writers:     writers,
    		writeQuorum: quorum,
    		errs:        make([]error, len(writers)),
    	}
    
    	for {
    		var blocks [][]byte
    		n, err := io.ReadFull(src, buf)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  7. schema/serializer.go

    	rv := reflect.ValueOf(fieldValue)
    	switch v := fieldValue.(type) {
    	case int64, int, uint, uint64, int32, uint32, int16, uint16:
    		result = time.Unix(reflect.Indirect(rv).Int(), 0).UTC()
    	case *int64, *int, *uint, *uint64, *int32, *uint32, *int16, *uint16:
    		if rv.IsZero() {
    			return nil, nil
    		}
    		result = time.Unix(reflect.Indirect(rv).Int(), 0).UTC()
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 08:45:38 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. cmd/erasure_test.go

    type erasureTestSetup struct {
    	dataBlocks   int
    	parityBlocks int
    	blockSize    int64
    	diskPaths    []string
    	disks        []StorageAPI
    }
    
    // Returns an initialized setup for erasure tests.
    func newErasureTestSetup(tb testing.TB, dataBlocks int, parityBlocks int, blockSize int64) (*erasureTestSetup, error) {
    	diskPaths := make([]string, dataBlocks+parityBlocks)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  9. api/go1.5.txt

    pkg go/types, type Sizes interface, Alignof(Type) int64
    pkg go/types, type Sizes interface, Offsetsof([]*Var) []int64
    pkg go/types, type Sizes interface, Sizeof(Type) int64
    pkg go/types, type Slice struct
    pkg go/types, type StdSizes struct
    pkg go/types, type StdSizes struct, MaxAlign int64
    pkg go/types, type StdSizes struct, WordSize int64
    pkg go/types, type Struct struct
    pkg go/types, type Tuple struct
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 30 21:14:09 UTC 2015
    - 46.6K bytes
    - Viewed (0)
  10. cmd/storage-datatypes.go

    	Versioned bool `msg:"vs"`
    }
    
    func (fi FileInfo) shardSize() int64 {
    	return ceilFrac(fi.Erasure.BlockSize, int64(fi.Erasure.DataBlocks))
    }
    
    // ShardFileSize - returns final erasure size from original size.
    func (fi FileInfo) ShardFileSize(totalLength int64) int64 {
    	if totalLength == 0 {
    		return 0
    	}
    	if totalLength == -1 {
    		return -1
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
Back to top