mirror of
https://github.com/slackhq/nebula.git
synced 2026-04-02 23:15:18 +02:00
checkpt
This commit is contained in:
@@ -322,7 +322,7 @@ func (t *tun) reload(c *config.C, initial bool) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if !initial {
|
if initial {
|
||||||
t.snatAddr = prepareSnatAddr(t, t.l, c, routes)
|
t.snatAddr = prepareSnatAddr(t, t.l, c, routes)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -413,6 +413,10 @@ func (t *tun) reload(c *config.C, initial bool) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if initial {
|
||||||
|
t.snatAddr = prepareSnatAddr(t, t.l, c, routes)
|
||||||
|
}
|
||||||
|
|
||||||
routeTree, err := makeRouteTree(t.l, routes, false)
|
routeTree, err := makeRouteTree(t.l, routes, false)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -182,7 +182,7 @@ func (t *tun) reload(c *config.C, initial bool) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if !initial {
|
if initial {
|
||||||
t.snatAddr = prepareSnatAddr(t, t.l, c, routes)
|
t.snatAddr = prepareSnatAddr(t, t.l, c, routes)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -328,7 +328,8 @@ func (t *tun) addIPs(link netlink.Link) error {
|
|||||||
Label: t.vpnNetworks[i].Addr().Zone(),
|
Label: t.vpnNetworks[i].Addr().Zone(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if t.snatAddr.IsValid() {
|
|
||||||
|
if t.snatAddr.IsValid() && len(t.vpnNetworks) > 0 { //TODO unsafe-routers should be able to snat and be snatted
|
||||||
newAddrs = append(newAddrs, &netlink.Addr{
|
newAddrs = append(newAddrs, &netlink.Addr{
|
||||||
IPNet: &net.IPNet{
|
IPNet: &net.IPNet{
|
||||||
IP: t.snatAddr.Addr().AsSlice(),
|
IP: t.snatAddr.Addr().AsSlice(),
|
||||||
@@ -429,11 +430,12 @@ func (t *tun) Activate() error {
|
|||||||
return fmt.Errorf("failed to set default route MTU for %s: %w", t.vpnNetworks[i], err)
|
return fmt.Errorf("failed to set default route MTU for %s: %w", t.vpnNetworks[i], err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if t.snatAddr.IsValid() {
|
//TODO snat and be snatted
|
||||||
if err = t.setDefaultRoute(t.snatAddr); err != nil {
|
//if t.snatAddr.IsValid() {
|
||||||
return fmt.Errorf("failed to set default route MTU for %s: %w", t.snatAddr, err)
|
// if err = t.setDefaultRoute(t.snatAddr); err != nil {
|
||||||
}
|
// return fmt.Errorf("failed to set default route MTU for %s: %w", t.snatAddr, err)
|
||||||
}
|
// }
|
||||||
|
//}
|
||||||
|
|
||||||
// Set the routes
|
// Set the routes
|
||||||
if err = t.addRoutes(false); err != nil {
|
if err = t.addRoutes(false); err != nil {
|
||||||
|
|||||||
@@ -352,6 +352,10 @@ func (t *tun) reload(c *config.C, initial bool) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if initial {
|
||||||
|
t.snatAddr = prepareSnatAddr(t, t.l, c, routes)
|
||||||
|
}
|
||||||
|
|
||||||
routeTree, err := makeRouteTree(t.l, routes, false)
|
routeTree, err := makeRouteTree(t.l, routes, false)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -273,6 +273,10 @@ func (t *tun) reload(c *config.C, initial bool) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if initial {
|
||||||
|
t.snatAddr = prepareSnatAddr(t, t.l, c, routes)
|
||||||
|
}
|
||||||
|
|
||||||
routeTree, err := makeRouteTree(t.l, routes, false)
|
routeTree, err := makeRouteTree(t.l, routes, false)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -105,7 +105,7 @@ func (t *winTun) reload(c *config.C, initial bool) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if !initial {
|
if initial {
|
||||||
t.snatAddr = prepareSnatAddr(t, t.l, c, routes)
|
t.snatAddr = prepareSnatAddr(t, t.l, c, routes)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user