undo yamux revert (#9036)

Using a plain ticket reference without TODO should still ensure we can track the issue. also added ticket reference for SszCollectionSchema.java Signed-off-by: Paul Harris <[email protected]>
Consensys · Jan 26, 2025 · 28f69d3 · 28f69d3
1 parent d9b07ea
commit 28f69d3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/...re/ssz/src/main/java/tech/pegasys/teku/infrastructure/ssz/schema/SszCollectionSchema.java b/...re/ssz/src/main/java/tech/pegasys/teku/infrastructure/ssz/schema/SszCollectionSchema.java
@@ -49,6 +49,7 @@ default SszCollectionT createFromElements(final List<? extends SszElementT> elem
   }
 
   default TreeNode createTreeFromElements(final List<? extends SszElementT> elements) {
+    // https://github.com/Consensys/teku/issues/9035
     // This is a generic implementation which works for both Vector and List but it potentially
     // could do better if construct the tree directly in List/Vector subclasses
     checkArgument(elements.size() <= getMaxLength(), "Too many elements for this collection type");

diff --git a/...rking/p2p/src/main/java/tech/pegasys/teku/networking/p2p/libp2p/LibP2PNetworkBuilder.java b/...rking/p2p/src/main/java/tech/pegasys/teku/networking/p2p/libp2p/LibP2PNetworkBuilder.java
@@ -217,7 +217,9 @@ protected Host createHost(final PrivKey privKey, final List<Multiaddr> advertise
 
           // Yamux must take precedence during negotiation
           if (config.isYamuxEnabled()) {
-            b.getMuxers().add(StreamMuxerProtocol.getYamux());
+            // https://github.com/Consensys/teku/issues/7532
+            final int maxBufferedConnectionWrites = 150 * 1024 * 1024;
+            b.getMuxers().add(StreamMuxerProtocol.getYamux(maxBufferedConnectionWrites));
           }
           b.getMuxers().add(StreamMuxerProtocol.getMplex());