mrt: merge gomrt to gobgp cli command

Usage
$ gobgp mrt inject global <filename> [<count>]

Signed-off-by: ISHIDA Wataru <ishida.wataru@lab.ntt.co.jp>

1 files changed, 0 insertions, 182 deletions

diff --git a/gomrt/main.go b/gomrt/main.go
deleted file mode 100644
index aeca76af..00000000
--- a/gomrt/main.go
+++ /dev/null
@@ -1,182 +0,0 @@
-// Copyright (C) 2015 Nippon Telegraph and Telephone Corporation.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-//    http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-// implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package main
-
-import (
-	"fmt"
-	"github.com/osrg/gobgp/api"
-	"github.com/osrg/gobgp/packet"
-	"github.com/spf13/cobra"
-	"golang.org/x/net/context"
-	"google.golang.org/grpc"
-	"io"
-	"net"
-	"os"
-	"time"
-)
-
-var globalOpts struct {
-	Host  string
-	Port  int
-	Input string
-	Count int
-}
-
-var client api.GrpcClient
-
-func connGrpc() *grpc.ClientConn {
-	timeout := grpc.WithTimeout(time.Second)
-
-	// determine IP address version
-	host := net.ParseIP(globalOpts.Host)
-	target := fmt.Sprintf("%s:%d", globalOpts.Host, globalOpts.Port)
-	if host.To4() == nil {
-		target = fmt.Sprintf("[%s]:%d", globalOpts.Host, globalOpts.Port)
-	}
-
-	conn, err := grpc.Dial(target, timeout)
-	if err != nil {
-		fmt.Println(err)
-		os.Exit(1)
-	}
-	return conn
-}
-
-func main() {
-
-	rootCmd := &cobra.Command{
-		Use: "gomrt",
-		PersistentPreRun: func(cmd *cobra.Command, args []string) {
-			conn := connGrpc()
-			client = api.NewGrpcClient(conn)
-		},
-		Run: func(cmd *cobra.Command, args []string) {
-			file, err := os.Open(globalOpts.Input)
-			if err != nil {
-				fmt.Println("failed to open file")
-				os.Exit(1)
-			}
-
-			idx := 0
-
-			ch := make(chan *api.Path, 1024)
-
-			go func() {
-
-				for {
-					buf := make([]byte, bgp.MRT_COMMON_HEADER_LEN)
-					_, err := file.Read(buf)
-					if err == io.EOF {
-						break
-					} else if err != nil {
-						fmt.Println("failed to read:", err)
-						os.Exit(1)
-					}
-
-					h := &bgp.MRTHeader{}
-					err = h.DecodeFromBytes(buf)
-					if err != nil {
-						fmt.Println("failed to parse")
-						os.Exit(1)
-					}
-
-					buf = make([]byte, h.Len)
-					_, err = file.Read(buf)
-					if err != nil {
-						fmt.Println("failed to read")
-						os.Exit(1)
-					}
-
-					msg, err := bgp.ParseMRTBody(h, buf)
-					if err != nil {
-						fmt.Println("failed to parse:", err)
-						os.Exit(1)
-					}
-
-					if msg.Header.Type == bgp.TABLE_DUMPv2 {
-						subType := bgp.MRTSubTypeTableDumpv2(msg.Header.SubType)
-						var af *api.AddressFamily
-						switch subType {
-						case bgp.PEER_INDEX_TABLE:
-							continue
-						case bgp.RIB_IPV4_UNICAST:
-							af = api.AF_IPV4_UC
-						case bgp.RIB_IPV6_UNICAST:
-							af = api.AF_IPV6_UC
-						default:
-							fmt.Println("unsupported subType:", subType)
-							os.Exit(1)
-						}
-						rib := msg.Body.(*bgp.Rib)
-						prefix := rib.Prefix.String()
-						path := &api.Path{}
-						path.Nlri = &api.Nlri{
-							Af:     af,
-							Prefix: prefix,
-						}
-
-						ch <- path
-					}
-
-					idx += 1
-
-					if idx == globalOpts.Count {
-						break
-					}
-				}
-
-				close(ch)
-			}()
-
-			stream, err := client.ModPath(context.Background())
-			if err != nil {
-				fmt.Println("failed to modpath:", err)
-				os.Exit(1)
-			}
-
-			for path := range ch {
-				arg := &api.ModPathArguments{
-					Resource: api.Resource_GLOBAL,
-					Path:     path,
-				}
-
-				err = stream.Send(arg)
-				if err != nil {
-					fmt.Println("failed to send:", err)
-					os.Exit(1)
-				}
-			}
-
-			res, err := stream.CloseAndRecv()
-			if err != nil {
-				fmt.Println("failed to send:", err)
-				os.Exit(1)
-			}
-			if res.Code != api.Error_SUCCESS {
-				fmt.Errorf("error: code: %d, msg: %s", res.Code, res.Msg)
-				os.Exit(1)
-			}
-
-		},
-	}
-
-	rootCmd.PersistentFlags().StringVarP(&globalOpts.Host, "host", "u", "127.0.0.1", "host")
-	rootCmd.PersistentFlags().IntVarP(&globalOpts.Port, "port", "p", 8080, "port")
-	rootCmd.Flags().StringVarP(&globalOpts.Input, "input", "i", "", "input mrt file")
-	rootCmd.Flags().IntVarP(&globalOpts.Count, "count", "c", -1, "how many mrt record you read")
-	rootCmd.Execute()
-
-}