- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 169 for chan (0.18 sec)
-
internal/grid/handlers.go
// An optional subroute can be given. Multiple entries are joined with '/'. 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)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
misc/cgo/gmp/fib.go
// license that can be found in the LICENSE file. //go:build ignore // Compute Fibonacci numbers with two goroutines // that pass integers back and forth. No actual // concurrency, just threads and synchronization // and foreign code on multiple pthreads. package main import ( big "." "runtime" ) func fibber(c chan *big.Int, out chan string, n int64) {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Apr 10 22:32:35 GMT 2023 - 919 bytes - Viewed (0) -
cmd/peer-rest-client.go
} func (client *peerRESTClient) GetResourceMetrics(ctx context.Context) (<-chan MetricV2, error) { resp, err := getResourceMetricsRPC.Call(ctx, client.gridConn(), grid.NewMSS()) if err != nil { return nil, err } ch := make(chan MetricV2) go func(ch chan<- MetricV2) { defer close(ch) for _, m := range resp.Value() { if m == nil { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
internal/s3select/csv/reader.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K 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.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/grid/muxclient.go
func (m *muxClient) handleTwowayResponses(responseCh chan<- Response, internalResp <-chan Response) { defer m.parent.deleteMux(false, m.MuxID) defer xioutil.SafeClose(responseCh) for resp := range internalResp { responseCh <- resp m.send(message{Op: OpUnblockSrvMux, MuxID: m.MuxID}) } } func (m *muxClient) handleTwowayRequests(internalResp chan<- Response, requests <-chan []byte) { var errState bool if debugPrint {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/namespace-lock_test.go
// not be required but makes reproduction much easier. nsLk.lockMapMutex.Lock() // lk3 blocks. lk3ch := make(chan bool) go func() { lk3ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0) }() // lk4, blocks. lk4ch := make(chan bool) go func() { lk4ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0) }() runtime.Gosched()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 3.1K bytes - Viewed (0) -
internal/grid/connection.go
if handler == nil { return nil, ErrUnknownHandler } var requests chan []byte var responses chan Response if handler.InCapacity > 0 { requests = make(chan []byte, handler.InCapacity) } if handler.OutCapacity > 0 { responses = make(chan Response, handler.OutCapacity) } else { responses = make(chan Response, 1) } cl, err := c.newMuxClient(ctx) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
type WaitGroup struct { count int32 done chan struct{} } func NewWaitGroup() *WaitGroup { return &WaitGroup{ done: make(chan struct{}), } } func NewWaitForNCalls(t *testing.T, n int32) (*WaitGroup, func()) { wg := &WaitGroup{ done: make(chan struct{}), } wg.Add(n) return wg, func() { select { case <-wg.C():
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
cmd/bucket-replication.go
mrfMU sync.Mutex resyncer *replicationResyncer // workers: workers []chan ReplicationWorkerOperation lrgworkers []chan ReplicationWorkerOperation // mrf: mrfWorkerKillCh chan struct{} mrfReplicaCh chan ReplicationWorkerOperation mrfSaveCh chan MRFReplicateEntry mrfStopCh chan struct{} mrfWorkerSize int }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1)