- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 34 for Acquirem (0.18 sec)
-
src/cmd/internal/obj/riscv/obj.go
inss = instructionsForLoad(p, ins.as, p.From.Reg) case ASW, ASH, ASB, ASD, AFSW, AFSD: inss = instructionsForStore(p, ins.as, p.To.Reg) case ALRW, ALRD: // Set aq to use acquire access ordering ins.funct7 = 2 ins.rs1, ins.rs2 = uint32(p.From.Reg), REG_ZERO case AADDI, AANDI, AORI, AXORI: inss = instructionsForOpImmediate(p, ins.as, p.Reg) case ASCW, ASCD:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 07 03:32:27 UTC 2024 - 77K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
// remains unchanged after "Reserve". func (f *frameworkImpl) SnapshotSharedLister() framework.SharedLister { return f.snapshotSharedLister } // IterateOverWaitingPods acquires a read lock and iterates over the WaitingPods map. func (f *frameworkImpl) IterateOverWaitingPods(callback func(framework.WaitingPod)) { f.waitingPods.iterate(callback) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
src/syscall/syscall_windows.go
err := readFile(fd, p, done, overlapped) if race.Enabled { if *done > 0 { race.WriteRange(unsafe.Pointer(&p[0]), int(*done)) } race.Acquire(unsafe.Pointer(&ioSync)) } if msan.Enabled && *done > 0 { msan.Write(unsafe.Pointer(&p[0]), uintptr(*done)) } if asan.Enabled && *done > 0 { asan.Write(unsafe.Pointer(&p[0]), uintptr(*done)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 11:49:46 UTC 2024 - 52.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/lower_static_tensor_list.cc
} Value element_shape = adaptor.getOperands()[0]; Type shape_dtype = getElementTypeOrSelf(element_shape.getType()); // If the `element_shape` is a scalar, we try to acquire its shape by // looking at the first `TensorListSetItemOp` writing to this tensor list. // Here we assume that the element_shape won't be changed before calling // the first `TensorListSetItemOp`.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 20:00:43 UTC 2024 - 70.7K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
// Because of the iptables logic, it is assumed that there is only a single Proxier active on a machine. // An error will be returned if iptables fails to update or acquire the initial lock. // Once a proxier is created, it will keep iptables up to date in the background and // will not terminate if a particular iptables call fails. func NewProxier(ctx context.Context, ipFamily v1.IPFamily,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
src/internal/trace/order.go
// (lack of a P altogether is also acceptable for advancing). // The transfer out of ProcSyscall can happen either voluntarily via // ProcStop or involuntarily via ProcSteal. We may also acquire a new P // before we get here (after the transfer out) but that's OK: that new // P won't be in the ProcSyscall state anymore. // // Basically: while we have a preemptible P, don't advance, because we
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/MapMakerInternalMap.java
runCleanup(); } } /** * Performs routine cleanup prior to executing a write. This should be called every time a write * thread acquires the segment lock, immediately after acquiring the lock. */ @GuardedBy("this") void preWriteCleanup() { runLockedCleanup(); } void runCleanup() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0) -
src/cmd/compile/internal/ppc64/ssa.go
ld = ppc64.AMOVBZ case ssa.OpPPC64LoweredAtomicLoad32: ld = ppc64.AMOVWZ cmp = ppc64.ACMPW } arg0 := v.Args[0].Reg() out := v.Reg0() // SYNC when AuxInt == 1; otherwise, load-acquire if v.AuxInt == 1 { psync := s.Prog(ppc64.ASYNC) psync.To.Type = obj.TYPE_NONE } // Load p := s.Prog(ld) p.From.Type = obj.TYPE_MEM p.From.Reg = arg0 p.To.Type = obj.TYPE_REG
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 19:59:38 UTC 2024 - 55.4K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
// Because of the iptables and ipvs logic, it is assumed that there is only a single Proxier active on a machine. // An error will be returned if it fails to update or acquire the initial lock. // Once a proxier is created, it will keep iptables and ipvs rules up to date in the background and // will not terminate if a particular iptables or ipvs call fails. func NewProxier( ctx context.Context,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
runCleanup(); } } /** * Performs routine cleanup prior to executing a write. This should be called every time a write * thread acquires the segment lock, immediately after acquiring the lock. */ @GuardedBy("this") void preWriteCleanup() { runLockedCleanup(); } void runCleanup() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0)