- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,230 for unlock2 (0.12 sec)
-
src/main/java/jcifs/internal/smb1/com/SmbComLockingAndX.java
this.timeout = SMBUtil.readInt4(buffer, bufferIndex); bufferIndex += 4; int nunlocks = SMBUtil.readInt2(buffer, bufferIndex); this.unlocks = new LockingAndXRange[nunlocks]; bufferIndex += 2; int nlocks = SMBUtil.readInt2(buffer, bufferIndex); this.locks = new LockingAndXRange[nlocks]; bufferIndex += 2; return start - bufferIndex; } /**
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 4.9K bytes - Viewed (0) -
src/net/internal/socktest/sys_unix.go
sw.fmu.RLock() f := sw.fltab[FilterSocket] sw.fmu.RUnlock() af, err := f.apply(so) if err != nil { return -1, err } s, so.Err = syscall.Socket(family, sotype, proto) if err = af.apply(so); err != nil { if so.Err == nil { syscall.Close(s) } return -1, err } sw.smu.Lock() defer sw.smu.Unlock() if so.Err != nil { sw.stats.getLocked(so.Cookie).OpenFailed++
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4K bytes - Viewed (0) -
pkg/kubelet/status/state/state_checkpoint.go
sc.mux.Lock() defer sc.mux.Unlock() sc.cache.SetContainerResourceAllocation(podUID, containerName, alloc) return sc.storeState() } // SetPodResourceAllocation sets pod resource allocation func (sc *stateCheckpoint) SetPodResourceAllocation(a PodResourceAllocation) error { sc.mux.Lock() defer sc.mux.Unlock() sc.cache.SetPodResourceAllocation(a) return sc.storeState() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 00:16:44 UTC 2023 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/ready.go
// waiting despite the state moved back to Pending. r.lock.RUnlock() case Ready: generation := r.generation r.lock.RUnlock() return generation, nil case Stopped: r.lock.RUnlock() return 0, fmt.Errorf("apiserver cacher is stopped") default: r.lock.RUnlock() return 0, fmt.Errorf("unexpected apiserver cache state: %v", r.state) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 16 13:32:11 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/kubelet/status/state/state_mem.go
defer s.Unlock() if _, ok := s.podAllocation[podUID]; !ok { s.podAllocation[podUID] = make(map[string]v1.ResourceList) } s.podAllocation[podUID][containerName] = alloc klog.V(3).InfoS("Updated container resource allocation", "podUID", podUID, "containerName", containerName, "alloc", alloc) return nil } func (s *stateMemory) SetPodResourceAllocation(a PodResourceAllocation) error { s.Lock() defer s.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 4K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
m.tlock.Unlock() m.mlock.Lock() delete(m.bucketsMeasurement, BucketOptions{Name: bucket, ReplicationARN: arn}) m.mlock.Unlock() } // throttle returns currently configured throttle for this bucket func (m *Monitor) throttle(opts BucketOptions) *bucketThrottle { m.tlock.RLock() defer m.tlock.RUnlock() return m.bucketsThrottle[opts] }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph.go
func (n *node) markBeingDeleted() { n.beingDeletedLock.Lock() defer n.beingDeletedLock.Unlock() n.beingDeleted = true } func (n *node) isBeingDeleted() bool { n.beingDeletedLock.RLock() defer n.beingDeletedLock.RUnlock() return n.beingDeleted } func (n *node) markObserved() { n.virtualLock.Lock() defer n.virtualLock.Unlock() n.virtual = false } func (n *node) isObserved() bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 13:37:56 UTC 2023 - 7.1K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_mem.go
} func (s *stateMemory) SetDefaultCPUSet(cset cpuset.CPUSet) { s.Lock() defer s.Unlock() s.defaultCPUSet = cset klog.InfoS("Updated default CPUSet", "cpuSet", cset) } func (s *stateMemory) SetCPUAssignments(a ContainerCPUAssignments) { s.Lock() defer s.Unlock() s.assignments = a.Clone() klog.InfoS("Updated CPUSet assignments", "assignments", a) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
test/inline_sync.go
// is solved. package foo import ( "sync" ) var mutex *sync.Mutex func small5() { // ERROR "can inline small5" // the Unlock fast path should be inlined mutex.Unlock() // ERROR "inlining call to sync\.\(\*Mutex\)\.Unlock" } func small6() { // ERROR "can inline small6" // the Lock fast path should be inlined mutex.Lock() // ERROR "inlining call to sync\.\(\*Mutex\)\.Lock" }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 06 21:01:50 UTC 2023 - 1.6K bytes - Viewed (0) -
cmd/lock-rest-client.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Nov 24 17:07:14 UTC 2023 - 3.3K bytes - Viewed (0)