matrix-capnproto-fed

commit 132cdb7cce6b0ddc7bd7a874835768504a795856
parent 45b558e2f6915487cb995ba95fd1146816b09952
Author: MTRNord <mtrnord1@gmail.com>
Date:   Thu, 14 Mar 2024 22:30:58 +0100

Slightly increase limit

Diffstat:
M
cmds/client/main.go
 | 
2
+-
M
cmds/server/main.go
 | 
2
+-

2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/cmds/client/main.go b/cmds/client/main.go
@@ -55,7 +55,7 @@ func printServerKeys(ctx context.Context, client protocol.MatrixFederation) erro
 	callback := helpers.NewKeyStreamCallback()
 	callback_client := protocol.StreamCallback_ServerToClient(callback)
 	defer callback_client.Release()
-	callback_client.SetFlowLimiter(flowcontrol.NewFixedLimiter(1 << 16))
+	callback_client.SetFlowLimiter(flowcontrol.NewFixedLimiter(1 << 17))
 	keys_future, release := client.GetKeys(ctx, func(p protocol.MatrixFederation_getKeys_Params) error {
 		log.Println("Sending getKeys request...")
 
diff --git a/cmds/server/main.go b/cmds/server/main.go
@@ -71,7 +71,7 @@ func main() {
 	server := rpcserver.NewServer()
 
 	client := protocol.MatrixFederation_ServerToClient(server)
-	client.SetFlowLimiter(flowcontrol.NewFixedLimiter(1 << 16))
+	client.SetFlowLimiter(flowcontrol.NewFixedLimiter(1 << 17))
 
 	ListenAndServe(context.Background(), "tcp", "localhost:2000", capnp.Client(client))
 }