Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 61 for npidle (0.15 sec)

  1. src/runtime/proc.go

    		timerpMask.clear(pp.id)
    	}
    	idlepMask.set(pp.id)
    	pp.link = sched.pidle
    	sched.pidle.set(pp)
    	sched.npidle.Add(1)
    	if !pp.limiterEvent.start(limiterEventIdle, now) {
    		throw("must be able to track idle limiter event")
    	}
    	return now
    }
    
    // pidleget tries to get a p from the _Pidle list, acquiring ownership.
    //
    // sched.lock must be held.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  2. src/runtime/runtime2.go

    	pollUntil atomic.Int64 // time to which current poll is sleeping
    
    	lock mutex
    
    	// When increasing nmidle, nmidlelocked, nmsys, or nmfreed, be
    	// sure to call checkdead().
    
    	midle        muintptr // idle m's waiting for work
    	nmidle       int32    // number of idle m's waiting for work
    	nmidlelocked int32    // number of locked m's waiting for work
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  3. src/runtime/mgcpacer.go

    //
    //go:nowritebarrier
    func (c *gcControllerState) enlistWorker() {
    	// If there are idle Ps, wake one so it will run an idle worker.
    	// NOTE: This is suspected of causing deadlocks. See golang.org/issue/19112.
    	//
    	//	if sched.npidle.Load() != 0 && sched.nmspinning.Load() == 0 {
    	//		wakep()
    	//		return
    	//	}
    
    	// There are no idle Ps. If we need more dedicated workers,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 55.4K bytes
    - Viewed (0)
  4. pilot/pkg/model/config.go

    // matching the needle and it's value, or false if no element in the maps matches the needle.
    func MostSpecificHostMatch[V any](needle host.Name, specific map[host.Name]V, wildcard map[host.Name]V) (host.Name, V, bool) {
    	if needle.IsWildCarded() {
    		// exact match first
    		if v, ok := wildcard[needle]; ok {
    			return needle, v, true
    		}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 08:51:03 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  5. src/slices/sort_benchmark_test.go

    			floats := make([]float64, size)
    			for i := range floats {
    				floats[i] = float64(i)
    			}
    			midpoint := len(floats) / 2
    			needle := (floats[midpoint] + floats[midpoint+1]) / 2
    			b.ResetTimer()
    			for i := 0; i < b.N; i++ {
    				slices.BinarySearch(floats, needle)
    			}
    		})
    	}
    }
    
    type myStruct struct {
    	a, b, c, d string
    	n          int
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 04 23:39:07 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  6. platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonStateCoordinatorTest.groovy

            0 * _._
        }
    
        def "idle millis is 0 if daemon is busy"() {
            given:
            Runnable command = Mock()
    
            when:
            coordinator.runCommand(command, "some command")
    
            then:
            1 * command.run() >> {
                coordinator.getIdleMillis() == 0L
            }
        }
    
        def "idle millis is > 0 when daemon is idle"() {
            when:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sun May 05 22:24:02 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  7. pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go

    	result.NonResourceURLs = rule.NonResourceURLs
    	result.Verbs = rule.Verbs
    	return result
    }
    
    func ruleExists(haystack []rbacv1.PolicyRule, needle rbacv1.PolicyRule) bool {
    	for _, curr := range haystack {
    		if equality.Semantic.DeepEqual(curr, needle) {
    			return true
    		}
    	}
    	return false
    }
    
    // Run starts the controller and blocks until stopCh is closed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8K bytes
    - Viewed (0)
  8. src/net/http/httptest/server_test.go

    	cnew := dial()
    	defer cnew.Close()
    
    	// Keep one connection in StateIdle (idle after a request)
    	cidle := dial()
    	defer cidle.Close()
    	cidle.Write([]byte("HEAD / HTTP/1.1\r\nHost: foo\r\n\r\n"))
    	_, err := http.ReadResponse(bufio.NewReader(cidle), nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	ts.Close() // test we don't hang here forever.
    }
    
    // Issue 14290
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 18 16:57:12 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  9. src/slices/slices.go

    }
    
    // startIdx returns the index in haystack where the needle starts.
    // prerequisite: the needle must be aliased entirely inside the haystack.
    func startIdx[E any](haystack, needle []E) int {
    	p := &needle[0]
    	for i := range haystack {
    		if p == &haystack[i] {
    			return i
    		}
    	}
    	// TODO: what if the overlap is by a non-integral number of Es?
    	panic("needle not found")
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 29 14:01:59 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  10. cmd/metrics-v3-system-cpu.go

    	// stores them in resourceMetricsMap. We can use it to get the Avg values of CPU idle and IOWait.
    	cpuResourceMetrics, found := resourceMetricsMap[cpuSubsystem]
    	if found {
    		if cpuIdleMetric, ok := cpuResourceMetrics[getResourceKey(cpuIdle, nil)]; ok {
    			avgVal := math.Round(cpuIdleMetric.Avg*100) / 100
    			m.Set(sysCPUAvgIdle, avgVal)
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Apr 23 23:56:12 UTC 2024
    - 3K bytes
    - Viewed (0)
Back to top