Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for _ecounters (0.2 sec)

  1. pkg/controller/job/job_controller.go

    //  2. Remove the finalizers from the Pods if they completed or were removed
    //     or the job was removed.
    //  3. Increment job counters for pods that no longer have a finalizer.
    //  4. Add Complete condition if satisfied with current counters.
    //
    // It does this up to a limited number of Pods so that the size of .status
    // doesn't grow too much and this sync doesn't starve other Jobs.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  2. pkg/proxy/nftables/proxier.go

    					Name: epInfo.affinitySetName,
    					Type: ipvX_addr,
    					Flags: []knftables.SetFlag{
    						// The nft docs say "dynamic" is only
    						// needed for sets containing stateful
    						// objects (eg counters), but (at least on
    						// RHEL8) if we create the set without
    						// "dynamic", it later gets mutated to
    						// have it, and then the next attempt to
    						// tx.Add() it here fails because it looks
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  3. src/net/http/httputil/reverseproxy_test.go

    	rpURL, err := url.Parse(backendServer.URL)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	rproxy := NewSingleHostReverseProxy(rpURL)
    
    	// Ensure that the handler panics when the body read encounters an
    	// io.ErrUnexpectedEOF
    	defer func() {
    		err := recover()
    		if err == nil {
    			t.Fatal("handler should have panicked")
    		}
    		if err != http.ErrAbortHandler {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 54.6K bytes
    - Viewed (0)
  4. pkg/proxy/iptables/proxier.go

    				proxier.logger.Error(err, "Failed to ensure chain jumps", "table", jump.table, "srcChain", jump.srcChain, "dstChain", jump.dstChain)
    				return
    			}
    		}
    
    		// ensure the nfacct counters
    		if proxier.nfacct != nil {
    			for name := range proxier.nfAcctCounters {
    				if err := proxier.nfacct.Ensure(name); err != nil {
    					proxier.nfAcctCounters[name] = false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  5. src/runtime/mgc.go

    // improve parallelism, the garbage collector breaks up scan jobs for
    // objects larger than maxObletBytes into "oblets" of at most
    // maxObletBytes. When scanning encounters the beginning of a large
    // object, it scans only the first oblet and enqueues the remaining
    // oblets as new scan jobs.
    
    package runtime
    
    import (
    	"internal/cpu"
    	"internal/runtime/atomic"
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  6. src/runtime/traceback.go

    	// stack trace.
    	tracebackOuterFrames = 50
    )
    
    // unwindFlags control the behavior of various unwinders.
    type unwindFlags uint8
    
    const (
    	// unwindPrintErrors indicates that if unwinding encounters an error, it
    	// should print a message and stop without throwing. This is used for things
    	// like stack printing, where it's better to get incomplete information than
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  7. src/runtime/pprof/pprof_test.go

    		},
    	}, {
    		name: "bug35538",
    		input: []uint64{
    			3, 0, 500, // hz = 500. Must match the period.
    			// Fake frame: tryAdd will have inlinedCallerDump
    			// (stack[1]) on the deck when it encounters the next
    			// inline function. It should accept this.
    			7, 0, 10, inlinedCallerStack[0], inlinedCallerStack[1], inlinedCallerStack[0], inlinedCallerStack[1],
    			5, 0, 20, inlinedCallerStack[0], inlinedCallerStack[1],
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 68.8K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    	}
    
    	cont := out.Continue
    
    	// the second list call should try to get 2 more items from etcd
    	// but since there is only one item left, that is all we should get with no continueValue
    	// both read counters should be incremented for the singular calls they make in this case
    	out = &example.PodList{}
    	options = storage.ListOptions{
    		// ResourceVersion should be unset when setting continuation token.
    		ResourceVersion: "",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  9. src/runtime/mheap.go

    	// freeindex is the slot index between 0 and nelems at which to begin scanning
    	// for the next free object in this span.
    	// Each allocation scans allocBits starting at freeindex until it encounters a 0
    	// indicating a free object. freeindex is then adjusted so that subsequent scans begin
    	// just past the newly discovered free object.
    	//
    	// If freeindex == nelem, this span has no free objects.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 78K bytes
    - Viewed (0)
Back to top