summaryrefslogtreecommitdiffhomepage
path: root/gobmpd/main.go
diff options
context:
space:
mode:
authorFUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>2018-07-07 13:49:24 +0900
committerFUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>2018-07-07 13:49:24 +0900
commitb3079759aa13172fcb548a83da9a9653d8d5fed4 (patch)
tree7841692199b4d67af3045b1bcf70d53d4491d76a /gobmpd/main.go
parent9cd6291b89f076cd009ab2ece96f974bd18dbf05 (diff)
delete gobmpd
this is just an example. Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
Diffstat (limited to 'gobmpd/main.go')
-rw-r--r--gobmpd/main.go66
1 files changed, 0 insertions, 66 deletions
diff --git a/gobmpd/main.go b/gobmpd/main.go
deleted file mode 100644
index f875f847..00000000
--- a/gobmpd/main.go
+++ /dev/null
@@ -1,66 +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 (
- "bufio"
- "encoding/json"
- "fmt"
- "github.com/osrg/gobgp/packet/bmp"
- log "github.com/sirupsen/logrus"
- "net"
- "os"
- "strconv"
-)
-
-func connLoop(conn *net.TCPConn) {
- addr := conn.RemoteAddr()
- scanner := bufio.NewScanner(bufio.NewReader(conn))
- scanner.Split(bmp.SplitBMP)
-
- for scanner.Scan() {
- msg, err := bmp.ParseBMPMessage(scanner.Bytes())
- if err != nil {
- log.Info(err)
- continue
- }
- j, _ := json.Marshal(msg)
- fmt.Print(string(j), "\n")
- }
- log.Info("conn was closed ", addr)
-}
-
-func main() {
- service := ":" + strconv.Itoa(bmp.BMP_DEFAULT_PORT)
- addr, _ := net.ResolveTCPAddr("tcp", service)
-
- l, err := net.ListenTCP("tcp", addr)
- if err != nil {
- log.Info(err)
- os.Exit(1)
- }
-
- for {
- conn, err := l.AcceptTCP()
- if err != nil {
- log.Info(err)
- continue
- }
- log.Info("Accepted a new connection from ", conn.RemoteAddr())
-
- go connLoop(conn)
- }
-}