diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-09-12 02:25:15 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-09-12 02:25:15 -0700 |
| commit | e690a2be161a3760595e98032e38ce41804a052c (patch) | |
| tree | 4a5bca5bf63d9931e926d5dce6acd45e75ee725a /weed/command/volume.go | |
| parent | 232ad2fe65b48e65ce5e4431aaadbd925d9c1a59 (diff) | |
| download | seaweedfs-e690a2be161a3760595e98032e38ce41804a052c.tar.xz seaweedfs-e690a2be161a3760595e98032e38ce41804a052c.zip | |
custom grpc port: volume server
Diffstat (limited to 'weed/command/volume.go')
| -rw-r--r-- | weed/command/volume.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/command/volume.go b/weed/command/volume.go index 3278107f5..f5ec11724 100644 --- a/weed/command/volume.go +++ b/weed/command/volume.go @@ -36,6 +36,7 @@ var ( type VolumeServerOptions struct { port *int + portGrpc *int publicPort *int folders []string folderMaxLimits []int @@ -68,6 +69,7 @@ type VolumeServerOptions struct { func init() { cmdVolume.Run = runVolume // break init cycle v.port = cmdVolume.Flag.Int("port", 8080, "http listen port") + v.portGrpc = cmdVolume.Flag.Int("port.grpc", 18080, "grpc listen port") v.publicPort = cmdVolume.Flag.Int("port.public", 0, "port opened to public") v.ip = cmdVolume.Flag.String("ip", util.DetectedHostAddress(), "ip or server name, also used as identifier") v.publicUrl = cmdVolume.Flag.String("publicUrl", "", "Publicly accessible address") @@ -307,7 +309,7 @@ func (v VolumeServerOptions) isSeparatedPublicPort() bool { } func (v VolumeServerOptions) startGrpcService(vs volume_server_pb.VolumeServerServer) *grpc.Server { - grpcPort := *v.port + 10000 + grpcPort := *v.portGrpc grpcL, err := util.NewListener(util.JoinHostPort(*v.bindIp, grpcPort), 0) if err != nil { glog.Fatalf("failed to listen on grpc port %d: %v", grpcPort, err) |