Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,361 for rescorer (0.22 sec)

  1. pkg/registry/core/service/allocator/interfaces.go

    	// called more than once.
    	Destroy()
    }
    
    // Snapshottable is an Interface that can be snapshotted and restored. Snapshottable
    // should be threadsafe.
    type Snapshottable interface {
    	Interface
    	Snapshot() (string, []byte)
    	Restore(string, []byte) error
    }
    
    type AllocatorFactory func(max int, rangeSpec string) (Interface, error)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 22 10:35:43 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  2. tools/istio-iptables/pkg/builder/testdata/append-multi-restore.golden

    Leonardo Sarra <******@****.***> 1718116194 +0200
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 11 14:29:54 UTC 2024
    - 91 bytes
    - Viewed (0)
  3. pkg/registry/core/service/ipallocator/bitmap.go

    	}
    	rangeString, data := snapshottable.Snapshot()
    	dst.Range = rangeString
    	dst.Data = data
    	return nil
    }
    
    // Restore restores the pool to the previously captured state. ErrMismatchedNetwork
    // is returned if the provided IPNet range doesn't exactly match the previous range.
    func (r *Range) Restore(net *net.IPNet, data []byte) error {
    	if !net.IP.Equal(r.net.IP) || net.Mask.String() != r.net.Mask.String() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 25 20:32:40 UTC 2023
    - 10.8K bytes
    - Viewed (0)
  4. src/go/doc/testdata/example.go

    }
    
    func RunExamples(examples []InternalExample) (ok bool) {
    	ok = true
    
    	var eg InternalExample
    
    	stdout, stderr := os.Stdout, os.Stderr
    	defer func() {
    		os.Stdout, os.Stderr = stdout, stderr
    		if e := recover(); e != nil {
    			fmt.Printf("--- FAIL: %s\npanic: %v\n", eg.Name, e)
    			os.Exit(1)
    		}
    	}()
    
    	for _, eg = range examples {
    		if *chatty {
    			fmt.Printf("=== RUN: %s\n", eg.Name)
    		}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Oct 02 02:28:27 UTC 2022
    - 1.6K bytes
    - Viewed (0)
  5. src/runtime/cgocall.go

    	if raceenabled {
    		racereleasemerge(unsafe.Pointer(&racecgosync))
    	}
    
    	// Do not unwind m->g0->sched.sp.
    	// Our caller, cgocallback, will do that.
    	restore = false
    }
    
    func unwindm(restore *bool) {
    	if *restore {
    		// Restore sp saved by cgocallback during
    		// unwind of g's stack (see comment at top of file).
    		mp := acquirem()
    		sched := &mp.g0.sched
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:47 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/cpumanager/state/state_checkpoint.go

    		}
    		if _, exists := dst.Entries[podUID]; !exists {
    			dst.Entries[podUID] = make(map[string]string)
    		}
    		dst.Entries[podUID][containerName] = cset
    	}
    	return nil
    }
    
    // restores state from a checkpoint and creates it if it doesn't exist
    func (sc *stateCheckpoint) restoreState() error {
    	sc.mux.Lock()
    	defer sc.mux.Unlock()
    	var err error
    
    	checkpointV1 := newCPUManagerCheckpointV1()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 00:59:30 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  7. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/InputTrackingState.kt

            ++inputTrackingDisabledCounterForThread
        }
    
        /**
         * Restores the input tracking state to the state it was in before the last call to
         * [disableForCurrentThread].
         */
        fun restoreForCurrentThread() {
            Preconditions.checkState(inputTrackingDisabledCounterForThread > 0, "Restore input tracking state without prior disable is detected")
            --inputTrackingDisabledCounterForThread
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  8. internal/bucket/lifecycle/lifecycle.go

    	}
    
    	return Event{
    		Action: NoneAction,
    	}
    }
    
    // ExpectedExpiryTime calculates the expiry, transition or restore date/time based on a object modtime.
    // The expected transition or restore time is always a midnight time following the object
    // modification time plus the number of transition/restore days.
    //
    //	e.g. If the object modtime is `Thu May 21 13:42:50 GMT 2020` and the object should
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  9. test/fixedbugs/issue32187.go

    		{"type assertion", "", func() { _ = x == x.(*int) }},
    		{"out of bounds", "", func() { _ = x == s[1] }},
    		{"nil pointer dereference #1", "", func() { _ = x == *p }},
    		// TODO(mdempsky): Restore "nil pointer dereference" check. The Go
    		// spec doesn't mandate an order for panics (or even panic
    		// messages), but left-to-right is less confusing to users.
    		{"nil pointer dereference #2", "", func() { _ = *l == r[0] }},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jul 19 23:02:39 UTC 2022
    - 1.5K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/noderesources/fit.go

    	// preScoreStateKey is the key in CycleState to NodeResourcesFit pre-computed data for Scoring.
    	preScoreStateKey = "PreScore" + Name
    )
    
    // nodeResourceStrategyTypeMap maps strategy to scorer implementation
    var nodeResourceStrategyTypeMap = map[config.ScoringStrategyType]scorer{
    	config.LeastAllocated: func(args *config.NodeResourcesFitArgs) *resourceAllocationScorer {
    		resources := args.ScoringStrategy.Resources
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
Back to top