From 010b320617a9c23b91143bf548e239ea33be6823 Mon Sep 17 00:00:00 2001 From: Michael Quigley Date: Thu, 4 Mar 2021 15:14:01 -0500 Subject: [PATCH] Sleep on dial. (#173) --- router/handler_ctrl/route.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/router/handler_ctrl/route.go b/router/handler_ctrl/route.go index 1c75a96a9..714eb6a50 100644 --- a/router/handler_ctrl/route.go +++ b/router/handler_ctrl/route.go @@ -29,6 +29,7 @@ import ( "github.com/openziti/foundation/identity/identity" "github.com/pkg/errors" "github.com/sirupsen/logrus" + "time" ) type routeHandler struct { @@ -116,8 +117,7 @@ func (rh *routeHandler) fail(msg *channel2.Message, attempt int, ch channel2.Cha func (rh *routeHandler) connectEgress(msg *channel2.Message, attempt int, ch channel2.Channel, route *ctrl_pb.Route) { rh.pool.Queue(func() { log := pfxlog.Logger().WithField("sessionId", route.SessionId) - log.Debugf("route request received. binding: %v, destination: %v, address: %v", - route.Egress.Binding, route.Egress.Destination, route.Egress.Address) + log.Debugf("route request received. binding: %v, destination: %v, address: %v", route.Egress.Binding, route.Egress.Destination, route.Egress.Address) if factory, err := xgress.GlobalRegistry().Factory(route.Egress.Binding); err == nil { if dialer, err := factory.CreateDialer(rh.dialerCfg[route.Egress.Binding]); err == nil { sessionId := &identity.TokenId{Token: route.SessionId, Data: route.Egress.PeerData} @@ -127,6 +127,9 @@ func (rh *routeHandler) connectEgress(msg *channel2.Message, attempt int, ch cha handler_xgress.NewCloseHandler(rh.ctrl, rh.forwarder), rh.forwarder) + logrus.Infof("sleeping 10 seconds on dial") + time.Sleep(10 * time.Second) + if peerData, err := dialer.Dial(route.Egress.Destination, sessionId, xgress.Address(route.Egress.Address),