- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 100 for ErrRange (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)