Refixes #148
This commit is contained in:
11
cmd/main.go
11
cmd/main.go
@@ -327,21 +327,20 @@ func onConnected(
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
var port uint16
|
var port uint16
|
||||||
for err != nil {
|
for {
|
||||||
port, err = piaConf.GetPortForward()
|
port, err = piaConf.GetPortForward()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Error("port forwarding:", err)
|
logger.Error("port forwarding:", err)
|
||||||
|
logger.Info("port forwarding: retrying in 5 seconds...")
|
||||||
|
time.Sleep(5 * time.Second)
|
||||||
|
} else {
|
||||||
|
break
|
||||||
}
|
}
|
||||||
logger.Info("port forwarding: retrying in 5 seconds...")
|
|
||||||
time.Sleep(5 * time.Second)
|
|
||||||
}
|
}
|
||||||
logger.Info("port forwarding: Port %d", port)
|
|
||||||
if err := piaConf.WritePortForward(portForwardingFilepath, port, uid, gid); err != nil {
|
if err := piaConf.WritePortForward(portForwardingFilepath, port, uid, gid); err != nil {
|
||||||
logger.Error("port forwarding:", err)
|
logger.Error("port forwarding:", err)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
if err := piaConf.AllowPortForwardFirewall(ctx, constants.TUN, port); err != nil {
|
if err := piaConf.AllowPortForwardFirewall(ctx, constants.TUN, port); err != nil {
|
||||||
logger.Error("port forwarding:", err)
|
logger.Error("port forwarding:", err)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user