Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 24 for mirror_pad (0.25 sec)

  1. pkg/kubelet/runonce.go

    		if err := kl.mirrorPodClient.CreateMirrorPod(pod); err != nil {
    			klog.ErrorS(err, "Failed creating a mirror pod", "pod", klog.KObj(pod))
    		}
    		mirrorPod, _ := kl.podManager.GetMirrorPodByPod(pod)
    		if isTerminal, err = kl.SyncPod(ctx, kubetypes.SyncPodUpdate, pod, mirrorPod, status); err != nil {
    			return fmt.Errorf("error syncing pod %q: %v", format.Pod(pod), err)
    		}
    		if retry >= runOnceMaxRetries {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  2. tensorflow/cc/gradients/array_grad_test.cc

      TensorShape y_shape({4, 7});
      auto y = MirrorPad(scope_, x, paddings, "REFLECT");
      RunTest(x, x_shape, y, y_shape);
    }
    
    TEST_F(ArrayGradTest, MirrorPadGrad_Symmetric) {
      TensorShape x_shape({2, 3});
      auto x = Placeholder(scope_, DT_FLOAT, Placeholder::Shape(x_shape));
      auto paddings = Const(scope_, {{1, 1}, {2, 2}});
      TensorShape y_shape({4, 7});
      auto y = MirrorPad(scope_, x, paddings, "SYMMETRIC");
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Oct 10 23:33:32 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  3. pkg/kubelet/pod_workers.go

    		opts.Pod = other.Pod
    	}
    	// running pods will not persist but will be remembered for replay
    	opts.RunningPod = other.RunningPod
    	// if mirrorPod was not provided, remember the last one for replay
    	if other.MirrorPod != nil {
    		opts.MirrorPod = other.MirrorPod
    	}
    	// accumulate kill pod options
    	if other.KillPodOptions != nil {
    		opts.KillPodOptions = &KillPodOptions{}
    		if other.KillPodOptions.Evict {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 13:22:37 UTC 2024
    - 74.8K bytes
    - Viewed (0)
  4. pkg/kubelet/status/status_manager.go

    				klog.InfoS("Got unexpected podIsFinished=false, while podIsFinished=true in status cache, programmer error.", "pod", klog.KObj(pod))
    				podIsFinished = true
    			}
    		}
    	} else if mirrorPod, ok := m.podManager.GetMirrorPodByPod(pod); ok {
    		oldStatus = mirrorPod.Status
    	} else {
    		oldStatus = pod.Status
    	}
    
    	// Check for illegal state transition in containers
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
  5. tensorflow/cc/gradients/array_grad.cc

      grad_outputs->push_back(tensorflow::ops::internal::MirrorPadGrad(
          scope, grad_inputs[0], op.input(1), mode));
      grad_outputs->push_back(NoGradient());
      return scope.status();
    }
    REGISTER_GRADIENT_OP("MirrorPad", MirrorPadGrad);
    
    // TODO(suharshs): b/34770860. This gradient was within 1e-3 but not 1e-4.
    Status MirrorPadGradGrad(const Scope& scope, const Operation& op,
                             const std::vector<Output>& grad_inputs,
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Oct 10 23:33:32 UTC 2023
    - 31.7K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_test.go

    	// Mirror pod has an outdated spec.
    	mirrorPod := podWithUIDNameNsSpec("11111111", "foo", "ns", v1.PodSpec{
    		Containers: []v1.Container{
    			{Name: "1234", Image: "bar"},
    		},
    	})
    	mirrorPod.Annotations[kubetypes.ConfigSourceAnnotationKey] = "api"
    	mirrorPod.Annotations[kubetypes.ConfigMirrorAnnotationKey] = "mirror"
    
    	pods := []*v1.Pod{pod, mirrorPod}
    	kl.podManager.SetPods(pods)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_pods.go

    			continue
    		}
    		kl.podWorkers.UpdatePod(UpdatePodOptions{
    			UpdateType: kubetypes.SyncPodCreate,
    			Pod:        pod,
    			MirrorPod:  mirrorPod,
    		})
    
    		// the desired pod is now known as well
    		workingPods[desiredPod.UID] = PodWorkerSync{State: SyncPod, HasConfig: true, Static: isStatic}
    		if isStatic {
    			// restartable static pods are the normal case
    			restartCountStatic++
    		} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_pods_test.go

    				pod := staticPod()
    
    				w.UpdatePod(UpdatePodOptions{
    					UpdateType: kubetypes.SyncPodCreate,
    					StartTime:  time.Unix(1, 0).UTC(),
    					Pod:        pod,
    					MirrorPod:  mirrorPod(pod, "node-1", "node-uid-1"),
    				})
    				drainAllWorkers(w)
    
    				// expect we get a pod sync record for kill that should have the default grace period
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  9. pkg/kubelet/metrics/metrics.go

    	RunningContainersKey               = "running_containers"
    	DesiredPodCountKey                 = "desired_pods"
    	ActivePodCountKey                  = "active_pods"
    	MirrorPodCountKey                  = "mirror_pods"
    	WorkingPodCountKey                 = "working_pods"
    	OrphanedRuntimePodTotalKey         = "orphaned_runtime_pods_total"
    	RestartedPodTotalKey               = "restarted_pods_total"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 15:13:25 UTC 2024
    - 45.6K bytes
    - Viewed (0)
  10. tensorflow/compiler/mlir/lite/schema/schema_generated.h

    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue May 21 18:21:50 UTC 2024
    - 1M bytes
    - Viewed (0)
Back to top