kopia lustrzana https://github.com/cyoung/stratux
Typo fix. Addresses #267.
rodzic
e97b7f5e4c
commit
8f28239dd8
|
@ -296,7 +296,7 @@ func messageQueueSender() {
|
||||||
averageSendableQueueSize = averageSendableQueueSize / float64(len(outSockets)) // It's a total, not an average, up until this point.
|
averageSendableQueueSize = averageSendableQueueSize / float64(len(outSockets)) // It's a total, not an average, up until this point.
|
||||||
pd = math.Max(float64(1.0/750.0), float64(1.0/(4.0*averageSendableQueueSize))) // Say 250ms is enough to get through the whole queue.
|
pd = math.Max(float64(1.0/750.0), float64(1.0/(4.0*averageSendableQueueSize))) // Say 250ms is enough to get through the whole queue.
|
||||||
} else {
|
} else {
|
||||||
pd = float64(1.0 / 0.1) // 100ms.
|
pd = float64(0.1) // 100ms.
|
||||||
}
|
}
|
||||||
queueTimer.Stop()
|
queueTimer.Stop()
|
||||||
queueTimer = time.NewTicker(time.Duration(pd*1000000000.0) * time.Nanosecond)
|
queueTimer = time.NewTicker(time.Duration(pd*1000000000.0) * time.Nanosecond)
|
||||||
|
|
Ładowanie…
Reference in New Issue