constants

other/java/client/src/main/java/seaweedfs/client/FilerGrpcClient.java

@@ -22,6 +22,10 @@ public class FilerGrpcClient {
     private static final SslContext sslContext;
     private static final String protocol;
 
+    // gRPC keepalive settings - must be consistent with server-side settings in grpc_client_server.go
+    private static final long KEEP_ALIVE_TIME_SECONDS = 60L;
+    private static final long KEEP_ALIVE_TIMEOUT_SECONDS = 20L;
+
     static {
         sslContext = FilerSecurityContext.getGrpcSslContext();
         protocol = FilerSecurityContext.isHttpSecurityEnabled() ? "https" : "http";
@@ -81,8 +85,8 @@ public class FilerGrpcClient {
                 .flowControlWindow(16 * 1024 * 1024)
                 .initialFlowControlWindow(16 * 1024 * 1024)
                 .maxHeaderListSize(16 * 1024 * 1024)
-                .keepAliveTime(60, TimeUnit.SECONDS)
-                .keepAliveTimeout(10, TimeUnit.SECONDS)
+                .keepAliveTime(KEEP_ALIVE_TIME_SECONDS, TimeUnit.SECONDS)
+                .keepAliveTimeout(KEEP_ALIVE_TIMEOUT_SECONDS, TimeUnit.SECONDS)
                 .keepAliveWithoutCalls(true)
                 .withOption(io.grpc.netty.shaded.io.netty.channel.ChannelOption.SO_RCVBUF, 16 * 1024 * 1024)
                 .withOption(io.grpc.netty.shaded.io.netty.channel.ChannelOption.SO_SNDBUF, 16 * 1024 * 1024);

weed/pb/grpc_client_server.go

@@ -29,6 +29,10 @@ import (
 
 const (
 	Max_Message_Size = 1 << 30 // 1 GB
+
+	// gRPC keepalive settings - must be consistent between client and server
+	GrpcKeepAliveTime    = 60 * time.Second // ping interval when no activity
+	GrpcKeepAliveTimeout = 20 * time.Second // ping timeout
 )
 
 var (
@@ -52,12 +56,12 @@ func NewGrpcServer(opts ...grpc.ServerOption) *grpc.Server {
 	var options []grpc.ServerOption
 	options = append(options,
 		grpc.KeepaliveParams(keepalive.ServerParameters{
-			Time:    60 * time.Second, // wait time before ping if no activity (match client)
-			Timeout: 20 * time.Second, // ping timeout
+			Time:    GrpcKeepAliveTime,    // wait time before ping if no activity
+			Timeout: GrpcKeepAliveTimeout, // ping timeout
 			// MaxConnectionAge: 10 * time.Hour,
 		}),
 		grpc.KeepaliveEnforcementPolicy(keepalive.EnforcementPolicy{
-			MinTime:             60 * time.Second, // min time a client should wait before sending a ping (match client)
+			MinTime:             GrpcKeepAliveTime, // min time a client should wait before sending a ping
 			PermitWithoutStream: true,
 		}),
 		grpc.MaxRecvMsgSize(Max_Message_Size),
@@ -89,8 +93,8 @@ func GrpcDial(ctx context.Context, address string, waitForReady bool, opts ...gr
 			grpc.WaitForReady(waitForReady),
 		),
 		grpc.WithKeepaliveParams(keepalive.ClientParameters{
-			Time:                60 * time.Second, // client ping server if no activity for this long
-			Timeout:             20 * time.Second,
+			Time:                GrpcKeepAliveTime,    // client ping server if no activity for this long
+			Timeout:             GrpcKeepAliveTimeout, // ping timeout
 			PermitWithoutStream: true,
 		}))
 	for _, opt := range opts {