- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 179 for zero (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
counter.Add(1) // account for main activity of the goroutine running this test ctx1 := context.Background() pZero := func() *int32 { var zero int32; return &zero } // counts of calls to the QueueNoteFns queueNoteCounts := map[int]map[bool]*int32{ 1: {false: pZero(), true: pZero()}, 2: {false: pZero(), true: pZero()}, } queueNoteFn := func(fn int) func(inQueue bool) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
src/runtime/mgcpacer.go
// no dedicated workers, this will be 0.25. If the goal is // 25%, there is one dedicated worker, and GOMAXPROCS is 5, // this will be 0.05 to make up the missing 5%. // // If this is zero, no fractional workers are needed. fractionalUtilizationGoal float64 // These memory stats are effectively duplicates of fields from // memstats.heapStats but are updated atomically or with the world
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 55.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit_test.go
MilliCPU: 0, Memory: 0, ScalarResources: map[v1.ResourceName]int64{extendedResourceA: 6}})), name: "skip checking extended resource request with quantity zero via resource groups", wantInsufficientResources: []InsufficientResource{}, }, { pod: newResourcePod( framework.Resource{ ScalarResources: map[v1.ResourceName]int64{ extendedResourceA: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 57.4K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
} hcnImpl := proxier.hcn err := hcnImpl.DsrSupported() if err != nil { preserveDIP = false localTrafficDSR = false } // targetPort is zero if it is specified as a name in port.TargetPort. // Its real value would be got later from endpoints. targetPort := 0 if port.TargetPort.Type == intstr.Int { targetPort = port.TargetPort.IntValue() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
// new requests will be allowed to run by: // - sending N requests that will occupy the whole capacity // - sending initialiation signals for them // - ensuring that number of inflight requests will get to zero concurrentRequests := 5 firstRunning := sync.WaitGroup{} firstRunning.Add(concurrentRequests) allRunning := sync.WaitGroup{} allRunning.Add(2 * concurrentRequests)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
src/os/os_test.go
defer Remove(f.Name()) f.Write([]byte("hello, world\n")) f.Close() testChtimes(t, f.Name()) } func TestChtimesWithZeroTimes(t *testing.T) { file := newFile("chtimes-with-zero", t) _, err := file.Write([]byte("hello, world\n")) if err != nil { t.Fatalf("Write: %s", err) } fName := file.Name() defer Remove(file.Name()) err = file.Close() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 83.1K bytes - Viewed (0) -
tensorflow/c/c_api.h
// // `num_return_outputs` must be the number of return outputs added (i.e. the // result of TF_ImportGraphDefOptionsNumReturnOutputs()). If // `num_return_outputs` is non-zero, `return_outputs` must be of length // `num_return_outputs`. Otherwise it can be null. TF_CAPI_EXPORT extern void TF_GraphImportGraphDefWithReturnOutputs( TF_Graph* graph, const TF_Buffer* graph_def,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 26 21:08:15 UTC 2023 - 82.3K bytes - Viewed (0) -
src/runtime/asm_amd64.s
MOVQ $runtime·systemstack_switch+8(SB), R9 MOVQ R9, (g_sched+gobuf_pc)(R14) LEAQ 8(SP), R9 MOVQ R9, (g_sched+gobuf_sp)(R14) MOVQ $0, (g_sched+gobuf_ret)(R14) MOVQ BP, (g_sched+gobuf_bp)(R14) // Assert ctxt is zero. See func save. MOVQ (g_sched+gobuf_ctxt)(R14), R9 TESTQ R9, R9 JZ 2(PC) CALL runtime·abort(SB) RET // func asmcgocall_no_g(fn, arg unsafe.Pointer)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 20:38:24 UTC 2024 - 60.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
func (t *watcherBookmarkTimeBuckets) addWatcherThreadUnsafe(w *cacheWatcher) bool { // note that the returned time can be before t.createTime, // especially in cases when the nextBookmarkTime method // give us the zero value of type Time // so buckedID can hold a negative value nextTime, ok := w.nextBookmarkTime(t.clock.Now(), t.bookmarkFrequency) if !ok { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
desiredReplicas = 0 rescale = false setCondition(hpa, autoscalingv2.ScalingActive, v1.ConditionFalse, "ScalingDisabled", "scaling is disabled since the replica count of the target is zero") } else if currentReplicas > hpa.Spec.MaxReplicas { rescaleReason = "Current number of replicas above Spec.MaxReplicas" desiredReplicas = hpa.Spec.MaxReplicas } else if currentReplicas < minReplicas {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0)