summaryrefslogtreecommitdiffhomepage
path: root/test/scenario_test/quagga-rsconfig.go
diff options
context:
space:
mode:
Diffstat (limited to 'test/scenario_test/quagga-rsconfig.go')
-rw-r--r--test/scenario_test/quagga-rsconfig.go249
1 files changed, 0 insertions, 249 deletions
diff --git a/test/scenario_test/quagga-rsconfig.go b/test/scenario_test/quagga-rsconfig.go
deleted file mode 100644
index 60ae9fd0..00000000
--- a/test/scenario_test/quagga-rsconfig.go
+++ /dev/null
@@ -1,249 +0,0 @@
-package main
-
-import (
- "bytes"
- "fmt"
- "github.com/BurntSushi/toml"
- "github.com/jessevdk/go-flags"
- "github.com/osrg/gobgp/config"
- "io/ioutil"
- "log"
- "net"
- "os"
- "path/filepath"
-)
-
-var serverAddress = make(map[string]string)
-var baseNeighborAddress = make(map[string]string)
-var baseNeighborNetwork = make(map[string]string)
-var baseNeighborNetMask = make(map[string]string)
-
-const (
- IPv4 = "ipv4"
- IPv6 = "ipv6"
-)
-
-type QuaggaConfig struct {
- id int
- config *config.Neighbor
- gobgpConfig *config.Global
- serverIP net.IP
-}
-
-func NewQuaggaConfig(id int, gConfig *config.Global, myConfig *config.Neighbor, server net.IP) *QuaggaConfig {
- return &QuaggaConfig{
- id: id,
- config: myConfig,
- gobgpConfig: gConfig,
- serverIP: server,
- }
-}
-
-func (qt *QuaggaConfig) IPv4Config() *bytes.Buffer {
- buf := bytes.NewBuffer(nil)
- buf.WriteString(fmt.Sprintf("! my address %s\n", qt.config.NeighborConfig.NeighborAddress))
- buf.WriteString(fmt.Sprintf("! my ip_version %s\n", IPv4))
- buf.WriteString("hostname bgpd\n")
- buf.WriteString("password zebra\n")
- buf.WriteString(fmt.Sprintf("router bgp %d\n", qt.config.NeighborConfig.PeerAs))
- buf.WriteString(fmt.Sprintf("bgp router-id 192.168.0.%d\n", qt.id))
- buf.WriteString(fmt.Sprintf("network %s%d%s\n", baseNeighborNetwork[IPv4], qt.id, baseNeighborNetMask[IPv4]))
- buf.WriteString(fmt.Sprintf("neighbor %s remote-as %d\n", qt.serverIP, qt.gobgpConfig.GlobalConfig.As))
- buf.WriteString(fmt.Sprintf("neighbor %s password %s\n", qt.serverIP, qt.config.NeighborConfig.AuthPassword))
- buf.WriteString("debug bgp as4\n")
- buf.WriteString("debug bgp fsm\n")
- buf.WriteString("debug bgp updates\n")
- buf.WriteString("debug bgp events\n")
- buf.WriteString("log file /var/log/quagga/bgpd.log\n")
-
- return buf
-}
-
-func (qt *QuaggaConfig) IPv6Config() *bytes.Buffer {
- buf := bytes.NewBuffer(nil)
- buf.WriteString(fmt.Sprintf("! my address %s\n", qt.config.NeighborConfig.NeighborAddress))
- buf.WriteString(fmt.Sprintf("! my ip_version %s\n", IPv6))
- buf.WriteString("hostname bgpd\n")
- buf.WriteString("password zebra\n")
- buf.WriteString(fmt.Sprintf("router bgp %d\n", qt.config.NeighborConfig.PeerAs))
- buf.WriteString(fmt.Sprintf("bgp router-id 192.168.0.%d\n", qt.id))
- buf.WriteString("no bgp default ipv4-unicast\n")
- buf.WriteString(fmt.Sprintf("neighbor %s remote-as %d\n", qt.serverIP, qt.gobgpConfig.GlobalConfig.As))
- buf.WriteString(fmt.Sprintf("neighbor %s password %s\n", qt.serverIP, qt.config.NeighborConfig.AuthPassword))
- buf.WriteString("address-family ipv6\n")
- buf.WriteString(fmt.Sprintf("network %s%d%s\n", baseNeighborNetwork[IPv6], qt.id, baseNeighborNetMask[IPv6]))
- buf.WriteString(fmt.Sprintf("neighbor %s activate\n", qt.serverIP))
- buf.WriteString(fmt.Sprintf("neighbor %s route-map IPV6-OUT out\n", qt.serverIP))
- buf.WriteString("exit-address-family\n")
- buf.WriteString("ipv6 prefix-list pl-ipv6 seq 10 permit any\n")
- buf.WriteString("route-map IPV6-OUT permit 10\n")
- buf.WriteString("match ipv6 address prefix-list pl-ipv6\n")
- buf.WriteString(fmt.Sprintf("set ipv6 next-hop global %s\n", qt.config.NeighborConfig.NeighborAddress))
- buf.WriteString("debug bgp as4\n")
- buf.WriteString("debug bgp fsm\n")
- buf.WriteString("debug bgp updates\n")
- buf.WriteString("debug bgp events\n")
- buf.WriteString("log file /var/log/quagga/bgpd.log\n")
-
- return buf
-}
-
-func create_config_files(nr int, outputDir string, IPVersion string, nonePeer bool, normalBGP bool) {
- quaggaConfigList := make([]*QuaggaConfig, 0)
-
- gobgpConf := config.Bgp{}
- gobgpConf.Global.GlobalConfig.As = 65000
- gobgpConf.Global.GlobalConfig.RouterId = net.ParseIP("192.168.255.1")
-
- for i := 1; i < nr+1; i++ {
-
- c := config.Neighbor{}
- c.NeighborConfig.PeerAs = 65000 + uint32(i)
- c.NeighborConfig.NeighborAddress = net.ParseIP(fmt.Sprintf("%s%d", baseNeighborAddress[IPVersion], i))
- c.NeighborConfig.AuthPassword = fmt.Sprintf("hoge%d", i)
- c.Transport.TransportConfig.PassiveMode = true
- c.RouteServer.RouteServerConfig.RouteServerClient = !normalBGP
-
- timers := config.Timers{}
- timers.TimersConfig.HoldTime = 30
- timers.TimersConfig.KeepaliveInterval = 10
- timers.TimersConfig.IdleHoldTimeAfterReset = 10
-
- c.Timers = timers
- c.NeighborConfig.PeerType = config.PEER_TYPE_EXTERNAL
-
- gobgpConf.Neighbors.NeighborList = append(gobgpConf.Neighbors.NeighborList, c)
- if !nonePeer {
- q := NewQuaggaConfig(i, &gobgpConf.Global, &c, net.ParseIP(serverAddress[IPVersion]))
- quaggaConfigList = append(quaggaConfigList, q)
- os.Mkdir(fmt.Sprintf("%s/q%d", outputDir, i), 0755)
- var err error
- if IPVersion == IPv6 {
- err = ioutil.WriteFile(fmt.Sprintf("%s/q%d/bgpd.conf", outputDir, i), q.IPv6Config().Bytes(), 0644)
- } else {
- err = ioutil.WriteFile(fmt.Sprintf("%s/q%d/bgpd.conf", outputDir, i), q.IPv4Config().Bytes(), 0644)
- }
- if err != nil {
- log.Fatal(err)
- }
- }
- }
-
- var buffer bytes.Buffer
- encoder := toml.NewEncoder(&buffer)
- encoder.Encode(gobgpConf)
-
- err := ioutil.WriteFile(fmt.Sprintf("%s/gobgpd.conf", outputDir), buffer.Bytes(), 0644)
- if err != nil {
- log.Fatal(err)
- }
-}
-
-func append_config_files(ar int, outputDir string, IPVersion string, noQuagga bool, normalBGP bool) {
-
- gobgpConf := config.Bgp{}
- gobgpConf.Global.GlobalConfig.As = 65000
- gobgpConf.Global.GlobalConfig.RouterId = net.ParseIP("192.168.255.1")
-
- c := config.Neighbor{}
- c.NeighborConfig.PeerAs = 65000 + uint32(ar)
- c.NeighborConfig.NeighborAddress = net.ParseIP(fmt.Sprintf("%s%d", baseNeighborAddress[IPVersion], ar))
- c.NeighborConfig.AuthPassword = fmt.Sprintf("hoge%d", ar)
- c.RouteServer.RouteServerConfig.RouteServerClient = !normalBGP
- c.Transport.TransportConfig.PassiveMode = true
-
- timers := config.Timers{}
- timers.TimersConfig.HoldTime = 30
- timers.TimersConfig.KeepaliveInterval = 10
- timers.TimersConfig.IdleHoldTimeAfterReset = 10
-
- c.Timers = timers
- c.NeighborConfig.PeerType = config.PEER_TYPE_EXTERNAL
-
- if !noQuagga {
- q := NewQuaggaConfig(ar, &gobgpConf.Global, &c, net.ParseIP(serverAddress[IPVersion]))
- os.Mkdir(fmt.Sprintf("%s/q%d", outputDir, ar), 0755)
- var err error
- if IPVersion == IPv6 {
- err = ioutil.WriteFile(fmt.Sprintf("%s/q%d/bgpd.conf", outputDir, ar), q.IPv6Config().Bytes(), 0644)
- } else {
- err = ioutil.WriteFile(fmt.Sprintf("%s/q%d/bgpd.conf", outputDir, ar), q.IPv4Config().Bytes(), 0644)
- }
- if err != nil {
- log.Fatal(err)
- }
- }
- newConf := config.Bgp{}
- _, d_err := toml.DecodeFile(fmt.Sprintf("%s/gobgpd.conf", outputDir), &newConf)
- if d_err != nil {
- log.Fatal(d_err)
- }
- newConf.Neighbors.NeighborList = append(newConf.Neighbors.NeighborList, c)
- var buffer bytes.Buffer
- encoder := toml.NewEncoder(&buffer)
- encoder.Encode(newConf)
-
- policyConf := &config.RoutingPolicy{}
- _, p_err := toml.DecodeFile(fmt.Sprintf("%s/gobgpd.conf", outputDir), policyConf)
- if p_err != nil {
- log.Fatal(p_err)
- }
-
- if policyConf != nil && len(policyConf.PolicyDefinitions.PolicyDefinitionList) != 0 {
- encoder.Encode(policyConf)
- }
-
- e_err := ioutil.WriteFile(fmt.Sprintf("%s/gobgpd.conf", outputDir), buffer.Bytes(), 0644)
- if e_err != nil {
- log.Fatal(e_err)
- }
-}
-
-func main() {
- var opts struct {
- ClientNumber int `short:"n" long:"client-number" description:"specfying the number of clients" default:"8"`
- OutputDir string `short:"c" long:"output" description:"specifing the output directory"`
- AppendClient int `short:"a" long:"append" description:"specifing the add client number" default:"0"`
- IPVersion string `short:"v" long:"ip-version" description:"specifing the use ip version" default:"IPv4"`
- NetIdentifier int `short:"i" long:"net-identifer" description:"specifing the use network identifier" default:"0"`
- NonePeer bool `long:"none-peer" description:"disable make quagga config"`
- NormalBGP bool `long:"normal-bgp" description:"generate normal bgp server configuration"`
- }
- parser := flags.NewParser(&opts, flags.Default)
- _, err := parser.Parse()
- if err != nil {
- fmt.Print(err)
- os.Exit(1)
- }
- if opts.OutputDir == "" {
- opts.OutputDir, _ = filepath.Abs(".")
- } else {
- if _, err := os.Stat(opts.OutputDir); os.IsNotExist(err) {
- os.Mkdir(opts.OutputDir, 0755)
- }
- }
-
- if opts.IPVersion == IPv6 {
- serverAddress[IPv6] = fmt.Sprintf("2001::%d:192:168:255:1", opts.NetIdentifier)
- baseNeighborAddress[IPv6] = fmt.Sprintf("2001::%d:192:168:0:", opts.NetIdentifier)
- baseNeighborNetwork[IPv6] = "2001:0:10:"
- baseNeighborNetMask[IPv6] = "::/64"
- } else {
- opts.IPVersion = IPv4
- serverAddress[IPv4] = fmt.Sprintf("1%d.0.255.1", opts.NetIdentifier)
- baseNeighborAddress[IPv4] = fmt.Sprintf("1%d.0.0.", opts.NetIdentifier)
- baseNeighborNetwork[IPv4] = "192.168."
- baseNeighborNetMask[IPv4] = ".0/24"
- }
-
- isCreateMode := opts.AppendClient == 0
-
- if isCreateMode {
- create_config_files(opts.ClientNumber, opts.OutputDir, opts.IPVersion, opts.NonePeer, opts.NormalBGP)
- } else {
- if _, err := os.Stat(fmt.Sprintf("%s/gobgpd.conf", opts.OutputDir)); os.IsNotExist(err) {
- log.Fatal(err)
- }
- append_config_files(opts.AppendClient, opts.OutputDir, opts.IPVersion, opts.NonePeer, opts.NormalBGP)
- }
-}
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-16 03:27:19 +0000