- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 42 for BeUint64 (0.13 sec)
-
pilot/pkg/xds/discovery_test.go
return } atomic.AddInt32(&fullPushes, 1) time.Sleep(opts.debounceMax * 2) <-pushingCh } else { atomic.AddInt32(&partialPushes, 1) } } updateSent := uatomic.NewInt64(0) wg.Add(1) go func() { debounce(updateCh, stopCh, opts, fakePush, updateSent) wg.Done() }() expect := func(expectedPartial, expectedFull int32) { t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
src/math/big/float.go
// no effect). func (z *Float) SetUint64(x uint64) *Float { return z.setBits64(false, x) } // SetInt64 sets z to the (possibly rounded) value of x and returns z. // If z's precision is 0, it is changed to 64 (and rounding will have // no effect). func (z *Float) SetInt64(x int64) *Float { u := x if u < 0 { u = -u } // We cannot simply call z.SetUint64(uint64(u)) and change
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 15:46:54 UTC 2024 - 44.5K bytes - Viewed (0) -
src/crypto/internal/edwards25519/scalar.go
} else if w > 8 { panic("NAF digits must fit in int8") } var naf [256]int8 var digits [5]uint64 for i := 0; i < 4; i++ { digits[i] = byteorder.LeUint64(b[i*8:]) } width := uint64(1 << w) windowMask := uint64(width - 1) pos := uint(0) carry := uint64(0) for pos < 256 { indexU64 := pos / 64 indexBit := pos % 64
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 18:57:38 UTC 2024 - 10.8K bytes - Viewed (0) -
cmd/kubeadm/app/util/pkiutil/pki_helpers.go
// returns a uniform random value in [0, max-1), then add 1 to serial to make it a uniform random value in [1, max). serial, err := cryptorand.Int(cryptorand.Reader, new(big.Int).SetInt64(math.MaxInt64-1)) if err != nil { return nil, err } serial = new(big.Int).Add(serial, big.NewInt(1)) if len(cfg.CommonName) == 0 { return nil, errors.New("must specify a CommonName") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 25.5K bytes - Viewed (0) -
cmd/data-scanner.go
scannerIdleMode = uatomic.NewInt32(0) // default is throttled when idle scannerExcessObjectVersions = uatomic.NewInt64(100) scannerExcessObjectVersionsTotalSize = uatomic.NewInt64(1024 * 1024 * 1024 * 1024) // 1 TB scannerExcessFolders = uatomic.NewInt64(50000) ) // initDataScanner will start the scanner in the background. func initDataScanner(ctx context.Context, objAPI ObjectLayer) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:43:17 UTC 2024 - 47.6K bytes - Viewed (0) -
src/time/time_test.go
b1e9 = new(big.Int) ) b1e9.SetInt64(1e9) testOne := func(ti, tns, di int64) bool { t.Helper() t0 := Unix(ti, tns).UTC() d := Duration(di) if d < 0 { d = -d } if d <= 0 { d = 1 } // Compute bt = absolute nanoseconds. sec, nsec := abs(t0) bsec.SetInt64(sec) bnsec.SetInt64(nsec) bt.Mul(bsec, b1e9) bt.Add(bt, bnsec)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:13:47 UTC 2024 - 56.5K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
for _, s := range collections.Pilot.All() { clienttest.MakeCRD(t, fake, s.GroupVersionResource()) } stop := test.NewStop(t) c := New(fake, Option{}) events := atomic.NewInt64(0) c.RegisterEventHandler(gvk.ServiceEntry, func(c config.Config, c2 config.Config, event model.Event) { events.Inc() }) go c.Run(stop) fake.RunAndWait(stop) kube.WaitForCacheSync("test", stop, c.HasSynced)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
cmd/kube-apiserver/app/testing/testserver.go
if err != nil { return result, err } // make a client certificate for the api server - common name has to match one of our defined names above serial, err := rand.Int(rand.Reader, new(big.Int).SetInt64(math.MaxInt64-1)) if err != nil { return result, err } serial = new(big.Int).Add(serial, big.NewInt(1)) tenThousandHoursLater := time.Now().Add(10_000 * time.Hour) certTmpl := x509.Certificate{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 17.6K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
for { select { case <-time.After(time.Millisecond): case <-stop: return } _ = wt.List("", klabels.Everything()) } } func TestHasSynced(t *testing.T) { handled := atomic.NewInt64(0) c := kube.NewFakeClient() deployments := kclient.New[*appsv1.Deployment](c) obj1 := &appsv1.Deployment{ ObjectMeta: metav1.ObjectMeta{Name: "1", Namespace: "default"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
src/go/internal/gcimporter/iimport.go
if maxBytes == 1 { maxSmall = 256 } n, _ := r.declReader.ReadByte() if uint(n) < maxSmall { v := int64(n) if signed { v >>= 1 if n&1 != 0 { v = ^v } } x.SetInt64(v) return } v := -n if signed { v = -(n &^ 1) >> 1 } if v < 1 || uint(v) > maxBytes { errorf("weird decoding: %v, %v => %v", n, signed, v) } b := make([]byte, v)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.2K bytes - Viewed (0)