From 6b350c65fe0ec845cecf58bfb41ffc63dc9c04f7 Mon Sep 17 00:00:00 2001 From: Ondrej Fabry Date: Thu, 23 Aug 2018 22:51:56 +0200 Subject: Simplify subscribing to events and fix events - there is no need for sending subscription requests through channels, since all the messages are registered and no communication with VPP is needed Change-Id: Ibc29957be02a32e26309f66c369a071559b822a9 Signed-off-by: Ondrej Fabry --- examples/cmd/perf-bench/perf-bench.go | 16 +++++----------- 1 file changed, 5 insertions(+), 11 deletions(-) (limited to 'examples/cmd/perf-bench/perf-bench.go') diff --git a/examples/cmd/perf-bench/perf-bench.go b/examples/cmd/perf-bench/perf-bench.go index 5b4b17d..664f046 100644 --- a/examples/cmd/perf-bench/perf-bench.go +++ b/examples/cmd/perf-bench/perf-bench.go @@ -20,7 +20,6 @@ import ( "flag" "fmt" "log" - "os" "time" "github.com/pkg/profile" @@ -65,16 +64,14 @@ func main() { // connect to VPP conn, err := govpp.Connect("") if err != nil { - log.Println("Error:", err) - os.Exit(1) + log.Fatalln("Error:", err) } defer conn.Disconnect() // create an API channel ch, err := conn.NewAPIChannelBuffered(cnt, cnt) if err != nil { - log.Println("Error:", err) - os.Exit(1) + log.Fatalln("Error:", err) } defer ch.Close() @@ -101,10 +98,8 @@ func syncTest(ch api.Channel, cnt int) { req := &vpe.ControlPing{} reply := &vpe.ControlPingReply{} - err := ch.SendRequest(req).ReceiveReply(reply) - if err != nil { - log.Println("Error in reply:", err) - os.Exit(1) + if err := ch.SendRequest(req).ReceiveReply(reply); err != nil { + log.Fatalln("Error in reply:", err) } } } @@ -125,8 +120,7 @@ func asyncTest(ch api.Channel, cnt int) { for ctx := range ctxChan { reply := &vpe.ControlPingReply{} if err := ctx.ReceiveReply(reply); err != nil { - log.Println("Error in reply:", err) - os.Exit(1) + log.Fatalln("Error in reply:", err) } } } -- cgit 1.2.3-korg