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>

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)
 		}
 	}
 }