@@ -65,9 +65,9 @@ func init() {
6565 flag .StringVar (& protocol , "protocol" , "" , "dispatcher protocol to use. One of [http, grpc]" )
6666 flag .IntVar (& port , "port" , - 1 , "invoker port to call" )
6767 flag .BoolVar (& exitOnComplete , "exitOnComplete" , false , "flag to signal that the sidecar should exit when the output stream is closed" )
68- flag .IntVar (& backoffMaxRetries , "maxBackoffRetries" , 3 , "maximum number of times to retry connecting to the invoker" )
69- flag .IntVar (& backoffMultiplier , "backoffMultiplier" , 2 , "wait time increase for each retry" )
70- flag .IntVar (& backoffDurationMs , "backoffDuration" , 1000 , "base wait time (ms) to wait before retry" )
68+ flag .IntVar (& backoffMaxRetries , "maxBackoffRetries" , 1000 , "maximum number of times to retry connecting to the invoker" )
69+ flag .IntVar (& backoffMultiplier , "backoffMultiplier" , 1 , "wait time increase for each retry" )
70+ flag .IntVar (& backoffDurationMs , "backoffDuration" , 60 , "base wait time (ms) to wait before retry" )
7171
7272}
7373
@@ -143,7 +143,7 @@ LOOP:
143143 if ! backoffOrExit (backoffPtr ) {
144144 panic (err )
145145 } else {
146- log .Printf ("Error %v attempting to create dispatcher\n " , err )
146+ log .Printf ("%v attempting to create dispatcher. Retrying... \n " , err )
147147 continue LOOP
148148 }
149149 }
@@ -182,7 +182,7 @@ func createDispatcher(protocol string) (dispatch.Dispatcher, error) {
182182 if exitOnComplete {
183183 timeout = 60 * time .Second
184184 } else {
185- timeout = 100 * time .Millisecond
185+ timeout = 500 * time .Millisecond
186186 }
187187 return grpc .NewGrpcDispatcher (port , timeout )
188188 default :
0 commit comments