Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 356 for uint32 (0.04 sec)

  1. 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
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu May 02 08:20:42 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  2. tests/preload_suits_test.go

    	type (
    		Level0 struct {
    			ID       uint
    			Value    string
    			Level1ID uint
    		}
    		Level1 struct {
    			ID         uint
    			Value      string
    			Level2ID   *uint
    			Level2_1ID *uint
    			Level0s    []Level0 `json:",omitempty"`
    		}
    		Level2 struct {
    			ID       uint
    			Level1s  []Level1
    			Level3ID uint
    		}
    		Level2_1 struct {
    			ID       uint
    			Level1s  []Level1 `json:",omitempty"`
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Thu Jun 05 11:34:13 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  3. internal/bucket/bandwidth/monitor_test.go

    package bandwidth
    
    import (
    	"reflect"
    	"testing"
    	"time"
    )
    
    const (
    	oneMiB uint64 = 1024 * 1024
    )
    
    func TestMonitor_GetReport(t *testing.T) {
    	type fields struct {
    		activeBuckets map[BucketOptions]*bucketMeasurement
    		endTime       time.Time
    		update2       uint64
    		endTime2      time.Time
    	}
    	start := time.Now()
    	m0 := newBucketMeasurement(start)
    	m0.incrementBytes(0)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  4. 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)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 950 bytes
    - Viewed (0)
  5. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  6. src/main/java/jcifs/SmbPipeResource.java

         */
    
        int PIPE_TYPE_RDWR = SmbConstants.O_RDWR;
    
        /**
         * Pipe operations should behave like the <code>CallNamedPipe</code> Win32 Named Pipe function.
         */
    
        int PIPE_TYPE_CALL = 0x0100;
    
        /**
         * Pipe operations should behave like the <code>TransactNamedPipe</code> Win32 Named Pipe function.
         */
    
        int PIPE_TYPE_TRANSACT = 0x0200;
    
        /**
         * Pipe is used for DCE
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    	}
    	// Read header
    	switch binary.LittleEndian.Uint16(data[0:2]) {
    	case format:
    	default:
    		return fmt.Errorf("%s: unknown format: %d", ri.JobType, binary.LittleEndian.Uint16(data[0:2]))
    	}
    	switch binary.LittleEndian.Uint16(data[2:4]) {
    	case version:
    	default:
    		return fmt.Errorf("%s: unknown version: %d", ri.JobType, binary.LittleEndian.Uint16(data[2:4]))
    	}
    
    	ri.mu.Lock()
    	defer ri.mu.Unlock()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (1)
  8. cmd/last-minute.go

    	}
    	return 0
    }
    
    // asTimedAction returns the element as a madmin.TimedAction.
    func (a AccElem) asTimedAction() madmin.TimedAction {
    	return madmin.TimedAction{AccTime: uint64(a.Total), Count: uint64(a.N), Bytes: uint64(a.Size)}
    }
    
    // lastMinuteLatency keeps track of last minute latency.
    type lastMinuteLatency struct {
    	Totals  [60]AccElem
    	LastSec int64
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Jul 05 17:40:45 UTC 2023
    - 4.8K bytes
    - Viewed (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, ""},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  10. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Feb 26 09:25:50 UTC 2025
    - 8K bytes
    - Viewed (2)
Back to top