Code Review
/
govpp.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Update generated binapi to v22.02 & makefile changes
[govpp.git]
/
examples
/
perf-bench
/
perf-bench.go
diff --git
a/examples/perf-bench/perf-bench.go
b/examples/perf-bench/perf-bench.go
index
6472068
..
f7a9857
100644
(file)
--- a/
examples/perf-bench/perf-bench.go
+++ b/
examples/perf-bench/perf-bench.go
@@
-30,7
+30,7
@@
import (
"git.fd.io/govpp.git/adapter/socketclient"
"git.fd.io/govpp.git/adapter/statsclient"
"git.fd.io/govpp.git/api"
"git.fd.io/govpp.git/adapter/socketclient"
"git.fd.io/govpp.git/adapter/statsclient"
"git.fd.io/govpp.git/api"
- "git.fd.io/govpp.git/binapi/
vpe
"
+ "git.fd.io/govpp.git/binapi/
memclnt
"
"git.fd.io/govpp.git/core"
)
"git.fd.io/govpp.git/core"
)
@@
-117,8
+117,8
@@
func syncTest(ch api.Channel, cnt int) {
fmt.Printf("Running synchronous perf test with %d requests...\n", cnt)
for i := 0; i < cnt; i++ {
fmt.Printf("Running synchronous perf test with %d requests...\n", cnt)
for i := 0; i < cnt; i++ {
- req := &
vpe
.ControlPing{}
- reply := &
vpe
.ControlPingReply{}
+ req := &
memclnt
.ControlPing{}
+ reply := &
memclnt
.ControlPingReply{}
if err := ch.SendRequest(req).ReceiveReply(reply); err != nil {
log.Fatalln("Error in reply:", err)
if err := ch.SendRequest(req).ReceiveReply(reply); err != nil {
log.Fatalln("Error in reply:", err)
@@
-134,12
+134,12
@@
func syncTest2(conn api.Connection, cnt int) {
log.Fatalln("Error NewStream:", err)
}
for i := 0; i < cnt; i++ {
log.Fatalln("Error NewStream:", err)
}
for i := 0; i < cnt; i++ {
- if err := stream.SendMsg(&
vpe
.ControlPing{}); err != nil {
+ if err := stream.SendMsg(&
memclnt
.ControlPing{}); err != nil {
log.Fatalln("Error SendMsg:", err)
}
if msg, err := stream.RecvMsg(); err != nil {
log.Fatalln("Error RecvMsg:", err)
log.Fatalln("Error SendMsg:", err)
}
if msg, err := stream.RecvMsg(); err != nil {
log.Fatalln("Error RecvMsg:", err)
- } else if _, ok := msg.(*
vpe
.ControlPingReply); ok {
+ } else if _, ok := msg.(*
memclnt
.ControlPingReply); ok {
// ok
} else {
log.Fatalf("unexpected reply: %v", msg.GetMessageName())
// ok
} else {
log.Fatalf("unexpected reply: %v", msg.GetMessageName())
@@
-154,14
+154,14
@@
func asyncTest(ch api.Channel, cnt int) {
go func() {
for i := 0; i < cnt; i++ {
go func() {
for i := 0; i < cnt; i++ {
- ctxChan <- ch.SendRequest(&
vpe
.ControlPing{})
+ ctxChan <- ch.SendRequest(&
memclnt
.ControlPing{})
}
close(ctxChan)
fmt.Printf("Sending asynchronous requests finished\n")
}()
for ctx := range ctxChan {
}
close(ctxChan)
fmt.Printf("Sending asynchronous requests finished\n")
}()
for ctx := range ctxChan {
- reply := &
vpe
.ControlPingReply{}
+ reply := &
memclnt
.ControlPingReply{}
if err := ctx.ReceiveReply(reply); err != nil {
log.Fatalln("Error in reply:", err)
}
if err := ctx.ReceiveReply(reply); err != nil {
log.Fatalln("Error in reply:", err)
}
@@
-179,7
+179,7
@@
func asyncTest2(conn api.Connection, cnt int) {
if err != nil {
log.Fatalln("Error NewStream:", err)
}
if err != nil {
log.Fatalln("Error NewStream:", err)
}
- if err := stream.SendMsg(&
vpe
.ControlPing{}); err != nil {
+ if err := stream.SendMsg(&
memclnt
.ControlPing{}); err != nil {
log.Fatalln("Error SendMsg:", err)
}
ctxChan <- stream
log.Fatalln("Error SendMsg:", err)
}
ctxChan <- stream
@@
-191,7
+191,7
@@
func asyncTest2(conn api.Connection, cnt int) {
for ctx := range ctxChan {
if msg, err := ctx.RecvMsg(); err != nil {
log.Fatalln("Error RecvMsg:", err)
for ctx := range ctxChan {
if msg, err := ctx.RecvMsg(); err != nil {
log.Fatalln("Error RecvMsg:", err)
- } else if _, ok := msg.(*
vpe
.ControlPingReply); ok {
+ } else if _, ok := msg.(*
memclnt
.ControlPingReply); ok {
// ok
} else {
log.Fatalf("unexpected reply: %v", msg.GetMessageName())
// ok
} else {
log.Fatalf("unexpected reply: %v", msg.GetMessageName())