makeID - Code Search

pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

		// an unschedulable Pod schedulable.
		// - Delete. An unschedulable Pod may fail due to violating an existing Pod's topology spread constraints,
		// deleting an existing Pod may make it schedulable.
		{Event: framework.ClusterEvent{Resource: framework.Pod, ActionType: framework.All}, QueueingHintFn: pl.isSchedulableAfterPodChange},
		// Node add|delete|update maybe lead an topology key changed,

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Sat Mar 16 14:13:06 UTC 2024

- 12.7K bytes

- Viewed (0)

github.com/golang/go

test/fixedbugs/issue24491a.go

// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

// This test makes sure unsafe-uintptr arguments are handled correctly.

package main

import (
	"runtime"
	"unsafe"
)

var done = make(chan bool, 1)

func setup() unsafe.Pointer {
	s := "ok"
	runtime.SetFinalizer(&s, func(p *string) { *p = "FAIL" })
	return unsafe.Pointer(&s)
}

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Thu Aug 17 19:36:58 UTC 2023

- 1.9K bytes

- Viewed (0)

github.com/golang/go

test/fixedbugs/issue5373.go

package main

import (
	"fmt"
	"os"
)

func check(n int) {
	// When n == 0, i is untouched by the range loop.
	// Picking an initial value of -1 for i makes the
	// "want" calculation below correct in all cases.
	i := -1
	s := make([]byte, n)
	for i = range s {
		s[i] = 0
	}
	if want := n - 1; i != want {
		fmt.Printf("index after range with side-effect = %d want %d\n", i, want)
		os.Exit(1)
	}

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Mon May 02 13:43:18 UTC 2016

- 1.4K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/config/config.go

		return false
	}
	return true
}

// checkAndUpdatePod updates existing, and:
//   - if ref makes a meaningful change, returns needUpdate=true
//   - if ref makes a meaningful change, and this change is graceful deletion, returns needGracefulDelete=true
//   - if ref makes no meaningful change, but changes the pod status, returns needReconcile=true
//   - else return all false

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Tue Jun 04 06:25:43 UTC 2024

- 16.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/scheduler/framework/plugins/volumebinding/test_utils.go

	*v1.PersistentVolume
}

func makePV(name, className string) pvBuilder {
	return pvBuilder{PersistentVolume: &v1.PersistentVolume{
		ObjectMeta: metav1.ObjectMeta{
			Name: name,
		},
		Spec: v1.PersistentVolumeSpec{
			StorageClassName: className,
		},
	}}
}

func (pvb pvBuilder) withNodeAffinity(keyValues map[string][]string) pvBuilder {
	matchExpressions := make([]v1.NodeSelectorRequirement, 0)

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed Sep 13 07:42:19 UTC 2023

- 4.9K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/apis/core/validation/events.go

		if event.Series.LastObservedTime.Time == zeroTime {
			allErrs = append(allErrs, field.Required(field.NewPath("series.lastObservedTime"), ""))
		}
	}
	return allErrs
}

// legacyValidateEvent makes sure that the event makes sense.
func legacyValidateEvent(event *core.Event, requestVersion schema.GroupVersion) field.ErrorList {
	allErrs := field.ErrorList{}
	// Because go
	zeroTime := time.Time{}

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Sep 01 19:47:37 UTC 2022

- 9.2K bytes

- Viewed (0)

github.com/istio/istio

pilot/cmd/pilot-agent/app/request.go

// which interprets the output literally as json document.
var (
	requestCmd = &cobra.Command{
		Use:   "request <method> <path> [<body>]",
		Short: "Makes an HTTP request to the Envoy admin API",
		Args:  cobra.MinimumNArgs(2),
		PreRunE: func(cmd *cobra.Command, args []string) error {
			if !allowedPorts.Contains(debugRequestPort) {

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Fri Dec 08 03:13:05 UTC 2023

- 2K bytes

- Viewed (0)

github.com/golang/go

src/runtime/sys_libc.go

		mp.libcallpc = getcallerpc()
		// sp must be the last, because once async cpu profiler finds
		// all three values to be non-zero, it will use them
		mp.libcallsp = getcallersp()
	} else {
		// Make sure we don't reset libcallsp. This makes
		// libcCall reentrant; We remember the g/pc/sp for the
		// first call on an M, until that libcCall instance
		// returns.  Reentrance only matters for signals, as

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Tue Apr 05 17:54:15 UTC 2022

- 1.8K bytes

- Viewed (0)

github.com/golang/go

src/cmd/compile/internal/test/testdata/namedReturn_test.go

// Copyright 2016 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

// This test makes sure that naming named
// return variables in a return statement works.
// See issue #14904.

package main

import (
	"runtime"
	"testing"
)

// Our heap-allocated object that will be GC'd incorrectly.
// Note that we always check the second word because that's

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Wed Dec 23 06:40:04 UTC 2020

- 1.6K bytes

- Viewed (0)

github.com/golang/go

src/cmd/internal/bootstrap_test/overlaydir_test.go

// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package bootstrap_test

import (
	"io"
	"io/fs"
	"os"
	"path/filepath"
	"strings"
)

// overlayDir makes a minimal-overhead copy of srcRoot in which new files may be added.
//
// TODO: Once we no longer need to support the misc module in GOPATH mode,
// factor this function out into a package to reduce duplication.

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri May 12 12:35:05 UTC 2023

- 2.1K bytes

- Viewed (0)

Search Options