- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 196 for Unreserve (0.2 sec)
-
pkg/scheduler/framework/plugins/examples/stateful/stateful.go
return nil } // Unreserve is the function invoked by the framework when any error happens // during "reserve" extension point or later. In this example, the Unreserve // method loses its reference to the string slice, allowing it to be garbage // collected, and thereby "unallocating" the reserved resources. func (mp *MultipointExample) Unreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 03:43:17 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/examples/multipoint/multipoint.go
} if pod.Name == "my-test-pod" { state.Write(framework.StateKey(pod.Name), &stateData{data: "never bind"}) } return nil } // Unreserve is the function invoked by the framework when any error happens // during "reserve" extension point or later. func (mc CommunicatingPlugin) Unreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) { if pod.Name == "my-test-pod" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 03:43:17 UTC 2023 - 3K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_plugins.go
}, nil } } // FakeReservePlugin is a test reserve plugin. type FakeReservePlugin struct { Status *framework.Status } // Name returns name of the plugin. func (pl *FakeReservePlugin) Name() string { return "FakeReserve" } // Reserve invoked at the Reserve extension point. func (pl *FakeReservePlugin) Reserve(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) *framework.Status {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/scheduler/apis/config/v1/default_plugins.go
defaultPlugins.Score = mergePluginSet(logger, defaultPlugins.Score, customPlugins.Score) defaultPlugins.Reserve = mergePluginSet(logger, defaultPlugins.Reserve, customPlugins.Reserve) defaultPlugins.Permit = mergePluginSet(logger, defaultPlugins.Permit, customPlugins.Permit) defaultPlugins.PreBind = mergePluginSet(logger, defaultPlugins.PreBind, customPlugins.PreBind)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 06:27:01 UTC 2024 - 6.7K bytes - Viewed (0) -
src/runtime/tracebuf.go
} // varintAt writes varint v at byte position pos in buf. This always // consumes traceBytesPerNumber bytes. This is intended for when the caller // needs to reserve space for a varint but can't populate it until later. // Use varintReserve to reserve this space. func (buf *traceBuf) varintAt(pos int, v uint64) { for i := 0; i < traceBytesPerNumber; i++ { if i < traceBytesPerNumber-1 { buf.arr[pos] = 0x80 | byte(v)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 6.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/cluster_formation.cc
// op. So live-out values no longer escape the region. ReplaceLiveOutExternalUses(live_outs, launch_op); // Ensure that users of the launch op's results appear after the launch op // in order to preserve the dominance property. TF::ReorderOpResultUses(launch_op); } std::string GetDevice(Operation* op) { auto device_attr = op->getAttrOfType<StringAttr>("device");
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 05 13:30:21 UTC 2023 - 6.8K bytes - Viewed (0) -
src/runtime/sys_windows_arm.s
// tls_g stores the TLS slot allocated TlsAlloc(). TEXT runtimeĀ·save_g(SB),NOSPLIT,$0 MRC 15, 0, R0, C13, C0, 2 ADD $0xe10, R0 MOVW $runtimeĀ·tls_g(SB), R11 MOVW (R11), R11 MOVW g, R11<<2(R0) MOVW g, R0 // preserve R0 across call to setg<> RET // load_g loads the g register from thread-local memory, // for use after calling externally compiled // ARM code that overwrote those registers.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 21 15:56:43 UTC 2023 - 7.7K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/test/kotlin/org/gradle/kotlin/dsl/execution/ProgramTextTest.kt
class ProgramTextTest { @Test fun `preserve`() { val text = text("0123456789") assertThat( text.preserve(0..1), equalTo(text("01 ")) ) assertThat( text.preserve(0..1, 7..9), equalTo(text("01 789")) ) assertThat( text.preserve(7..9, 0..1), equalTo(text("01 789"))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 1.2K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/dsl/org.gradle.api.tasks.Sync.xml
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 795 bytes - Viewed (0) -
platforms/native/platform-native/src/testFixtures/groovy/org/gradle/nativeplatform/fixtures/app/IncrementalCppStaleLinkOutputAppWithLib.groovy
class IncrementalCppLib extends IncrementalCppElement { final greeter = new CppGreeter() final sum = new CppSum() final List<IncrementalElement.Transform> incrementalChanges = [preserve(greeter.asLib()), preserve(sum.asLib())] } class IncrementalCppAppWithDep extends IncrementalCppElement implements AppElement { final CppMain main IncrementalCppAppWithDep(IncrementalCppLib library) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 1.8K bytes - Viewed (0)