Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 708 for held (0.04 sec)

  1. src/runtime/lockrank_on.go

    		println("<none>")
    		return
    	}
    
    	for j, held := range gp.m.locksHeld[:gp.m.locksHeldLen] {
    		println(j, ":", held.rank.String(), held.rank, unsafe.Pointer(gp.m.locksHeld[j].lockAddr))
    	}
    }
    
    // acquireLockRankAndM acquires a rank which is not associated with a mutex
    // lock. To maintain the invariant that an M with m.locks==0 does not hold any
    // lock-like resources, it also acquires the M.
    //
    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. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy

        boolean lockIsHeld(final ResourceLock resourceLock) {
            MutableBoolean held = new MutableBoolean()
            coordinationService.withStateLock(new InternalTransformer<ResourceLockState.Disposition, ResourceLockState>() {
                @Override
                ResourceLockState.Disposition transform(ResourceLockState resourceLockState) {
                    held.set(resourceLock.locked && resourceLock.isLockedByCurrentThread())
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 16:29:26 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  3. cmd/local-locker.go

    	defer l.mutex.Unlock()
    	var lri []lockRequesterInfo
    
    	resource := args.Resources[0]
    	if lri, reply = l.lockMap[resource]; !reply {
    		// No lock is held on the given name
    		return true, nil
    	}
    	if isWriteLock(lri) {
    		// A write-lock is held, cannot release a read lock
    		return false, fmt.Errorf("RUnlock attempted on a write locked entity: %s", resource)
    	}
    	l.removeEntry(resource, args, &lri)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. src/runtime/mpagealloc.go

    //
    // Returns a 0 base address on failure, in which case other returned values
    // should be ignored.
    //
    // p.mheapLock must be held.
    //
    // Must run on the system stack because p.mheapLock must be held.
    //
    //go:systemstack
    func (p *pageAlloc) alloc(npages uintptr) (addr uintptr, scav uintptr) {
    	assertLockHeld(p.mheapLock)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    	// A lock for writing is needed
    	// for writing to any of the following:
    	// - the flowSchemas field
    	// - the slice held in the flowSchemas field
    	// - the priorityLevelStates field
    	// - the map held in the priorityLevelStates field
    	// - any field of a priorityLevelState held in that map
    	lock sync.RWMutex
    
    	// flowSchemas holds the flow schema objects, sorted by increasing
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

      override fun clone(): Call = RealCall(client, originalRequest, forWebSocket)
    
      override fun request(): Request = originalRequest
    
      /**
       * Immediately closes the socket connection if it's currently held. Use this to interrupt an
       * in-flight request from any thread. It's the caller's responsibility to close the request body
       * and response body streams; otherwise resources may be leaked.
       *
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  7. src/sync/map.go

    	// concurrent access (with or without mu held).
    	//
    	// The read field itself is always safe to load, but must only be stored with
    	// mu held.
    	//
    	// Entries stored in read may be updated concurrently without mu, but updating
    	// a previously-expunged entry requires that the entry be copied to the dirty
    	// map and unexpunged with mu held.
    	read atomic.Pointer[readOnly]
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/moduleconverter/dependencies/DefaultLocalConfigurationMetadataBuilder.java

                for (PublishArtifact ownArtifact : ownArtifacts) {
                    // The following line may realize tasks, so project lock must be held.
                    result.add(new PublishArtifactLocalArtifactMetadata(componentId, ownArtifact));
                }
    
                // TODO: Deprecate the behavior of inheriting artifacts from parent configurations.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 22 16:00:57 UTC 2024
    - 18K bytes
    - Viewed (0)
  9. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java

            setProjectExecutionState(current, next);
        }
    
        @Override
        public void finishProjectExecution() {
            // TODO - check no locks are currently held
            Registries current = registries.get();
            Registries next = current.finishProjectExecution();
            setProjectExecutionState(current, next);
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 09 04:43:28 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  10. src/cmd/trace/gstate.go

    		stk = ctx.Stack(viewerFrames(gs.lastStopStack))
    	}
    	// Check invariants.
    	if gs.startRunningTime == 0 {
    		panic("silently broken trace or generator invariant (startRunningTime != 0) not held")
    	}
    	if gs.executing == R(noResource) {
    		panic("non-executing goroutine stopped")
    	}
    	ctx.Slice(traceviewer.SliceEvent{
    		Name:     gs.name(),
    		Ts:       ctx.elapsed(gs.startRunningTime),
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 11.9K bytes
    - Viewed (0)
Back to top