Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 34 for Acquirem (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top