[igp] increase ServerWithMaxInflightPackets

VKCOM · Sep 18, 2023 · 323e6c9 · 323e6c9
1 parent b2219b3
commit 323e6c9
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/internal/aggregator/ingress_proxy.go b/internal/aggregator/ingress_proxy.go
@@ -97,7 +97,7 @@ func RunIngressProxy(sh2 *agent.Agent, aesPwd string, config ConfigIngressProxy)
 		rpc.ServerWithTrustedSubnetGroups(build.TrustedSubnetGroups()),
 		rpc.ServerWithVersion(build.Info()),
 		rpc.ServerWithDefaultResponseTimeout(data_model.MaxConveyorDelay*time.Second),
-		rpc.ServerWithMaxInflightPackets((data_model.MaxConveyorDelay+data_model.MaxHistorySendStreams)*3), // see server settings in aggregator
+		rpc.ServerWithMaxInflightPackets((data_model.MaxConveyorDelay+data_model.MaxHistorySendStreams)*3*30), // see server settings in aggregator
 		rpc.ServerWithMaxWorkers(128<<10),
 		rpc.ServerWithResponseBufSize(1024),
 		rpc.ServerWithResponseMemEstimate(1024),

diff --git a/internal/metadata/rpc_handler_test.go b/internal/metadata/rpc_handler_test.go
@@ -32,14 +32,15 @@ func initServer(t *testing.T, now func() time.Time) (net.Listener, *rpc.Server,
 	handler := NewHandler(db, "abc", log.Printf)
 	proxy := ProxyHandler{}
 	h := tlmetadata.Handler{
-		RawGetMapping:          proxy.HandleProxy("", handler.RawGetMappingByValue),
-		RawGetInvertMapping:    proxy.HandleProxy("", handler.RawGetMappingByID),
-		RawEditEntitynew:       proxy.HandleProxy("", handler.RawEditEntity),
-		RawGetJournalnew:       proxy.HandleProxy("", handler.RawGetJournal),
+		RawGetMapping:       proxy.HandleProxy("", handler.RawGetMappingByValue),
+		RawGetInvertMapping: proxy.HandleProxy("", handler.RawGetMappingByID),
+		RawEditEntitynew:    proxy.HandleProxy("", handler.RawEditEntity),
+
 		PutTagMappingBootstrap: handler.PutTagMappingBootstrap,
 		GetTagMappingBootstrap: handler.GetTagMappingBootstrap,
 	}
-	server := rpc.NewServer(rpc.ServerWithHandler(h.Handle), rpc.ServerWithLogf(log.Printf))
+	sh := tlmetadata.Handler{RawGetJournalnew: proxy.HandleProxy("", handler.RawGetJournal)}
+	server := rpc.NewServer(rpc.ServerWithHandler(h.Handle), rpc.ServerWithSyncHandler(sh.Handle), rpc.ServerWithLogf(log.Printf))
 	t.Cleanup(func() {
 		server.Close()
 	})