- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 128 for acquirem (0.36 sec)
-
pkg/util/flock/flock_unix.go
See the License for the specific language governing permissions and limitations under the License. */ package flock import "golang.org/x/sys/unix" // Acquire acquires a lock on a file for the duration of the process. This method // is reentrant. func Acquire(path string) error { fd, err := unix.Open(path, unix.O_CREAT|unix.O_RDWR|unix.O_CLOEXEC, 0600) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 1.1K bytes - Viewed (0) -
src/runtime/mklockrank.go
// the syntax. // // "a < b" means a must be acquired before b if both are held // (or, if b is held, a cannot be acquired). // // "NONE < a" means no locks may be held when a is acquired. // // If a lock is not given a rank, then it is assumed to be a leaf // lock, which means no other lock can be acquired while it is held. // Therefore, leaf locks do not need to be given an explicit rank. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.1K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
lrwm := NewLRWMutex() if !lrwm.GetRLock(ctx, "", "object1", time.Second) { panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") if !lrwm.GetRLock(ctx, "", "object1", time.Second) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() { time.Sleep(2 * time.Second) lrwm.RUnlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 7.9K bytes - Viewed (0) -
src/cmd/go/internal/base/limit.go
type netTokenChecker struct { released bool // We want to use a finalizer to check that all acquired tokens are returned, // so we arbitrarily pad the tokens with a string to defeat the runtime's // “tiny allocator”. unusedAvoidTinyAllocator string } func (c *netTokenChecker) panicUnreleased() { panic("internal error: net token acquired but not released")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 19 02:47:12 UTC 2023 - 1.9K bytes - Viewed (0) -
tensorflow/compiler/jit/variable_info_util.h
// Acquires the mutexes for all the variables in `variables` using a // deadlock-safe protocol (acquire the mutexes in increasing-address order). // // `variables` is allowed to contain instances that don't track a resource // variable (i.e. variables[i].var() can be null for some i). // // If the variable is read_only(), only acquires reader locks.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Feb 14 21:57:02 UTC 2023 - 4.3K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") drwm2 := NewDRWMutex(ds, "simplelock") ctx2, cancel2 := context.WithCancel(context.Background()) if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
src/runtime/lock_sema.go
// // func semacreate(mp *m) // Create a semaphore for mp, if it does not already have one. // // func semasleep(ns int64) int32 // If ns < 0, acquire m's semaphore and return 0. // If ns >= 0, try to acquire m's semaphore for at most ns nanoseconds. // Return 0 if the semaphore was acquired, -1 if interrupted or timed out. // // func semawakeup(mp *m) // Wake up mp, which is or will soon be sleeping on its semaphore. const (
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0) -
cmd/lock-rest-server.go
} // LockHandler - Acquires a lock. func (l *lockRESTServer) LockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { resp := lockRPCLock.NewResponse() success, err := l.ll.Lock(context.Background(), *args) if err == nil && !success { return l.makeResp(resp, errLockConflict) } return l.makeResp(resp, err) } // UnlockHandler - releases the acquired lock.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/apis/coordination/types.go
// +optional HolderIdentity *string // leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last // observed renewTime. // +optional LeaseDurationSeconds *int32 // acquireTime is a time when the current lease was acquired. // +optional AcquireTime *metav1.MicroTime // renewTime is a time when the current holder of a lease has last // updated the lease.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 16 16:45:58 UTC 2022 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/api/coordination/v1beta1/types_swagger_doc_generated.go
"leaseDurationSeconds": "leaseDurationSeconds is a duration that candidates for a lease need to wait to force acquire it. This is measure against time of last observed renewTime.", "acquireTime": "acquireTime is a time when the current lease was acquired.", "renewTime": "renewTime is a time when the current holder of a lease has last updated the lease.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 22 00:51:25 UTC 2023 - 2.7K bytes - Viewed (0)