Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 48 of 48 for Unlock1 (0.12 sec)

  1. src/cmd/vendor/golang.org/x/sys/unix/syscall_zos_s390x.go

    	p := &b[cap(b)-1]
    	m.Lock()
    	defer m.Unlock()
    	m.active[p] = b
    	return b, nil
    }
    
    func (m *mmapper) Munmap(data []byte) (err error) {
    	if len(data) == 0 || len(data) != cap(data) {
    		return EINVAL
    	}
    
    	// Find the base of the mapping.
    	p := &data[cap(data)-1]
    	m.Lock()
    	defer m.Unlock()
    	b := m.active[p]
    	if b == nil || &b[0] != &data[0] {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 16:12:58 UTC 2024
    - 84.4K bytes
    - Viewed (0)
  2. platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_8.adoc

    This change is part of a larger ongoing effort to make the intended behavior of configurations more consistent and predictable, and to unlock further speed and memory improvements.
    
    Currently, the following methods should only be called with these listed allowed usages:
    
    - `resolve()` - RESOLVABLE configurations only
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 17:01:07 UTC 2024
    - 90.7K bytes
    - Viewed (0)
  3. src/cmd/go/internal/modload/buildlist.go

    			summary, err := goModSummary(m)
    
    			mu.Lock()
    			if err == nil {
    				mg.g.Require(m, summary.require)
    			} else {
    				hasError = true
    			}
    			mu.Unlock()
    
    			return summary, err
    		})
    	}
    
    	var enqueue func(m module.Version, pruning modPruning)
    	enqueue = func(m module.Version, pruning modPruning) {
    		if m.Version == "none" {
    			return
    		}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 16:04:44 UTC 2024
    - 53.8K bytes
    - Viewed (0)
  4. pkg/controller/replicaset/replica_set_test.go

    	}
    }
    
    func TestSlowStartBatch(t *testing.T) {
    	fakeErr := fmt.Errorf("fake error")
    	callCnt := 0
    	callLimit := 0
    	var lock sync.Mutex
    	fn := func() error {
    		lock.Lock()
    		defer lock.Unlock()
    		callCnt++
    		if callCnt > callLimit {
    			return fakeErr
    		}
    		return nil
    	}
    
    	tests := []struct {
    		name              string
    		count             int
    		callLimit         int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
  5. src/runtime/traceback.go

    	if iscgo && gp.m != nil && gp.m.ncgo > 0 && gp.syscallsp != 0 && gp.m.cgoCallers != nil && gp.m.cgoCallers[0] != 0 {
    		// Lock cgoCallers so that a signal handler won't
    		// change it, copy the array, reset it, unlock it.
    		// We are locked to the thread and are not running
    		// concurrently with a signal handler.
    		// We just have to stop a signal handler from interrupting
    		// in the middle of our copy.
    		gp.m.cgoCallersUse.Store(1)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  6. src/cmd/go/internal/modget/get.go

    				// the final LoadPackages call.
    				return true
    			}
    		}
    
    		mu.Lock()
    		upgrades = append(upgrades, pathSet{path: path, pkgMods: pkgMods, err: err})
    		mu.Unlock()
    		return false
    	}
    
    	r.loadPackages(ctx, patterns, findPackage)
    
    	// Since we built up the candidate lists concurrently, they may be in a
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:26:32 UTC 2024
    - 66.5K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    			return statusError(logger, fmt.Errorf("internal error, unexpected allocation mode %v", claim.Spec.AllocationMode))
    		}
    	}
    
    	if len(unavailableClaims) > 0 {
    		state.mutex.Lock()
    		defer state.mutex.Unlock()
    		if state.unavailableClaims == nil {
    			state.unavailableClaims = sets.New[int]()
    		}
    
    		for _, index := range unavailableClaims {
    			claim := state.claims[index]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  8. src/cmd/go/internal/test/test.go

    // still be intelligible.
    var stdoutMu sync.Mutex
    
    type lockedStdout struct{}
    
    func (lockedStdout) Write(b []byte) (int, error) {
    	stdoutMu.Lock()
    	defer stdoutMu.Unlock()
    	return os.Stdout.Write(b)
    }
    
    func (r *runTestActor) Act(b *work.Builder, ctx context.Context, a *work.Action) error {
    	sh := b.Shell(a)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 14:34:32 UTC 2024
    - 71.9K bytes
    - Viewed (0)
Back to top