- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 691 for deltaT (0.14 sec)
-
pilot/pkg/xds/monitoring.go
[]float64{1, 10000, 1000000, 4000000, 10000000, 40000000}, monitoring.WithUnit(monitoring.Bytes), ) ) func recordXDSClients(version string, delta float64) { xdsClientTrackerMutex.Lock() defer xdsClientTrackerMutex.Unlock() xdsClientTracker[version] += delta xdsClients.With(versionTag.Value(version)).Record(xdsClientTracker[version]) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 6.7K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-fail-first-gen-first.go
// A running goroutine emits a task begin. t.RawEvent(go122.EvEventBatch, nil, 1 /*gen*/, 0 /*thread ID*/, 0 /*timestamp*/, 5 /*batch length*/) t.RawEvent(go122.EvGoCreate, nil, 0 /*timestamp delta*/, 1 /*go ID*/, 0, 0) // Write an invalid batch event for the next generation. t.RawEvent(go122.EvEventBatch, nil, 2 /*gen*/, 0 /*thread ID*/, 0 /*timestamp*/, 50 /*batch length (invalid)*/)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1.7K bytes - Viewed (0) -
src/runtime/netpoll.go
// Disable notifications for fd. Return an errno value. // // func netpoll(delta int64) (gList, int32) // Poll the network. If delta < 0, block indefinitely. If delta == 0, // poll without blocking. If delta > 0, block for up to delta nanoseconds. // Return a list of goroutines built by calling netpollready, // and a delta to add to netpollWaiters when all goroutines are ready.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 20.7K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
if dir == model.TrafficDirectionInbound { // Append all inbound clusters because in both stow/delta we always build all inbound clusters. // In reality, the delta building is only for outbound clusters. We need to revist here once we support delta for inbound. // So deletedClusters.Difference(builtClusters) would give us the correct deleted inbound clusters. deletedClusters.Insert(cluster)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
src/runtime/mgcpacer_test.go
deltas[i] += *workLeft work -= *workLeft *workLeft = 0 } } return deltas[0], deltas[1], deltas[2] } var ( gcDuration int64 assistTime int64 bytesAllocatedBlack int64 ) for heapScanWorkLeft+stackScanWorkLeft+globalsScanWorkLeft > 0 { // Simulate GC assist pacing. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 19 13:53:21 UTC 2023 - 39.3K bytes - Viewed (0) -
pilot/pkg/features/experimental.go
DeltaXds = env.Register("ISTIO_DELTA_XDS", true, "If enabled, pilot will only send the delta configs as opposed to the state of the world on a "+ "Resource Request. This feature uses the delta xds api, but does not currently send the actual deltas.").Get() EnableQUICListeners = env.Register("PILOT_ENABLE_QUIC_LISTENERS", false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/adsc/delta_test.go
return nil } func (t *mockDeltaXdsServer) DeltaAggregatedResources(delta discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error { return deltaHandler(delta) } var testCluster = &cluster.Cluster{ Name: "test-eds", ClusterDiscoveryType: &cluster.Cluster_Type{Type: cluster.Cluster_EDS},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 13.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 4.2K bytes - Viewed (0) -
src/sync/atomic/atomic_test.go
before int32 i int32 after int32 } x.before = magic32 x.after = magic32 var j int32 for delta := int32(1); delta+delta > delta; delta += delta { k := SwapInt32(&x.i, delta) if x.i != delta || k != j { t.Fatalf("delta=%d i=%d j=%d k=%d", delta, x.i, j, k) } j = delta } if x.before != magic32 || x.after != magic32 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:37:29 UTC 2024 - 71.4K bytes - Viewed (0) -
pkg/apis/core/v1/helper/qos/qos.go
if !isSupportedQoSComputeResource(name) { continue } if quantity.Cmp(zeroQuantity) == 1 { delta := quantity.DeepCopy() if _, exists := requests[name]; !exists { requests[name] = delta } else { delta.Add(requests[name]) requests[name] = delta } } } // process limits qosLimitsFound := sets.NewString()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 08 04:01:46 UTC 2023 - 3.5K bytes - Viewed (0)