Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 544 for Dlog (0.33 sec)

  1. pkg/kubelet/kuberuntime/labels.go

    		if err != nil {
    			klog.ErrorS(err, "Unable to marshal lifecycle PreStop handler for container", "containerName", container.Name, "pod", klog.KObj(pod))
    		} else {
    			annotations[containerPreStopHandlerLabel] = string(rawPreStop)
    		}
    	}
    
    	if len(container.Ports) > 0 {
    		rawContainerPorts, err := json.Marshal(container.Ports)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. pkg/kubelet/util/swap/swap_util.go

    			// https://github.com/torvalds/linux/blob/v6.8/mm/shmem.c#L4004-L4011
    			// https://github.com/kubernetes/kubernetes/issues/125137
    			klog.InfoS("Running under a user namespace - tmpfs noswap is not supported")
    			return false
    		}
    
    		kernelVersion, err := utilkernel.GetVersion()
    		if err != nil {
    			klog.ErrorS(err, "cannot determine kernel version, unable to determine is tmpfs noswap is supported")
    			return false
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 10:07:06 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    				}
    				if !suitable {
    					return statusUnschedulable(logger, "resourceclaim cannot be allocated for the node (unsuitable)", "pod", klog.KObj(pod), "node", klog.KObj(node), "resourceclaim", klog.KObj(claim))
    				}
    			} else {
    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. pkg/controller/deployment/deployment_controller.go

    	}
    
    	<-ctx.Done()
    }
    
    func (dc *DeploymentController) addDeployment(logger klog.Logger, obj interface{}) {
    	d := obj.(*apps.Deployment)
    	logger.V(4).Info("Adding deployment", "deployment", klog.KObj(d))
    	dc.enqueueDeployment(d)
    }
    
    func (dc *DeploymentController) updateDeployment(logger klog.Logger, old, cur interface{}) {
    	oldD := old.(*apps.Deployment)
    	curD := cur.(*apps.Deployment)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  5. pkg/controller/volume/pvprotection/pv_protection_controller.go

    	return true
    }
    
    func (c *Controller) processPV(ctx context.Context, pvName string) error {
    	logger := klog.FromContext(ctx)
    	logger.V(4).Info("Processing PV", "PV", klog.KRef("", pvName))
    	startTime := time.Now()
    	defer func() {
    		logger.V(4).Info("Finished processing PV", "PV", klog.KRef("", pvName), "cost", time.Since(startTime))
    	}()
    
    	pv, err := c.pvLister.Get(pvName)
    	if apierrors.IsNotFound(err) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  6. pkg/volume/util/atomic_writer.go

    			klog.V(4).Infof("%s: write required for target directory %v", w.logContext, w.targetDir)
    		}
    	}
    
    	if shouldWrite {
    		// (5)
    		tsDir, err := w.newTimestampDir()
    		if err != nil {
    			klog.V(4).Infof("%s: error creating new ts data directory: %v", w.logContext, err)
    			return err
    		}
    		tsDirName := filepath.Base(tsDir)
    
    		// (6)
    		if err = w.writePayloadToDir(cleanPayload, tsDir); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/runtime/framework.go

    	}()
    	logger := klog.FromContext(ctx)
    	verboseLogs := logger.V(4).Enabled()
    	if verboseLogs {
    		logger = klog.LoggerWithName(logger, "PreBind")
    		logger = klog.LoggerWithValues(logger, "node", klog.ObjectRef{Name: nodeName})
    	}
    	for _, pl := range f.preBindPlugins {
    		ctx := ctx
    		if verboseLogs {
    			logger := klog.LoggerWithName(logger, pl.Name())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  8. pkg/controller/daemon/daemon_controller.go

    				podsToDelete = append(podsToDelete, oldestOldPod.Name)
    			case podutil.IsPodAvailable(oldestNewPod, ds.Spec.MinReadySeconds, metav1.Time{Time: dsc.failedPodsBackoff.Clock.Now()}):
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  9. pkg/controller/volume/pvcprotection/pvc_protection_controller.go

    	return true
    }
    
    func (c *Controller) processPVC(ctx context.Context, pvcNamespace, pvcName string) error {
    	logger := klog.FromContext(ctx)
    	logger.V(4).Info("Processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName))
    	startTime := time.Now()
    	defer func() {
    		logger.V(4).Info("Finished processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName), "duration", time.Since(startTime))
    	}()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 14K bytes
    - Viewed (0)
  10. pkg/volume/util/operationexecutor/operation_generator.go

    		simpleMsg, detailedMsg := volumeToMount.GenerateMsg("MapVolume.MapPodDevice succeeded", fmt.Sprintf("globalMapPath %q", globalMapPath))
    		verbosity := klog.Level(4)
    		og.recorder.Eventf(volumeToMount.Pod, v1.EventTypeNormal, kevents.SuccessfulMountVolume, simpleMsg)
    		klog.V(verbosity).InfoS(detailedMsg, "pod", klog.KObj(volumeToMount.Pod))
    
    		// Device mapping for pod device map path succeeded
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
Back to top