- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for drain (0.19 sec)
-
internal/grid/grid_test.go
<-serverSent // Now do 100 other requests to ensure that the server doesn't block. for i := 0; i < 100; i++ { _, err := remoteConn.Request(ctx, handlerTest2, []byte(testPayload)) errFatal(err) } // Drain responses got := 0 for resp := range st.responses { // t.Log("got response", resp) errFatal(resp.Err) if resp.Msg[0] != byte(got) { t.Error("expected response", got, "got", resp.Msg[0]) }
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/logger/target/http/http.go
select { case currentGlobalBuffer <- v: default: } } if mainWorker { drain: for { select { case v, ok := <-h.logCh: if !ok { break drain } currentGlobalBuffer <- v default: break drain } } } }() var entry interface{} var ok bool var err error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
internal/grid/muxclient.go
defer func() { fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond)) }() } // Listen for client messages. for { if errState { go func() { // Drain requests. for range requests { } }() return } select { case <-m.ctx.Done(): if debugPrint { fmt.Println("Client sending disconnect to mux", m.MuxID) }
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/admin-heal-ops.go
} h.mutex.Unlock() case <-h.ctx.Done(): h.mutex.Lock() h.endTime = UTCNow() h.currentStatus.Summary = healFinishedStatus h.mutex.Unlock() // drain traverse channel so the traversal // go-routine does not leak. go func() { // Eventually the traversal go-routine closes // the channel and returns, so this go-routine // itself will not leak.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
internal/s3select/message.go
quitFlag = true } } } close(writer.doneCh) recordStagingTicker.Stop() keepAliveTicker.Stop() if progressTicker != nil { progressTicker.Stop() } // Whatever drain the payloadCh to prevent from memory leaking. for len(writer.payloadCh) > 0 { payload := <-writer.payloadCh bufPool.Put(payload) } } // Sends a single whole record.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// for this instance of unlocker, we should let the // caller know that lock is not successfully released // yet. if len(locks)-tolerance == tolerance { // In case of split brain scenarios where // tolerance is exactly half of the len(*locks) // then we need to make sure we have unlocked // upto tolerance+1 - especially for RUnlock // to ensure that we don't end up with active
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0)