Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for watchForLockfileContention (0.27 sec)

  1. cmd/kubelet/app/server_unsupported.go

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package app
    
    import "errors"
    
    func watchForLockfileContention(path string, done chan struct{}) error {
    	return errors.New("kubelet unsupported in this build")
    }
    
    func isCgroup2UnifiedMode() bool {
    	return false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 820 bytes
    - Viewed (0)
  2. cmd/kubelet/app/server_linux.go

    limitations under the License.
    */
    
    package app
    
    import (
    	"k8s.io/klog/v2"
    	"k8s.io/utils/inotify"
    
    	libcontainercgroups "github.com/opencontainers/runc/libcontainer/cgroups"
    )
    
    func watchForLockfileContention(path string, done chan struct{}) error {
    	watcher, err := inotify.NewWatcher()
    	if err != nil {
    		klog.ErrorS(err, "Unable to create watcher for lockfile")
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 26 09:04:06 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  3. cmd/kubelet/app/server.go

    			return fmt.Errorf("unable to acquire file lock on %q: %w", s.LockFilePath, err)
    		}
    		if s.ExitOnLockContention {
    			klog.InfoS("Watching for inotify events", "path", s.LockFilePath)
    			if err := watchForLockfileContention(s.LockFilePath, done); err != nil {
    				return err
    			}
    		}
    	}
    
    	// Register current configuration with /configz endpoint
    	err = initConfigz(&s.KubeletConfiguration)
    	if 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)
Back to top