Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 421 - 430 of 477 for int64 (0.19 seconds)

  1. internal/bpool/bpool_test.go

    	for i := uint64(0); i < size*2; i++ {
    		bp.Put(make([]byte, bp.w, bp.wcap))
    	}
    
    	b = bp.Get()
    	if len(b) != width {
    		t.Fatalf("bytepool length invalid: got %v want %v", len(b), width)
    	}
    	if cap(b) != capWidth {
    		t.Fatalf("bytepool length invalid: got %v want %v", cap(b), capWidth)
    	}
    
    	bp.Put(b)
    
    	// Check the size of the pool.
    	if uint64(len(bp.c)) != size {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  2. cmd/os-dirent_fileino.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import "syscall"
    
    func direntInode(dirent *syscall.Dirent) uint64 {
    	return uint64(dirent.Fileno)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 950 bytes
    - Click Count (0)
  3. internal/disk/stat_bsd.go

    	s := syscall.Statfs_t{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := s.Bfree - s.Bavail
    	info = Info{
    		Total:  uint64(s.Bsize) * (s.Blocks - reservedBlocks),
    		Free:   uint64(s.Bsize) * s.Bavail,
    		Files:  s.Files,
    		Ffree:  s.Ffree,
    		FSType: getFSType(s.Fstypename[:]),
    	}
    	if info.Free > info.Total {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 1.7K bytes
    - Click Count (0)
  4. internal/dsync/dsync_test.go

    	// As a matter of fact, this benchmark still triggers some spinning in the mutex.
    	m := NewDRWMutex(ds, "")
    	var acc0, acc1 uint64
    	b.SetParallelism(4)
    	b.RunParallel(func(pb *testing.PB) {
    		c := make(chan bool)
    		var data [4 << 10]uint64
    		for i := 0; pb.Next(); i++ {
    			if i%4 == 0 {
    				m.Lock(id, source)
    				acc0 -= 100
    				acc1 += 100
    				m.Unlock(b.Context())
    			} else {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  5. cmd/os-dirent_namelen_linux.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"fmt"
    	"syscall"
    	"unsafe"
    )
    
    func direntNamlen(dirent *syscall.Dirent) (uint64, error) {
    	const fixedHdr = uint16(unsafe.Offsetof(syscall.Dirent{}.Name))
    	nameBuf := (*[unsafe.Sizeof(dirent.Name)]byte)(unsafe.Pointer(&dirent.Name[0]))
    	const nameBufLen = uint16(len(nameBuf))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 1.5K bytes
    - Click Count (0)
  6. lib/time/mkzip.go

    		}
    		name := filepath.ToSlash(path)
    		w, err := zw.CreateRaw(&zip.FileHeader{
    			Name:               name,
    			Method:             zip.Store,
    			CompressedSize64:   uint64(len(data)),
    			UncompressedSize64: uint64(len(data)),
    			CRC32:              crc32.ChecksumIEEE(data),
    		})
    		if err != nil {
    			log.Fatal(err)
    		}
    		if _, err := w.Write(data); err != nil {
    			log.Fatal(err)
    		}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Mar 04 17:32:07 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  7. cmd/metrics-v3-cluster-iam.go

    	lastSyncTime := atomic.LoadUint64(&globalIAMSys.LastRefreshTimeUnixNano)
    	if lastSyncTime != 0 {
    		m.Set(sinceLastSyncMillis, float64((uint64(time.Now().UnixNano())-lastSyncTime)/uint64(time.Millisecond)))
    	}
    	m.Set(syncFailures, float64(atomic.LoadUint64(&globalIAMSys.TotalRefreshFailures)))
    	m.Set(syncSuccesses, float64(atomic.LoadUint64(&globalIAMSys.TotalRefreshSuccesses)))
    	return nil
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu May 02 08:20:42 GMT 2024
    - 4.5K bytes
    - Click Count (0)
  8. internal/event/name.go

    		}
    		return res
    	default:
    		return []Name{name}
    	}
    }
    
    // Mask returns the type as mask.
    // Compound "All" types are expanded.
    func (name Name) Mask() uint64 {
    	if name < objectSingleTypesEnd {
    		return 1 << (name - 1)
    	}
    	var mask uint64
    	for _, n := range name.Expand() {
    		mask |= 1 << (n - 1)
    	}
    	return mask
    }
    
    // String - returns string representation of event type.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  9. cmd/streaming-signature-v4_test.go

    			t.Errorf("Test %d: Expected %s, got %s this", i+1, tt.expectedErr, err)
    		}
    	}
    }
    
    // Tests parsing hex number into its uint64 decimal equivalent.
    func TestParseHexUint(t *testing.T) {
    	type testCase struct {
    		in      string
    		want    uint64
    		wantErr string
    	}
    	tests := []testCase{
    		{"x", 0, "invalid byte in chunk length"},
    		{"0000000000000000", 0, ""},
    		{"0000000000000001", 1, ""},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  10. internal/bucket/object/lock/lock_test.go

    	}
    }
    
    // TestUnmarshalDefaultRetention checks if default retention
    // marshaling and unmarshalling work as expected
    func TestUnmarshalDefaultRetention(t *testing.T) {
    	days := uint64(4)
    	years := uint64(1)
    	zerodays := uint64(0)
    	invalidDays := uint64(maximumRetentionDays + 1)
    	tests := []struct {
    		value       DefaultRetention
    		expectedErr error
    		expectErr   bool
    	}{
    		{
    			value:       DefaultRetention{Mode: "retain"},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 18.4K bytes
    - Click Count (0)
Back to Top