- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 277 for mkchan (0.05 sec)
-
internal/grid/connection_test.go
- }()
- cleanReqs := make(chan struct{})
- gotCall := make(chan struct{})
- defer close(cleanReqs)
- // 1: Block forever
- h1 := func(payload []byte) ([]byte, *RemoteErr) {
- gotCall <- struct{}{}
- <-cleanReqs
- return nil, nil
- }
- // 2: Also block, but with streaming.
- h2 := StreamHandler{
- Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 08 21:44:00 UTC 2024 - 5.9K bytes - Viewed (0) -
internal/pubsub/pubsub.go
- select {
- case sub.ch <- item:
- default:
- }
- }
- }
- }
- // Subscribe - Adds a subscriber to pubsub system
- func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error {
- totalSubs := atomic.AddInt32(&ps.numSubscribers, 1)
- if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers {
- atomic.AddInt32(&ps.numSubscribers, -1)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/math/StatsBenchmark.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.7K bytes - Viewed (0) -
internal/grid/handlers.go
- func (h *StreamTypeHandler[Payload, Req, Resp]) RegisterNoPayload(m *Manager, handle func(ctx context.Context, in <-chan Req, out chan<- Resp) *RemoteErr, subroute ...string) error {
- h.WithPayload = false
- return h.register(m, func(ctx context.Context, p Payload, in <-chan Req, out chan<- Resp) *RemoteErr {
- return handle(ctx, in, out)
- }, subroute...)
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 27.7K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
- )
- // Reader - JSON record reader for S3Select.
- type Reader struct {
- args *json.ReaderArgs
- input chan simdjson.Stream
- decoded chan simdjson.Object
- // err will only be returned after decoded has been closed.
- err *error
- readCloser io.ReadCloser
- onReaderExit func()
- exitReader chan struct{}
- readerWg sync.WaitGroup
- }
- // Read - reads single record.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 30 17:02:22 UTC 2023 - 4.9K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
- if m.GetRLock(ctx, "", "", time.Second) {
- clocked <- true
- <-cunlock
- m.RUnlock()
- cdone <- true
- }
- }
- // Borrowed from rwmutex_test.go
- func doTestParallelReaders(numReaders, gomaxprocs int) {
- runtime.GOMAXPROCS(gomaxprocs)
- m := NewLRWMutex()
- clocked := make(chan bool)
- cunlock := make(chan bool)
- cdone := make(chan bool)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 7.9K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
- func doTestParallelReaders(numReaders, gomaxprocs int) {
- runtime.GOMAXPROCS(gomaxprocs)
- m := NewDRWMutex(ds, "test-parallel")
- clocked := make(chan bool)
- cunlock := make(chan bool)
- cdone := make(chan bool)
- for i := 0; i < numReaders; i++ {
- go parallelReader(context.Background(), m, clocked, cunlock, cdone)
- }
- // Wait for all parallel RLock()s to succeed.
- for i := 0; i < numReaders; i++ {
- <-clocked
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
docs/de/docs/help-fastapi.md
- ### Der Stil ist nicht so wichtig
- * Machen Sie sich nicht zu viele Gedanken über Dinge wie den Stil von Commit-Nachrichten, ich werde den Commit manuell zusammenführen und anpassen.
- * Machen Sie sich auch keine Sorgen über Stilregeln, es gibt bereits automatisierte Tools, die das überprüfen.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 16K bytes - Viewed (0) -
internal/grid/grid_test.go
- remoteHost := remote.HostName()
- // 1: Echo
- serverSent := make(chan struct{})
- serverCanceled := make(chan struct{})
- register := func(manager *Manager) {
- errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{
- Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, resp chan<- []byte) *RemoteErr {
- // Send many responses.
- // Test that this doesn't block.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 36.4K bytes - Viewed (0) -
internal/s3select/jstream/scanner.go
- nbuf [chunk]byte // next internal buffer
- fillReq chan struct{}
- fillReady chan int64
- readerErr error // underlying reader error, if any
- }
- func newScanner(r io.Reader) *scanner {
- sr := &scanner{
- end: maxInt,
- fillReq: make(chan struct{}),
- fillReady: make(chan int64),
- }
- go func() {
- var rpos int64 // total bytes read into buffer
- defer func() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 2.5K bytes - Viewed (0)