Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for lock_held_ (0.2 sec)

  1. src/runtime/lockrank_on.go

    	systemstack(func() {
    		i := gp.m.locksHeldLen
    		if i >= len(gp.m.locksHeld) {
    			throw("too many locks held concurrently for rank checking")
    		}
    		gp.m.locksHeld[i].rank = rank
    		gp.m.locksHeld[i].lockAddr = uintptr(unsafe.Pointer(l))
    		gp.m.locksHeldLen++
    
    		// i is the index of the lock being acquired
    		if i > 0 {
    			checkRanks(gp, gp.m.locksHeld[i-1].rank, rank)
    		}
    		lock2(l)
    	})
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 14:29:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. cmd/admin-handlers_test.go

    			UID:    mustGetUUID(),
    			Owner:  owners[i%len(owners)],
    			Quorum: 2,
    		}
    		lris = append(lris, lri)
    		locksHeld[resource] = append(locksHeld[resource], lri)
    		// concurrent read lock, same resource different uid
    		lri.UID = mustGetUUID()
    		lris = append(lris, lri)
    		locksHeld[resource] = append(locksHeld[resource], lri)
    	}
    
    	var peerLocks []*PeerLocks
    	for _, owner := range owners {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  3. tensorflow/c/kernels_experimental.cc

                         TF_Tensor* dest),
        tensorflow::Var* var, bool lock_held = false) {
      auto* context = reinterpret_cast<::tensorflow::OpKernelContext*>(ctx);
      if (var->copy_on_read_mode.load()) {
        return absl::OkStatus();
      }
    
      std::optional<mutex_lock> ml;
      if (!lock_held) {
        ml.emplace(*var->mu());
      }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Apr 23 06:12:29 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  4. tensorflow/compiler/jit/variable_info_util.cc

        absl::Span<VariableInfo const> variable_args,
        absl::flat_hash_map<int, const VariableInfo*>& variable_info_lookup) {
      for (const VariableInfo& info : variable_args) {
        if (!(!info.var() || info.lock_held() || info.shared_lock_held())) {
          return errors::Internal(
              "Need to hold the lock on resource variables "
              "before calling BuildXlaCompilerArguments");
        }
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 22 08:47:20 UTC 2024
    - 7K bytes
    - Viewed (0)
  5. tensorflow/compiler/jit/get_compiler_ir.cc

      TF_RETURN_IF_ERROR(
          CreateVariableInfoLookup(variable_args, variable_info_lookup));
    
      for (const VariableInfo& info : variable_args) {
        TF_RET_CHECK(!info.var() || info.lock_held() || info.shared_lock_held())
            << "Need to hold the lock on resource variables "
               "before calling BuildXlaCompilerArguments";
        variable_info_lookup.emplace(info.index(), &info);
      }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 22 06:59:07 UTC 2024
    - 19K bytes
    - Viewed (0)
  6. src/runtime/proc.go

    	mp := acquirem()
    	if !lockheld {
    		lock(&sched.lock)
    	}
    	if pp == nil {
    		if spinning {
    			// TODO(prattmic): All remaining calls to this function
    			// with _p_ == nil could be cleaned up to find a P
    			// before calling startm.
    			throw("startm: P required for spinning=true")
    		}
    		pp, _ = pidleget(0)
    		if pp == nil {
    			if !lockheld {
    				unlock(&sched.lock)
    			}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  7. src/runtime/runtime2.go

    	pcvalueCache pcvalueCache
    
    	dlogPerM
    
    	mOS
    
    	chacha8   chacha8rand.State
    	cheaprand uint64
    
    	// Up to 10 locks held by this m, maintained by the lock ranking code.
    	locksHeldLen int
    	locksHeld    [10]heldLockInfo
    }
    
    type p struct {
    	id          int32
    	status      uint32 // one of pidle/prunning/...
    	link        puintptr
    	schedtick   uint32     // incremented on every scheduler call
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
Back to top