- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 117 for addpool (0.57 sec)
-
maven-core/src/test/java/org/apache/maven/lifecycle/EmptyLifecyclePluginAnalyzer.java
for (String goal : goals) { PluginExecution pluginExecution = new PluginExecution(); pluginExecution.setId("default-" + goal); pluginExecution.addGoal(goal); plugin.addExecution(pluginExecution); } return plugin; }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 2.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/tf_to_corert/tf_to_corert_pipeline.mlir
// CHECK-NEXT: [[o7:%.*]] = tfrt_fallback_async.executeop key({{[0-9]+}}) cost({{.*}}) device("/job:localhost/replica:0/task:0/device:CPU:0") "tf.AvgPool"([[o6]]) // CHECK-NEXT: [[o8:%.*]] = tfrt_fallback_async.executeop key({{[0-9]+}}) cost({{.*}}) device("/job:localhost/replica:0/task:0/device:CPU:0") "tf.Reshape"([[o7]], [[o1]])
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 08 00:18:59 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
syncer := newTestManager(&fake.Clientset{}) pod := getTestPod() pod.UID = "first" syncer.podManager.(mutablePodManager).AddPod(pod) differentPod := getTestPod() differentPod.UID = "second" syncer.podManager.(mutablePodManager).AddPod(differentPod) syncer.kubeClient = fake.NewSimpleClientset(pod) syncer.SetPodStatus(differentPod, getRandomPodStatus())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
platforms/core-configuration/declarative-dsl-provider/src/main/kotlin/org/gradle/internal/declarativedsl/conventions/conventions.kt
override fun apply(receiver: AssignmentRecordConventionReceiver) { receiver.receive(assignmentRecord) } } /** * A convention that applies a data addition operation (e.g. addFoo("bar")). */ class AdditionRecordConvention(private val dataAdditionRecord: DataAdditionRecord) : Convention<AdditionRecordConventionReceiver> { override fun apply(receiver: AdditionRecordConventionReceiver) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 12:25:47 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/scheduler/internal/cache/interface.go
// ForgetPod removes an assumed pod from cache. ForgetPod(logger klog.Logger, pod *v1.Pod) error // AddPod either confirms a pod if it's assumed, or adds it back if it's expired. // If added back, the pod's information would be added again. AddPod(logger klog.Logger, pod *v1.Pod) error // UpdatePod removes oldPod's information and adds newPod's information.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 5.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go
}) addNodes(t, controller, node) pod := generatePod("128.0.0.1", "pod1", ns, "svcaccount", "node1", map[string]string{"app": appName}, map[string]string{}) pods := []*corev1.Pod{pod} addPods(t, controller, fx, pods...) createServiceWait(controller, svcName, ns, nil, nil, []int32{8080}, map[string]string{"app": appName}, t) // Ensure that the service is available.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/filtering.go
// PreFilterExtensions returns prefilter extensions, pod add and remove. func (pl *PodTopologySpread) PreFilterExtensions() framework.PreFilterExtensions { return pl } // AddPod from pre-computed data in cycleState. func (pl *PodTopologySpread) AddPod(ctx context.Context, cycleState *framework.CycleState, podToSchedule *v1.Pod, podInfoToAdd *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status { s, err := getPreFilterState(cycleState)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 12.4K bytes - Viewed (0) -
pkg/registry/core/service/strategy_test.go
patch: patches(setTypeClusterIP, addPort), expect: makeValidServiceCustom(addPort), }, { name: "don't clear nodePorts when adding a port with NodePort", svc: makeValidServiceCustom(setTypeLoadBalancer, setNodePorts), patch: patches(setTypeClusterIP, addPort, setNodePorts), expect: makeValidServiceCustom(addPort, setNodePorts), }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 32.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
pc.addPod(pod, ip, key) } else { return nil } case model.EventUpdate: if !shouldPodBeInEndpoints(pod) || !IsPodReady(pod) { // delete only if this pod was in the cache if !pc.deleteIP(ip, key) { return nil } ev = model.EventDelete } else if shouldPodBeInEndpoints(pod) && IsPodReady(pod) { pc.addPod(pod, ip, key) } else { return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
maven-compat/src/test/java/org/apache/maven/project/EmptyLifecycleExecutor.java
for (String goal : goals) { PluginExecution pluginExecution = new PluginExecution(); pluginExecution.setId("default-" + goal); pluginExecution.addGoal(goal); plugin.addExecution(pluginExecution); } return plugin; } public void calculateForkedExecutions(MojoExecution mojoExecution, MavenSession session) {}
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Apr 25 05:46:50 UTC 2024 - 3.5K bytes - Viewed (0)