package threading

import "k8s.io/kubernetes/pkg/util/threading"

Index ¶

• func DeadlockWatchdog(lock sync.Locker, name string, maxLockPeriod time.Duration)
• func DeadlockWatchdogReadLock(lock *sync.RWMutex, name string, maxLockPeriod time.Duration)

Functions ¶

func DeadlockWatchdog ¶

func DeadlockWatchdog(lock sync.Locker, name string, maxLockPeriod time.Duration)

func DeadlockWatchdogReadLock ¶

func DeadlockWatchdogReadLock(lock *sync.RWMutex, name string, maxLockPeriod time.Duration)

DeadlockWatchdogReadLock creates a watchdog on read/write mutex. If the mutex can not be acquired for read access within 'maxLockPeriod', the program exits via glog.Exitf() or os.Exit() if that fails 'name' is a semantic name that is useful for the user and is printed on exit.

Source Files ¶

deadlock-detector.go