Rename bridge detection/creation functions
This commit is contained in:
1 parent
44beed4027
commit
a731d47d97
4 files changed
+7
-7
No files matched your search
+3
-3
@@ -81,7 +81,7 @@ func (bridgeImpl) IsFastdp() bool { return false }
|
||||
func (fastdpImpl) IsFastdp() bool { return true }
|
||||
func (bridgedFastdpImpl) IsFastdp() bool { return true }
|
||||
|
||||
func DetectBridgeType(weaveBridgeName, datapathName string) (Bridge, error) {
|
||||
func ExistingBridgeType(weaveBridgeName, datapathName string) (Bridge, error) {
|
||||
bridge, _ := netlink.LinkByName(weaveBridgeName)
|
||||
datapath, _ := netlink.LinkByName(datapathName)
|
||||
|
||||
@@ -226,8 +226,8 @@ func (config *BridgeConfig) configuredBridgeType() Bridge {
|
||||
}
|
||||
}
|
||||
|
||||
func CreateBridge(procPath string, config *BridgeConfig) (Bridge, error) {
|
||||
bridgeType, err := DetectBridgeType(config.WeaveBridgeName, config.DatapathName)
|
||||
func EnsureBridge(procPath string, config *BridgeConfig) (Bridge, error) {
|
||||
bridgeType, err := ExistingBridgeType(config.WeaveBridgeName, config.DatapathName)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
+1
-1
@@ -38,7 +38,7 @@ func CreateAndAttachVeth(name, peerName, bridgeName string, mtu int, keepTXOn bo
|
||||
return nil, fmt.Errorf(format, a...)
|
||||
}
|
||||
|
||||
bridgeType, err := DetectBridgeType(bridgeName, DatapathName)
|
||||
bridgeType, err := ExistingBridgeType(bridgeName, DatapathName)
|
||||
if err != nil {
|
||||
return cleanup("detect bridge type: %s", err)
|
||||
}
|
||||
|
||||
+1
-1
@@ -261,7 +261,7 @@ func main() {
|
||||
name := peerName(routerName, bridgeConfig.WeaveBridgeName, dbPrefix, hostRoot)
|
||||
|
||||
bridgeConfig.Mac = name.String()
|
||||
bridgeType, err := weavenet.CreateBridge(procPath, &bridgeConfig)
|
||||
bridgeType, err := weavenet.EnsureBridge(procPath, &bridgeConfig)
|
||||
checkFatal(err)
|
||||
Log.Println("Bridge type is", bridgeType)
|
||||
|
||||
|
||||
@@ -11,7 +11,7 @@ func detectBridgeType(args []string) error {
|
||||
if len(args) != 2 {
|
||||
cmdUsage("detect-bridge-type", "<weave-bridge-name> <datapath-name>")
|
||||
}
|
||||
bridgeType, err := weavenet.DetectBridgeType(args[0], args[1])
|
||||
bridgeType, err := weavenet.ExistingBridgeType(args[0], args[1])
|
||||
if err != nil {
|
||||
return err
|
||||
} else if bridgeType == nil {
|
||||
@@ -47,7 +47,7 @@ func createBridge(args []string) error {
|
||||
NPC: args[9] == "--expect-npc",
|
||||
}
|
||||
procPath := args[8]
|
||||
bridgeType, err := weavenet.CreateBridge(procPath, &config)
|
||||
bridgeType, err := weavenet.EnsureBridge(procPath, &config)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user