Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 91 for rlocked (4.64 sec)

  1. 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)
  2. 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)
  3. src/runtime/preempt.go

    // Goroutine preemption
    //
    // A goroutine can be preempted at any safe-point. Currently, there
    // are a few categories of safe-points:
    //
    // 1. A blocked safe-point occurs for the duration that a goroutine is
    //    descheduled, blocked on synchronization, or in a system call.
    //
    // 2. Synchronous safe-points occur when a running goroutine checks
    //    for a preemption request.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  4. 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)
  5. src/cmd/trace/gstate.go

    // and orthogonal to syscallEnd; both must be called if the syscall blocked. This sets up an instant
    // to emit a flow event from, indicating explicitly that this goroutine was unblocked by the system.
    func (gs *gState[R]) blockedSyscallEnd(ts trace.Time, stack trace.Stack, ctx *traceContext) {
    	name := "exit blocked syscall"
    	gs.setStartCause(ts, name, trace.SyscallP, stack)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. internal/dsync/drwmutex.go

    			g := Granted{index: index}
    			if c == nil {
    				log("dsync: nil locker\n")
    				ch <- g
    				return
    			}
    
    			var locked bool
    			var err error
    			if isReadLock {
    				if locked, err = c.RLock(netLockCtx, args); err != nil {
    					log("dsync: Unable to call RLock failed with %s for %#v at %s\n", err, args, c)
    				}
    			} else {
    				if locked, err = c.Lock(netLockCtx, args); err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  7. 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)
  8. src/runtime/chan.go

    package runtime
    
    // This file contains the implementation of Go channels.
    
    // Invariants:
    //  At least one of c.sendq and c.recvq is empty,
    //  except for the case of an unbuffered channel with a single goroutine
    //  blocked on it for both sending and receiving using a select statement,
    //  in which case the length of c.sendq and c.recvq is limited only by the
    //  size of the select statement.
    //
    // For buffered channels, also:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:50 UTC 2024
    - 25.9K 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