server: remove Push timeout from sinkPool
This commit is contained in:
parent
766692bfe6
commit
86f41c8027
|
@ -2,7 +2,6 @@ package server
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// sinkPool represents a pool with sinks.
|
// sinkPool represents a pool with sinks.
|
||||||
|
@ -60,12 +59,9 @@ func (p *sinkPool) Destroy() {
|
||||||
func (p *sinkPool) Push(v []byte) {
|
func (p *sinkPool) Push(v []byte) {
|
||||||
p.mx.RLock()
|
p.mx.RLock()
|
||||||
for _, c := range p.sinks {
|
for _, c := range p.sinks {
|
||||||
// TODO: should this be done in parallel?
|
|
||||||
select {
|
select {
|
||||||
// Send the log output to the channel
|
// Send the log output to the channel
|
||||||
case c <- v:
|
case c <- v:
|
||||||
// Timeout after 100 milliseconds, this will cause the write to the channel to be cancelled.
|
|
||||||
case <-time.After(100 * time.Millisecond):
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
p.mx.RUnlock()
|
p.mx.RUnlock()
|
||||||
|
|
Loading…
Reference in New Issue
Block a user