- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 121 for Xaddint32 (0.18 sec)
-
pilot/pkg/xds/endpoints/endpoint_builder.go
} for _, locality := range locs { locLbEps := localityEpMap[locality] var weight uint32 var overflowStatus bool for _, ep := range locLbEps.llbEndpoints.LbEndpoints { weight, overflowStatus = addUint32(weight, ep.LoadBalancingWeight.GetValue()) } locLbEps.llbEndpoints.LoadBalancingWeight = &wrapperspb.UInt32Value{ Value: weight, } if overflowStatus {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
cmd/bucket-replication.go
return } switch v := oi.(type) { case ReplicateObjectInfo: globalReplicationStats.incQ(v.Bucket, v.Size, v.DeleteMarker, v.OpType) atomic.AddInt32(&p.activeMRFWorkers, 1) replicateObject(p.ctx, v, p.objLayer) atomic.AddInt32(&p.activeMRFWorkers, -1) globalReplicationStats.decQ(v.Bucket, v.Size, v.DeleteMarker, v.OpType) default:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
src/cmd/link/internal/loader/symbolbuilder.go
} return off + wid } func (sb *SymbolBuilder) AddUint16(arch *sys.Arch, v uint16) int64 { return sb.AddUintXX(arch, uint64(v), 2) } func (sb *SymbolBuilder) AddUint32(arch *sys.Arch, v uint32) int64 { return sb.AddUintXX(arch, uint64(v), 4) } func (sb *SymbolBuilder) AddUint64(arch *sys.Arch, v uint64) int64 { return sb.AddUintXX(arch, v, 8) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 15:25:19 UTC 2023 - 13.9K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
if status.Code() == framework.Error { errCh.SendErrorWithCancel(status.AsError(), cancel) return } if status.IsSuccess() { length := atomic.AddInt32(&feasibleNodesLen, 1) if length > numNodesToFind { cancel() atomic.AddInt32(&feasibleNodesLen, -1) } else { feasibleNodes[length-1] = nodeInfo } } else { result[i] = &nodeStatus{node: nodeInfo.Node().Name, status: status}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
src/net/http/client_test.go
readCalls *int32 closeCalls *int32 readErr error } func (b issue18239Body) Read([]byte) (int, error) { atomic.AddInt32(b.readCalls, 1) return 0, b.readErr } func (b issue18239Body) Close() error { atomic.AddInt32(b.closeCalls, 1) return nil } // Issue 18239: make sure the Transport doesn't retry requests with bodies // if Request.GetBody is not defined.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/gen_test.go
} return ans } var uCounter uint32 = 1 func uniqify(in RequestDigest) RequestDigest { u1 := in.User.(*user.DefaultInfo) u2 := *u1 u2.Extra = map[string][]string{"u": {fmt.Sprintf("z%d", atomic.AddUint32(&uCounter, 1))}} return RequestDigest{User: &u2, RequestInfo: in.RequestInfo} } // genSubject returns a randomly generated valid Subject that matches
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 24.8K bytes - Viewed (0) -
src/net/http/clientserver_test.go
time.Sleep(10 * time.Millisecond) rc, err := net.Dial("tcp", addr) if err != nil { return nil, err } atomic.AddInt32(&numOpen, 1) c := noteCloseConn{rc, func() { atomic.AddInt32(&numClose, 1) }} return tls.Client(c, tlsConfig), nil }, } if err := ExportHttp2ConfigureTransport(tr); err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 46.6K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
return &candidateList{idx: -1, items: make([]Candidate, size)} } // add adds a new candidate to the internal array atomically. func (cl *candidateList) add(c *candidate) { if idx := atomic.AddInt32(&cl.idx, 1); idx < int32(len(cl.items)) { cl.items[idx] = c } } // size returns the number of candidate stored. Note that some add() operations
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
src/net/http/transport_test.go
tr.Dial = func(network, addr string) (net.Conn, error) { atomic.AddInt32(&dialCnt, 1) c, err := net.Dial(network, addr) mu.Lock() defer mu.Unlock() conns = append(conns, c) return c, err } doReq := func() { trace := &httptrace.ClientTrace{ GotConn: func(connInfo httptrace.GotConnInfo) { if !connInfo.Reused { atomic.AddInt32(&gotConnCnt, 1) } }, TLSHandshakeStart: func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
cmd/xl-storage.go
}) } func (s *xlStorage) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, weSleep func() bool) (dataUsageCache, error) { atomic.AddInt32(&s.scanning, 1) defer atomic.AddInt32(&s.scanning, -1) var err error stopFn := globalScannerMetrics.log(scannerMetricScanBucketDrive, s.drivePath, cache.Info.Name) defer func() { res := make(map[string]string)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (2)