aboutsummaryrefslogtreecommitdiff
path: root/weed/command/filer.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-07-03 19:07:55 -0700
committerChris Lu <chris.lu@gmail.com>2018-07-03 19:07:55 -0700
commit77fc8c59140537bb693ccf44c63e68626322b70e (patch)
treefe68e68eeb061da8a1172b8c1d6b65fd84a2d734 /weed/command/filer.go
parent28e5f20c8e8cf7cb84026db43c9f33ff13236b64 (diff)
downloadseaweedfs-77fc8c59140537bb693ccf44c63e68626322b70e.tar.xz
seaweedfs-77fc8c59140537bb693ccf44c63e68626322b70e.zip
keep alive for gRpc calls
Diffstat (limited to 'weed/command/filer.go')
-rw-r--r--weed/command/filer.go3
1 files changed, 1 insertions, 2 deletions
diff --git a/weed/command/filer.go b/weed/command/filer.go
index 2d4696828..e5a3e379a 100644
--- a/weed/command/filer.go
+++ b/weed/command/filer.go
@@ -10,7 +10,6 @@ import (
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
"github.com/chrislusf/seaweedfs/weed/server"
"github.com/chrislusf/seaweedfs/weed/util"
- "google.golang.org/grpc"
"google.golang.org/grpc/reflection"
"strings"
)
@@ -129,7 +128,7 @@ func (fo *FilerOptions) start() {
if err != nil {
glog.Fatalf("failed to listen on grpc port %d: %v", grpcPort, err)
}
- grpcS := grpc.NewServer()
+ grpcS := util.NewGrpcServer()
filer_pb.RegisterSeaweedFilerServer(grpcS, fs)
reflection.Register(grpcS)
go grpcS.Serve(grpcL)