diff options
author | Ondrej Fabry <ofabry@cisco.com> | 2018-08-23 22:51:56 +0200 |
---|---|---|
committer | Ondrej Fabry <ofabry@cisco.com> | 2018-08-24 12:43:05 +0200 |
commit | 6b350c65fe0ec845cecf58bfb41ffc63dc9c04f7 (patch) | |
tree | 6255495854f43ec2f2d11f88990369aadb48db3f /examples/cmd/perf-bench | |
parent | 892683bef86cacc2ccda2b4df2b079171bd92164 (diff) |
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 <ofabry@cisco.com>
Diffstat (limited to 'examples/cmd/perf-bench')
-rw-r--r-- | examples/cmd/perf-bench/perf-bench.go | 16 |
1 files changed, 5 insertions, 11 deletions
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) } } } |