Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for syncJob (0.11 sec)

  1. pkg/kubelet/kubelet_pods.go

    	}
    	return resource.ExtractResourceValueByContainerName(fs, pod, containerName)
    }
    
    // killPod instructs the container runtime to kill the pod. This method requires that
    // the pod status contains the result of the last syncPod, otherwise it may fail to
    // terminate newly created containers and sandboxes.
    func (kl *Kubelet) killPod(ctx context.Context, pod *v1.Pod, p kubecontainer.Pod, gracePeriodOverride *int64) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  2. src/go/parser/parser.go

    			// both parseOperand and parseStmt call advance and
    			// correctly do not advance, thus the need for the
    			// invocation limit p.syncCnt).
    			if p.pos == p.syncPos && p.syncCnt < 10 {
    				p.syncCnt++
    				return
    			}
    			if p.pos > p.syncPos {
    				p.syncPos = p.pos
    				p.syncCnt = 0
    				return
    			}
    			// Reaching here indicates a parser bug, likely an
    			// incorrect token list in this function, but it only
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Dec 08 20:07:50 UTC 2023
    - 72.2K bytes
    - Viewed (0)
  3. pkg/controller/resourceclaim/controller.go

    	if err != nil {
    		return err
    	}
    
    	switch prefix {
    	case podKeyPrefix:
    		return ec.syncPod(ctx, namespace, name)
    	case claimKeyPrefix:
    		return ec.syncClaim(ctx, namespace, name)
    	default:
    		return fmt.Errorf("unexpected key prefix: %s", prefix)
    	}
    
    }
    
    func (ec *Controller) syncPod(ctx context.Context, namespace, name string) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  4. src/cmd/compile/internal/ppc64/ssa.go

    			st = ppc64.AMOVW
    		}
    		arg0 := v.Args[0].Reg()
    		arg1 := v.Args[1].Reg()
    		// If AuxInt == 0, LWSYNC (Store-Release), else SYNC
    		// SYNC
    		syncOp := ppc64.ASYNC
    		if v.AuxInt == 0 {
    			syncOp = ppc64.ALWSYNC
    		}
    		psync := s.Prog(syncOp)
    		psync.To.Type = obj.TYPE_NONE
    		// Store
    		p := s.Prog(st)
    		p.To.Type = obj.TYPE_MEM
    		p.To.Reg = arg0
    		p.From.Type = obj.TYPE_REG
    		p.From.Reg = arg1
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 19:59:38 UTC 2024
    - 55.4K bytes
    - Viewed (0)
  5. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go

    		// processing it at a very high frequency. The pod will be reprocessed when volume manager calls
    		// ReprocessPod() which is triggered by SyncPod.
    		dswp.markPodProcessed(uniquePodName)
    	}
    
    }
    
    // checkVolumeFSResize records desired PVC size for a volume mounted by the pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.3.md

        * This eliminates the race conditions between the pod creation loop and the orphaned volumes loops. It also removes the unmount/detach from the `syncPod()` path so volume clean up never blocks the `syncPod` loop.
    
    
    
    # v1.3.0-beta.1
    
    [Documentation](http://kubernetes.github.io) & [Examples](http://releases.k8s.io/release-1.3/examples)
    
    ## Downloads
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 84K bytes
    - Viewed (0)
Back to top