Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for Unreserve (5.84 sec)

  1. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    					testCtx.p.Unreserve(testCtx.ctx, testCtx.state, tc.pod, selectedNode.Node().Name)
    					t.Run("unreserve", func(t *testing.T) {
    						testCtx.verify(t, tc.want.unreserve, initialObjects, nil, status)
    					})
    				} else {
    					if tc.want.unreserveBeforePreBind != nil {
    						initialObjects = testCtx.listAll(t)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/runtime/framework.go

    	defer func() {
    		metrics.FrameworkExtensionPointDuration.WithLabelValues(metrics.Unreserve, framework.Success.String(), f.profileName).Observe(metrics.SinceInSeconds(startTime))
    	}()
    	// Execute the Unreserve operation of each reserve plugin in the
    	// *reverse* order in which the Reserve operation was executed.
    	logger := klog.FromContext(ctx)
    	verboseLogs := logger.V(4).Enabled()
    	if verboseLogs {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    // that the pod should get bound to this node. Because Reserve did not actually
    // reserve claims, we need to do it now. For claims with the builtin controller,
    // we also handle the allocation.
    //
    // If anything fails, we return an error and
    // the pod will have to go into the backoff queue. The scheduler will call
    // Unreserve as part of the error handling.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  4. tensorflow/compiler/mlir/lite/flatbuffer_import.cc

    // of intermediate tensors since importer doesn't guarantee to preserve tensor
    // names except output tensors.
    Location OpLoc(const OperatorT& op,
                   const std::vector<std::unique_ptr<tflite::TensorT>>& tensors,
                   Builder builder, Location base) {
      if (op.outputs.empty()) return base;
    
      llvm::SmallVector<Location, 4> locations;
      locations.reserve(op.outputs.size());
      for (auto tensor_index : op.outputs) {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue May 21 18:21:50 UTC 2024
    - 66.8K bytes
    - Viewed (0)
  5. tensorflow/compiler/mlir/lite/transforms/lower_static_tensor_list.cc

          return success();
        }
    
        // Extract individual tensor list element and combine them using the tf.Pack
        // op.
        Location loc = op.getLoc();
        llvm::SmallVector<Value, 4> values;
        values.reserve(tensors.size());
        for (const tensorflow::Tensor &tensor : tensors) {
          auto attr_or = tensorflow::ConvertTensor(tensor, &rewriter);
          if (!attr_or.ok()) return failure();
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Jun 11 20:00:43 UTC 2024
    - 70.7K bytes
    - Viewed (0)
  6. src/net/url/url_test.go

    	{
    		"http://[fe80::1%25%65%6e%301-._~]/", // percent-encoded+unreserved zone identifier
    		&URL{
    			Scheme: "http",
    			Host:   "[fe80::1%en01-._~]",
    			Path:   "/",
    		},
    		"http://[fe80::1%25en01-._~]/",
    	},
    	// host and port subcomponents; IPv6 address with zone identifier in RFC 6874
    	{
    		"http://[fe80::1%25%65%6e%301-._~]:8080/", // percent-encoded+unreserved zone identifier
    		&URL{
    			Scheme: "http",
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:52:38 UTC 2024
    - 52.1K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    			return res, osErrToFileErr(err)
    		}
    		diskHealthCheckOK(ctx, err)
    	}
    
    	// If we have oldDataDir then we must preserve current xl.meta
    	// as backup, in-case needing renames().
    	if res.OldDataDir != "" {
    		if contextCanceled(ctx) {
    			return res, ctx.Err()
    		}
    
    		// preserve current xl.meta inside the oldDataDir.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (2)
  8. cmd/kubelet/app/server.go

    			if len(kubeletFlags.KubeletConfigFile) > 0 || len(kubeletFlags.KubeletDropinConfigDirectory) > 0 {
    				// We must enforce flag precedence by re-parsing the command line into the new object.
    				// This is necessary to preserve backwards-compatibility across binary upgrades.
    				// See issue #56171 for more details.
    				if err := kubeletConfigFlagPrecedence(kubeletConfig, args); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:34 UTC 2024
    - 53.9K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    	versionID := srcInfo.VersionID
    	if srcInfo.versionOnly {
    		versionID = dstOpts.VersionID
    		// preserve destination versionId if specified.
    		if versionID == "" {
    			versionID = mustGetUUID()
    			fi.IsLatest = true // we are creating a new version so this is latest.
    		}
    	}
    
    	modTime = UTCNow() // We only preserve modTime if dstOpts.MTime is true.
    	// in all other cases mtime is latest.
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  10. src/cmd/go/internal/modload/buildlist.go

    	rs.graphOnce.Do(func() {
    		roots := MainModules.Versions()
    		if inWorkspaceMode() {
    			// Use rs.rootModules to pull in the go and toolchain roots
    			// from the go.work file and preserve the invariant that all
    			// of rs.rootModules are in mg.g.
    			roots = rs.rootModules
    		}
    		mg := &ModuleGraph{
    			g: mvs.NewGraph(cmpVersion, roots),
    		}
    
    		if rs.pruning == pruned {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 16:04:44 UTC 2024
    - 53.8K bytes
    - Viewed (0)
Back to top