- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 815 for fslock (0.14 sec)
-
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/ExclusiveAccessResourceLockTest.groovy
when: resourceLock.tryLock() then: thrown(IllegalStateException) when: resourceLock.unlock() then: thrown(IllegalStateException) } def "can lock and unlock a resource"() { when: coordinationService.withStateLock(tryLock(resourceLock)) then: resourceLock.doIsLocked()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 3.2K bytes - Viewed (0) -
cmd/erasure-multipart.go
if opts.CheckPrecondFn != nil { if !opts.NoLock { ns := er.NewNSLock(bucket, object) lkctx, err := ns.GetLock(ctx, globalOperationTimeout) if err != nil { return nil, err } ctx = lkctx.Context() defer ns.Unlock(lkctx) opts.NoLock = true } obj, err := er.getObjectInfo(ctx, bucket, object, opts)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
src/cmd/internal/obj/wasm/wasmobj.go
} } if numResumePoints > 0 { // Add Block instructions for resume points and BrTable to jump to selected resume point. for i := 0; i < numResumePoints+1; i++ { p = appendp(p, ABlock) } p = appendp(p, AGet, regAddr(REG_PC_B)) // read next basic block from PC_B p = appendp(p, ABrTable, obj.Addr{Val: tableIdxs}) p = appendp(p, AEnd) // end of Block } for p.Link != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 34.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/syscall_solaris.go
func (e *EventPort) Close() error { e.mu.Lock() defer e.mu.Unlock() err := Close(e.port) if err != nil { return err } e.fds = nil e.paths = nil e.cookies = nil return nil } // PathIsWatched checks to see if path is associated with this EventPort. func (e *EventPort) PathIsWatched(path string) bool { e.mu.Lock() defer e.mu.Unlock() _, found := e.paths[path] return found }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 29 21:28:33 UTC 2023 - 31.1K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/SharedResourceLeaseRegistryTest.groovy
when: coordinationService.withStateLock(lock(lockA)) coordinationService.withStateLock(lock(lockB)) then: lockIsHeld(lockA) lockIsHeld(lockB) when: coordinationService.withStateLock(unlock(lockA)) coordinationService.withStateLock(unlock(lockB)) then: !lockIsHeld(lockA) !lockIsHeld(lockB)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 5K bytes - Viewed (0) -
src/net/http/export_test.go
resetProxyConfig() } func (t *Transport) NumPendingRequestsForTesting() int { t.reqMu.Lock() defer t.reqMu.Unlock() return len(t.reqCanceler) } func (t *Transport) IdleConnKeysForTesting() (keys []string) { keys = make([]string, 0) t.idleMu.Lock() defer t.idleMu.Unlock() for key := range t.idleConn { keys = append(keys, key.String()) } slices.Sort(keys) return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/kubelet/runtime.go
s.Lock() defer s.Unlock() s.runtimeError = err } func (s *runtimeState) setRuntimeHandlers(rtHandlers []kubecontainer.RuntimeHandler) { s.Lock() defer s.Unlock() s.rtHandlers = rtHandlers } func (s *runtimeState) runtimeHandlers() []kubecontainer.RuntimeHandler { s.RLock() defer s.RUnlock() return s.rtHandlers } func (s *runtimeState) setStorageState(err error) { s.Lock() defer s.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 3.6K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
} l.mutex.Lock() defer l.mutex.Unlock() var locksHeld int64 if locksHeld, reply = l.lockMap[args.Resources[0]]; !reply { // No lock is held on the given name return false, fmt.Errorf("Unlock attempted on an unlocked entity: %s", args.Resources[0]) } if reply = locksHeld == WriteLock; !reply { // Unless it is a write lock
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jan 23 16:46:37 UTC 2023 - 8.3K bytes - Viewed (0) -
test/goto.go
func _() { { // GCCGO_ERROR "block starts here" L: } goto L // ERROR "goto L jumps into block starting at LINE-3|goto jumps into block" } // error shows first (outermost) offending block func _() { goto L // ERROR "goto L jumps into block starting at LINE+3|goto jumps into block" { { { // GCCGO_ERROR "block starts here" L: } } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 19 02:27:58 UTC 2017 - 8.4K bytes - Viewed (0) -
pkg/test/framework/scope.go
scopes.Framework.Debugf("Adding resource for tracking: %v", id) s.mu.Lock() defer s.mu.Unlock() s.resources = append(s.resources, r) if c, ok := r.(io.Closer); ok { s.closers = append(s.closers, c) } } func (s *scope) get(ref any) error { s.mu.Lock() defer s.mu.Unlock() refVal := reflect.ValueOf(ref) if refVal.Kind() != reflect.Ptr {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 21:55:23 UTC 2024 - 4.6K bytes - Viewed (0)