Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 100 for ErrRange (0.16 sec)

  1. src/sync/rwmutex.go

    // not locked for writing on entry to Unlock.
    //
    // As with Mutexes, a locked [RWMutex] is not associated with a particular
    // goroutine. One goroutine may [RWMutex.RLock] ([RWMutex.Lock]) a RWMutex and then
    // arrange for another goroutine to [RWMutex.RUnlock] ([RWMutex.Unlock]) it.
    func (rw *RWMutex) Unlock() {
    	if race.Enabled {
    		_ = rw.w.state
    		race.Release(unsafe.Pointer(&rw.readerSem))
    		race.Disable()
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  2. pkg/volume/csi/csi_plugin_test.go

    			endpoint:   "/var/log/kubelet/plugins_registry/myplugin/csi.sock",
    			versions:   []string{"var", "boo", "foo"},
    			shouldFail: true,
    		},
    	}
    
    	for _, tc := range testCases {
    		// Arrange & Act
    		err := PluginHandler.ValidatePlugin(tc.pluginName, tc.endpoint, tc.versions)
    
    		// Assert
    		if tc.shouldFail && err == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  3. src/net/rpc/client.go

    	call := new(Call)
    	call.ServiceMethod = serviceMethod
    	call.Args = args
    	call.Reply = reply
    	if done == nil {
    		done = make(chan *Call, 10) // buffered.
    	} else {
    		// If caller passes done != nil, it must arrange that
    		// done has enough buffer for the number of simultaneous
    		// RPCs that will be using that channel. If the channel
    		// is totally unbuffered, it's best not to run at all.
    		if cap(done) == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 9K bytes
    - Viewed (0)
  4. src/sync/mutex.go

    // Unlock unlocks m.
    // It is a run-time error if m is not locked on entry to Unlock.
    //
    // A locked [Mutex] is not associated with a particular goroutine.
    // It is allowed for one goroutine to lock a Mutex and then
    // arrange for another goroutine to unlock it.
    func (m *Mutex) Unlock() {
    	if race.Enabled {
    		_ = m.state
    		race.Release(unsafe.Pointer(m))
    	}
    
    	// Fast path: drop lock bit.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/util/version/version_test.go

    		{
    			versions:                        []string{"var", "boo", "foo"},
    			expectedHighestSupportedVersion: "",
    			shouldFail:                      true,
    		},
    	}
    
    	for _, tc := range testCases {
    		// Arrange & Act
    		actual, err := HighestSupportedVersion(tc.versions)
    
    		// Assert
    		if tc.shouldFail && err == nil {
    			t.Fatalf("expecting highestSupportedVersion to fail, but got nil error for testcase: %#v", tc)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 18 19:25:29 UTC 2023
    - 13.4K bytes
    - Viewed (0)
  6. src/internal/godebug/godebug.go

    // prefix the name with a #, as in godebug.New("#gofsystrace").
    // The # is a signal to New but not part of the key used in $GODEBUG.
    //
    // Note that almost all settings should arrange to call [IncNonDefault] precisely
    // when program behavior is changing from the default due to the setting
    // (not just when the setting is different, but when program behavior changes).
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Mar 09 14:19:39 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  7. pkg/volume/csi/nodeinfomanager/nodeinfomanager_test.go

    				},
    				nil /* labels */, nil /*capacity*/),
    		},
    	}
    
    	for _, tc := range testcases {
    		t.Logf("test case: %q", tc.name)
    
    		// Arrange
    		nodeName := tc.existingNode.Name
    		client := fake.NewSimpleClientset(tc.existingNode)
    
    		tmpDir, err := utiltesting.MkTmpdir("nodeinfomanager-test")
    		if err != nil {
    			t.Fatalf("can't create temp dir: %v", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 17 02:02:59 UTC 2022
    - 34.3K bytes
    - Viewed (0)
  8. pkg/controlplane/apiserver/options/options.go

    	s.Metrics.AddFlags(fss.FlagSet("metrics"))
    	logsapi.AddFlags(s.Logs, fss.FlagSet("logs"))
    	s.Traces.AddFlags(fss.FlagSet("traces"))
    
    	// Note: the weird ""+ in below lines seems to be the only way to get gofmt to
    	// arrange these text blocks sensibly. Grrr.
    	fs := fss.FlagSet("misc")
    	fs.DurationVar(&s.EventTTL, "event-ttl", s.EventTTL,
    		"Amount of time to retain events.")
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 12:19:56 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  9. src/runtime/map_benchmark_test.go

    			for i := 0; i < n; i++ {
    				m[i] = true
    			}
    			b.ResetTimer()
    			for i := 0; i < b.N; i++ {
    				_ = m[n-1]
    			}
    		})
    	}
    }
    
    func BenchmarkMapCycle(b *testing.B) {
    	// Arrange map entries to be a permutation, so that
    	// we hit all entries, and one lookup is data dependent
    	// on the previous lookup.
    	const N = 3127
    	p := rand.New(rand.NewSource(1)).Perm(N)
    	m := map[int]int{}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Aug 09 16:41:16 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  10. src/sync/atomic/doc.go

    //
    // On non-Linux ARM, the 64-bit functions use instructions unavailable before the ARMv6k core.
    //
    // On ARM, 386, and 32-bit MIPS, it is the caller's responsibility to arrange
    // for 64-bit alignment of 64-bit words accessed atomically via the primitive
    // atomic functions (types [Int64] and [Uint64] are automatically aligned).
    // The first word in an allocated struct, array, or slice; in a global
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 11.7K bytes
    - Viewed (0)
Back to top