- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 210 for Chan (0.14 sec)
-
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) -
cmd/mrf.go
setIndex, poolIndex int queued time.Time scanMode madmin.HealScanMode } // mrfState sncapsulates all the information // related to the global background MRF. type mrfState struct { opCh chan partialOperation } // Add a partial S3 operation (put/delete) when one or more disks are offline. func (m *mrfState) addPartialOp(op partialOperation) { if m == nil { return } select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K 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/metrics-v2.go
func (c *minioBucketCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc } // Collect is called by the Prometheus registry when collecting metrics. func (c *minioBucketCollector) Collect(out chan<- prometheus.Metric) { var wg sync.WaitGroup publish := func(in <-chan MetricV2) { defer wg.Done() for metric := range in {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cmd/erasure-server-pool.go
if firstErr == nil { firstErr = err } // Cancel remaining... cancel() mu.Unlock() return } }(resultIndex, erObj) } } updateCloser := make(chan chan struct{}) go func() { updateTicker := time.NewTicker(30 * time.Second) defer updateTicker.Stop() var lastUpdate time.Time // We need to merge since we will get the same buckets from each pool.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K 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/event/target/kafka.go
producer sarama.SyncProducer config *sarama.Config store store.Store[event.Event] batch *store.Batch[string, *sarama.ProducerMessage] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *KafkaTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *KafkaTarget) Name() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/event/target/nats.go
id event.TargetID args NATSArgs natsConn *nats.Conn stanConn stan.Conn jstream nats.JetStream store store.Store[event.Event] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *NATSTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *NATSTarget) Name() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.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) -
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)