Now gives a progression of 10s, 20s, 40s and 60s waits.
}
func (udp *udpWrap) sendQueue() {
}
func (udp *udpWrap) sendQueue() {
- initialWait := 6 * time.Second
+ initialWait := 5 * time.Second
wait := initialWait
for set := range udp.sendQueueCh {
Retry:
wait := initialWait
for set := range udp.sendQueueCh {
Retry:
if reply.Error() == udpapi.TimeoutError {
// retry
if reply.Error() == udpapi.TimeoutError {
// retry
- wait = (wait * 15) / 10
if wait > time.Minute {
wait = time.Minute
}
if wait > time.Minute {
wait = time.Minute
}