Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 96 for lockedm (0.14 sec)

  1. src/runtime/tracestack.go

    			}
    		}
    	}
    
    	if gp != nil && mp == nil {
    		// We're getting the backtrace for a G that's not currently executing.
    		// It may still have an M, if it's locked to some M.
    		mp = gp.lockedm.ptr()
    	}
    	nstk := 1
    	if tracefpunwindoff() || (mp != nil && mp.hasCgoOnStack()) {
    		// Slow path: Unwind using default unwinder. Used when frame pointer
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 21 14:38:56 UTC 2024
    - 11K bytes
    - Viewed (0)
  2. src/runtime/export_test.go

    }
    
    func LockOSCounts() (external, internal uint32) {
    	gp := getg()
    	if gp.m.lockedExt+gp.m.lockedInt == 0 {
    		if gp.lockedm != 0 {
    			panic("lockedm on non-locked goroutine")
    		}
    	} else {
    		if gp.lockedm == 0 {
    			panic("nil lockedm on locked goroutine")
    		}
    	}
    	return gp.m.lockedExt, gp.m.lockedInt
    }
    
    //go:noinline
    func TracebackSystemstack(stk []uintptr, i int) int {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:50:53 UTC 2024
    - 46.1K bytes
    - Viewed (0)
  3. src/runtime/runtime2.go

    	preemptoff    string // if != "", keep curg running on this m
    	locks         int32
    	dying         int32
    	profilehz     int32
    	spinning      bool // m is out of work and is actively looking for work
    	blocked       bool // m is blocked on a note
    	newSigstack   bool // minit on C thread called sigaltstack
    	printlock     int8
    	incgo         bool          // m is executing a cgo call
    	isextra       bool          // m is an extra m
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  4. internal/dsync/drwmutex.go

    // releaseAll releases all locks that are marked as locked
    func releaseAll(ctx context.Context, ds *Dsync, tolerance int, owner string, locks *[]string, isReadLock bool, restClnts []NetLocker, names ...string) bool {
    	var wg sync.WaitGroup
    	for lockID := range restClnts {
    		wg.Add(1)
    		go func(lockID int) {
    			defer wg.Done()
    			if sendRelease(ctx, ds, restClnts[lockID], owner, (*locks)[lockID], isReadLock, names...) {
    				(*locks)[lockID] = ""
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  5. src/crypto/tls/quic.go

    	defer c.handshakeMutex.Lock()
    	// Send on blockedc to notify the QUICConn that the handshake is blocked.
    	// Exported methods of QUICConn wait for the handshake to become blocked
    	// before returning to the user.
    	select {
    	case c.quic.blockedc <- struct{}{}:
    	case <-c.quic.cancelc:
    		return c.sendAlertLocked(alertCloseNotify)
    	}
    	// The QUICConn reads from signalc to notify us that the handshake may
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 17:23:54 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  6. platforms/documentation/docs/src/docs/userguide/dep-man/02-declaring-dependency-versions/dependency_locking.adoc

    You can also disable locking on a specific configuration.
    This can be useful if a plugin configured locking on all configurations but you happen to add one that should not be locked.
    
    .Unlocking a specific configuration
    ====
    include::sample[dir="snippets/dependencyManagement/dependencyLocking-unlockingSingleConfiguration/kotlin",files="build.gradle.kts[tags=locking-one]"]
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jun 06 16:55:22 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  7. src/syscall/exec_linux.go

    	// Set up and fork. This returns immediately in the parent or
    	// if there's an error.
    	upid, pidfd, err, mapPipe, locked := forkAndExecInChild1(argv0, argv, envv, chroot, dir, attr, sys, pipe)
    	if locked {
    		runtime_AfterFork()
    	}
    	if err != 0 {
    		return 0, err
    	}
    
    	// parent; return PID
    	pid = int(upid)
    	if sys.PidFD != nil {
    		*sys.PidFD = int(pidfd)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 07:45:37 UTC 2024
    - 23K bytes
    - Viewed (0)
  8. cmd/erasure-sets.go

    		}
    	}
    }
    
    func (s *erasureSets) GetLockers(setIndex int) func() ([]dsync.NetLocker, string) {
    	return func() ([]dsync.NetLocker, string) {
    		lockers := make([]dsync.NetLocker, len(s.erasureLockers[setIndex]))
    		copy(lockers, s.erasureLockers[setIndex])
    		return lockers, s.erasureLockOwner
    	}
    }
    
    func (s *erasureSets) GetEndpointStrings(setIndex int) func() []string {
    	return func() []string {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  9. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/configurations/DefaultConfigurationFactory.java

                    role
            );
            instance.addMutationValidator(rootComponentMetadataBuilder.getValidator());
            return instance;
        }
    
        /**
         * Creates a new locked resolvable configuration instance.
         */
        DefaultResolvableConfiguration createResolvable(
            String name,
            ConfigurationsProvider configurationsProvider,
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 23 17:29:40 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  10. src/cmd/vendor/golang.org/x/telemetry/internal/counter/counter.go

    				sum := c.add(uint64(n))
    				debugPrintf("Add %q += %d: count=%d\n", c.name, n, sum)
    			}
    			c.releaseReader(state)
    			return
    
    		case state.locked():
    			if !c.state.update(&state, state.addExtra(uint64(n))) {
    				continue
    			}
    			debugPrintf("Add %q += %d: locked extra=%d\n", c.name, n, state.extra())
    			return
    
    		case !state.havePtr():
    			if !c.state.update(&state, state.addExtra(uint64(n)).setLocked()) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 10.3K bytes
    - Viewed (0)
Back to top