- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for rebind (0.18 sec)
-
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
} initialObjects = testCtx.listAll(t) initialObjects = testCtx.updateAPIServer(t, initialObjects, tc.prepare.prebind) status := testCtx.p.PreBind(testCtx.ctx, testCtx.state, tc.pod, selectedNode.Node().Name) t.Run("prebind", func(t *testing.T) { testCtx.verify(t, tc.want.prebind, initialObjects, nil, status) }) if tc.want.unreserveAfterBindFailure != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
// the claim is assumed to be allocated. // - PreBind for pod B is called first, tries to update reservedFor and // fails because the claim is not really allocated yet. // // We could avoid the ordering problem by allowing either pod A or pod B // to set the allocation. But that is more complicated and leads to another // problem: // - Pod A and B get scheduled as above.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
if !state.ShouldRecordPluginMetrics() { return pl.PreBind(ctx, state, pod, nodeName) } startTime := time.Now() status := pl.PreBind(ctx, state, pod, nodeName) f.metricsRecorder.ObservePluginDurationAsync(metrics.PreBind, pl.Name(), status.Code().String(), metrics.SinceInSeconds(startTime)) return status } // RunBindPlugins runs the set of configured bind plugins until one returns a non `Skip` status.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
while (taskFaker.isIdle()) { set("a", "a", "a") set("b", "b", "b") } // Cause the rebuild action to fail. filesystem.setFaultyRename(cacheDir / DiskLruCache.JOURNAL_FILE_BACKUP, true) taskFaker.runNextTask() // The rebuild is retried on cache hits and on cache edits. val snapshot = cache["b"]!! snapshot.close() assertThat(cache.edit("d")).isNull()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 75.8K bytes - Viewed (0) -
src/cmd/dist/test.go
setNoOpt() var t tester var noRebuild bool flag.BoolVar(&t.listMode, "list", false, "list available tests") flag.BoolVar(&t.rebuild, "rebuild", false, "rebuild everything first") flag.BoolVar(&noRebuild, "no-rebuild", false, "overrides -rebuild (historical dreg)") flag.BoolVar(&t.keepGoing, "k", false, "keep going even when error occurred")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 16:01:35 UTC 2024 - 50K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
if (logger.isDebugEnabled()) { logger.debug("Logged in as Bind DN. {}", context); } isBind = true; } catch (final Exception e) { logger.warn("LDAP configuration is wrong.", e); } } return isBind; } public OptionalEntity<FessUser> login(final String username, final String password) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 65.9K bytes - Viewed (0) -
src/net/http/transport.go
// didn't do so already. This can happen if the pconn // write loop exits without reading the write request. req.closeBody() } return nil, err } testHookRoundTripRetried() // Rewind the body if we're able to. req, err = rewindBody(req) if err != nil { return nil, err } } } func awaitLegacyCancel(ctx context.Context, cancel context.CancelCauseFunc, req *Request) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/resource_op_lifting.mlir
// CHECK-SAME: tensor<*xi32> func.return %1 : tensor<*xi32> } // If multiple types are used across reads and writes, check that the read uses // the most refined type. The first ReadVariable should refine the type from // *xi32 to ?xi32 and the assign should refine it further to 4xi32. // CHECK-LABEL: func @type_refinement_use_refined_type func.func @type_refinement_use_refined_type() -> tensor<4xi32> {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Oct 30 06:52:55 UTC 2023 - 74K bytes - Viewed (0) -
src/runtime/mgcpacer.go
) const ( // gcGoalUtilization is the goal CPU utilization for // marking as a fraction of GOMAXPROCS. // // Increasing the goal utilization will shorten GC cycles as the GC // has more resources behind it, lessening costs from the write barrier, // but comes at the cost of increasing mutator latency. gcGoalUtilization = gcBackgroundUtilization // gcBackgroundUtilization is the fixed CPU utilization for background
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 55.4K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
if prev, ok := previous[key]; ok && !changed.Contains(key) { // Reuse the previous EnvoyFilterWrapper if it exists and hasn't changed when optimized config rebuild is enabled efw = prev } } // Rebuild the envoy filter in all other cases. if efw == nil { efw = convertToEnvoyFilterWrapper(&envoyFilterConfig) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)