- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 2,831 for watt (0.07 sec)
-
internal/ringbuffer/README.md
If you want to block when reading or writing, you must enable it: ```go rb := ringbuffer.New(1024).SetBlocking(true) ``` Enabling blocking will cause the ring buffer to behave like a buffered [io.Pipe](https://pkg.go.dev/io#Pipe). Regular Reads will block until data is available, but not wait for a full buffer.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.1K bytes - Viewed (0) -
src/sync/oncefunc_test.go
b.ReportAllocs() for i := 0; i < b.N; i++ { if want, got := 42, doOnceValue(); want != got { b.Fatalf("want %d, got %d", want, got) } } }) b.Run("v=Global", func(b *testing.B) { b.ReportAllocs() for i := 0; i < b.N; i++ { if want, got := 42, onceValue(); want != got { b.Fatalf("want %d, got %d", want, got) } } }) b.Run("v=Local", func(b *testing.B) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 17:31:33 UTC 2023 - 6.9K bytes - Viewed (0) -
src/os/signal/signal.go
if h == nil { handlers.Unlock() return } delete(handlers.m, c) for n := 0; n < numSig; n++ { if h.want(n) { handlers.ref[n]-- if handlers.ref[n] == 0 { disableSignal(n) } } } // Signals will no longer be delivered to the channel. // We want to avoid a race for a signal such as SIGINT: // it should be either delivered to the channel,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/authorization.go
See the License for the specific language governing permissions and limitations under the License. */ package options import ( "fmt" "time" "github.com/spf13/pflag" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/authorization/authorizer" "k8s.io/apiserver/pkg/authorization/authorizerfactory" "k8s.io/apiserver/pkg/authorization/path" "k8s.io/apiserver/pkg/authorization/union" "k8s.io/apiserver/pkg/server"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 9.3K bytes - Viewed (0) -
cmd/data-scanner_test.go
obj ObjectInfo want lifecycle.Action }{ { // with object locking ilm: *deleteAllLc, retention: lock.Retention{LockEnabled: true}, obj: obj, want: lifecycle.NoneAction, }, { // without object locking ilm: *deleteAllLc, retention: lock.Retention{}, obj: obj, want: lifecycle.DeleteAllVersionsAction, },
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 03 11:18:58 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/kube/informerfactory/factory.go
if !cache.WaitForCacheSync(stopCh, informer.HasSynced) { return false } } return true } func (f *informerFactory) Shutdown() { // Will return immediately if there is nothing to wait for. defer f.wg.Wait() f.lock.Lock() defer f.lock.Unlock() f.shuttingDown = true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.9K bytes - Viewed (0) -
src/html/template/clone_test.go
} if _, err := t0.Lookup("lhs").Clone(); err == nil { t.Error(`t0.Lookup("lhs").Clone(): got nil err want non-nil`) } // Execute t3. b.Reset() if err := t3.ExecuteTemplate(b, "a", "<i>*/"); err != nil { t.Fatal(err) } if got, want := b.String(), ` <style> ZgotmplZ </style> `; got != want { t.Errorf("t3: got %q want %q", got, want) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 06 15:48:16 UTC 2022 - 8K bytes - Viewed (0) -
src/cmd/go/go_unix_test.go
tg.creatingTemp(exe) tg.run("build", "-o", exe, tg.path("x.go")) fi, err := os.Stat(exe) if err != nil { t.Fatal(err) } got, want := fi.Mode(), cfi.Mode() if got == want { t.Logf("wrote x with mode %v", got) } else { t.Fatalf("wrote x with mode %v, wanted no 0077 bits (%v)", got, want) } } // TestTestInterrupt verifies the fix for issue #60203. // // If the whole process group for a 'go test' invocation receives
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 19 16:17:55 UTC 2023 - 3.5K bytes - Viewed (0) -
src/sync/map_test.go
t.Fatalf("Nested Range loads unexpected value, got %+v want %+v", v, value) } // We didn't keep 42 and a value into the map before, if somehow we loaded // a value from such a key, meaning there must be an internal bug regarding // nested range in the Map. if _, loaded := m.LoadOrStore(42, "dummy"); loaded { t.Fatalf("Nested Range loads unexpected value, want store a new value") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 01 15:34:22 UTC 2024 - 8.1K bytes - Viewed (0) -
src/net/file_test.go
}() c, err := ln2.Accept() if err != nil { if perr := parseAcceptError(err); perr != nil { t.Error(perr) } t.Fatal(err) } c.Close() wg.Wait() if !reflect.DeepEqual(ln2.Addr(), addr) { t.Fatalf("got %#v; want %#v", ln2.Addr(), addr) } } } var filePacketConnTests = []struct { network string }{ {"udp"}, {"unixgram"}, }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 6.4K bytes - Viewed (0)