Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 428 for fuint64 (0.06 seconds)

  1. internal/kms/kms.go

    type Metrics struct {
    	ReqOK   uint64                   `json:"kms_req_success"` // Number of requests that succeeded
    	ReqErr  uint64                   `json:"kms_req_error"`   // Number of requests that failed with a defined error
    	ReqFail uint64                   `json:"kms_req_failure"` // Number of requests that failed with an undefined error
    	Latency map[time.Duration]uint64 `json:"kms_resp_time"`   // Latency histogram of all requests
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 24 15:33:57 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  2. docs/debugging/hash-set/main.go

    	if cardinality <= 0 {
    		return -1
    	}
    	// use the faster version as per siphash docs
    	// https://github.com/dchest/siphash#usage
    	k0, k1 := binary.LittleEndian.Uint64(id[0:8]), binary.LittleEndian.Uint64(id[8:16])
    	sum64 := siphash.Hash(k0, k1, []byte(key))
    	return int(sum64 % uint64(cardinality))
    }
    
    // hashOrder - hashes input key to return consistent
    // hashed integer slice. Returned integer order is salted
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.7K bytes
    - Click Count (0)
  3. internal/grid/muxserver.go

    package grid
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    type muxServer struct {
    	ID                 uint64
    	LastPing           int64
    	SendSeq, RecvSeq   uint32
    	Resp               chan []byte
    	BaseFlags          Flags
    	ctx                context.Context
    	cancel             context.CancelFunc
    	inbound            chan []byte
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.7K bytes
    - Click Count (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)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 950 bytes
    - Click Count (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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  6. internal/bucket/bandwidth/measurement.go

    )
    
    // bucketMeasurement captures the bandwidth details for one bucket
    type bucketMeasurement struct {
    	lock                 sync.Mutex
    	bytesSinceLastWindow uint64    // Total bytes since last window was processed
    	startTime            time.Time // Start time for window
    	expMovingAvg         float64   // Previously calculate sliding window
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Jun 03 20:41:51 GMT 2023
    - 2.9K bytes
    - Click Count (0)
  7. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 1.5K bytes
    - Click Count (0)
  8. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  9. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  10. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 10.4K bytes
    - Click Count (0)
Back to Top