From 44a6d9dffd1cd2cd366b4062d8c32ac4b88cacc9 Mon Sep 17 00:00:00 2001 From: Chris Baker Date: Wed, 12 Dec 2018 19:09:06 +0000 Subject: [PATCH] gofmt --- nomad/rpc.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/nomad/rpc.go b/nomad/rpc.go index aa681d5f8..f39c52c76 100644 --- a/nomad/rpc.go +++ b/nomad/rpc.go @@ -49,8 +49,8 @@ const ( type rpcHandler struct { *Server - logger log.Logger - gologger *golog.Logger + logger log.Logger + gologger *golog.Logger acceptLoopDelay time.Duration } @@ -102,7 +102,7 @@ func (r *rpcHandler) listen(ctx context.Context) { r.handleAcceptErr(err, ctx) continue } - // No error, reset delay loop + // No error, reset loop delay r.acceptLoopDelay = 0 go r.handleConn(ctx, conn, &RPCContext{Conn: conn}) @@ -113,7 +113,7 @@ func (r *rpcHandler) listen(ctx context.Context) { // Sleep to avoid spamming the log, with a maximum delay according to whether or not the error is temporary func (r *rpcHandler) handleAcceptErr(err error, ctx context.Context) { const baseAcceptLoopDelay = 5 * time.Millisecond - const maxAcceptLoopDelay = 5 * time.Second + const maxAcceptLoopDelay = 5 * time.Second const maxAcceptLoopDelayTemporaryError = 1 * time.Second if r.acceptLoopDelay == 0 {