emulator: Configure max message size to 256 MiB
Fixes #1270
Change-Id: Id73f16fcef07d47d1469f699f98f6dce6dfdb06b
Reviewed-on: https://code-review.googlesource.com/c/37330
Reviewed-by: Solomon Duskis <sduskis@google.com>
Reviewed-by: kokoro <noreply+kokoro@google.com>
diff --git a/bigtable/cmd/emulator/cbtemulator.go b/bigtable/cmd/emulator/cbtemulator.go
index 2477a64..144c09f 100644
--- a/bigtable/cmd/emulator/cbtemulator.go
+++ b/bigtable/cmd/emulator/cbtemulator.go
@@ -31,10 +31,18 @@
port = flag.Int("port", 9000, "the port number to bind to on the local machine")
)
+const (
+ maxMsgSize = 256 * 1024 * 1024 // 256 MiB
+)
+
func main() {
grpc.EnableTracing = false
flag.Parse()
- srv, err := bttest.NewServer(fmt.Sprintf("%s:%d", *host, *port))
+ opts := []grpc.ServerOption{
+ grpc.MaxRecvMsgSize(maxMsgSize),
+ grpc.MaxSendMsgSize(maxMsgSize),
+ }
+ srv, err := bttest.NewServer(fmt.Sprintf("%s:%d", *host, *port), opts...)
if err != nil {
log.Fatalf("failed to start emulator: %v", err)
}
