Exclude Tx Hashes when serving Blocks & apply network back pressure

src/Nethermind/Nethermind.AccountAbstraction/Network/UserOperationsMessageSerializer.cs

@@ -15,7 +15,7 @@ public class UserOperationsMessageSerializer : IZeroInnerMessageSerializer<UserO
         public void Serialize(IByteBuffer byteBuffer, UserOperationsMessage message)
         {
             int length = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(length, true);
+            byteBuffer.EnsureWritable(length);
             NettyRlpStream nettyRlpStream = new(byteBuffer);
 
             nettyRlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Blockchain.Test/Blocks/BlockStoreTests.cs

@@ -26,12 +26,12 @@ public void Test_can_insert_get_and_remove_blocks(bool cached)
         Block block = Build.A.Block.WithNumber(1).TestObject;
         store.Insert(block);
 
-        Block? retrieved = store.Get(block.Number, block.Hash!, cached);
+        Block? retrieved = store.Get(block.Number, block.Hash!, RlpBehaviors.None, cached);
         retrieved.Should().BeEquivalentTo(block);
 
         store.Delete(block.Number, block.Hash!);
 
-        store.Get(block.Number, block.Hash!, cached).Should().BeNull();
+        store.Get(block.Number, block.Hash!, RlpBehaviors.None, cached).Should().BeNull();
     }
 
     [Test]
@@ -57,7 +57,7 @@ public void Test_can_get_block_that_was_stored_with_hash(bool cached)
         Block block = Build.A.Block.WithNumber(1).TestObject;
         db[block.Hash!.Bytes] = (new BlockDecoder()).Encode(block).Bytes;
 
-        Block? retrieved = store.Get(block.Number, block.Hash!, cached);
+        Block? retrieved = store.Get(block.Number, block.Hash!, RlpBehaviors.None, cached);
         retrieved.Should().BeEquivalentTo(block);
     }
 
@@ -83,12 +83,12 @@ public void Test_when_cached_does_not_touch_db_on_next_get()
         Block block = Build.A.Block.WithNumber(1).TestObject;
         store.Insert(block);
 
-        Block? retrieved = store.Get(block.Number, block.Hash!, true);
+        Block? retrieved = store.Get(block.Number, block.Hash!, RlpBehaviors.None, true);
         retrieved.Should().BeEquivalentTo(block);
 
         db.Clear();
 
-        retrieved = store.Get(block.Number, block.Hash!, true);
+        retrieved = store.Get(block.Number, block.Hash!, RlpBehaviors.None, true);
         retrieved.Should().BeEquivalentTo(block);
     }
 

src/Nethermind/Nethermind.Blockchain/BlockTree.cs

@@ -1301,7 +1301,11 @@ private bool ShouldCache(long number)
             blockNumber ??= _headerStore.GetBlockNumber(blockHash);
             if (blockNumber is not null)
             {
-                block = _blockStore.Get(blockNumber.Value, blockHash, shouldCache: false);
+                block = _blockStore.Get(
+                    blockNumber.Value,
+                    blockHash,
+                    (options & BlockTreeLookupOptions.ExcludeTxHashes) != 0 ? RlpBehaviors.ExcludeHashes : RlpBehaviors.None,
+                    shouldCache: false);
             }
 
             if (block is null)

src/Nethermind/Nethermind.Blockchain/BlockTreeMethodOptions.cs

@@ -13,7 +13,8 @@ public enum BlockTreeLookupOptions
     RequireCanonical = 2,
     DoNotCreateLevelIfMissing = 4,
     AllowInvalid = 8,
-    All = 15
+    ExcludeTxHashes = 16,
+    All = 31
 }
 
 [Flags]

src/Nethermind/Nethermind.Blockchain/Blocks/BlockStore.cs

@@ -84,11 +84,11 @@ public void Delete(long blockNumber, Hash256 blockHash)
         _blockDb.Remove(blockHash.Bytes);
     }
 
-    public Block? Get(long blockNumber, Hash256 blockHash, bool shouldCache = false)
+    public Block? Get(long blockNumber, Hash256 blockHash, RlpBehaviors rlpBehaviors = RlpBehaviors.None, bool shouldCache = false)
     {
-        Block? b = _blockDb.Get(blockNumber, blockHash, _blockDecoder, _blockCache, shouldCache);
+        Block? b = _blockDb.Get(blockNumber, blockHash, _blockDecoder, _blockCache, rlpBehaviors, shouldCache);
         if (b is not null) return b;
-        return _blockDb.Get(blockHash, _blockDecoder, _blockCache, shouldCache);
+        return _blockDb.Get(blockHash, _blockDecoder, _blockCache, rlpBehaviors, shouldCache);
     }
 
     public ReceiptRecoveryBlock? GetReceiptRecoveryBlock(long blockNumber, Hash256 blockHash)

src/Nethermind/Nethermind.Blockchain/Blocks/IBlockStore.cs

@@ -16,7 +16,7 @@ public interface IBlockStore
 {
     void Insert(Block block, WriteFlags writeFlags = WriteFlags.None);
     void Delete(long blockNumber, Hash256 blockHash);
-    Block? Get(long blockNumber, Hash256 blockHash, bool shouldCache = true);
+    Block? Get(long blockNumber, Hash256 blockHash, RlpBehaviors rlpBehaviors = RlpBehaviors.None, bool shouldCache = true);
     IEnumerable<Block> GetAll();
     ReceiptRecoveryBlock? GetReceiptRecoveryBlock(long blockNumber, Hash256 blockHash);
     void Cache(Block block);

src/Nethermind/Nethermind.Consensus/Processing/BlockProcessor.cs

@@ -4,6 +4,8 @@
 using System;
 using System.Collections.Generic;
 using System.Numerics;
+using System.Runtime.InteropServices;
+using System.Threading;
 using Nethermind.Blockchain;
 using Nethermind.Blockchain.Receipts;
 using Nethermind.Consensus.BeaconBlockRoot;
@@ -86,6 +88,7 @@ public Block[] Process(Hash256 newBranchStateRoot, List<Block> suggestedBlocks,
     {
         if (suggestedBlocks.Count == 0) return Array.Empty<Block>();
 
+        TxHashCalculator.CalculateInBackground(suggestedBlocks);
         BlocksProcessing?.Invoke(this, new BlocksProcessingEventArgs(suggestedBlocks));
 
         /* We need to save the snapshot state root before reorganization in case the new branch has invalid blocks.
@@ -371,4 +374,29 @@ private void ApplyDaoTransition(Block block)
             }
         }
     }
+
+    private class TxHashCalculator(List<Block> suggestedBlocks) : IThreadPoolWorkItem
+    {
+        public static void CalculateInBackground(List<Block> suggestedBlocks)
+        {
+            // Memory has been reserved on the transactions to delay calculate the hashes
+            // We calculate the hashes in the background to release that memory
+            ThreadPool.UnsafeQueueUserWorkItem(new TxHashCalculator(suggestedBlocks), preferLocal: false);
+        }
+
+        void IThreadPoolWorkItem.Execute()
+        {
+            // Hashes will be required for PersistentReceiptStorage in UpdateMainChain ForkchoiceUpdatedHandler
+            // Which occurs after the block has been processed; however the block is stored in cache and picked up
+            // from there so we can calculate the hashes now for that later use.
+            foreach (Block block in CollectionsMarshal.AsSpan(suggestedBlocks))
+            {
+                foreach (Transaction tx in block.Transactions)
+                {
+                    // Calculate the hashes to release the memory from the transactionSequence
+                    tx.CalculateHashInternal();
+                }
+            }
+        }
+    }
 }

src/Nethermind/Nethermind.Network/P2P/Messages/AddCapabilityMessageSerializer.cs

@@ -15,7 +15,7 @@ public class AddCapabilityMessageSerializer : IZeroMessageSerializer<AddCapabili
         public void Serialize(IByteBuffer byteBuffer, AddCapabilityMessage msg)
         {
             int totalLength = GetLength(msg, out int contentLength);
-            byteBuffer.EnsureWritable(totalLength, true);
+            byteBuffer.EnsureWritable(totalLength);
 
             NettyRlpStream stream = new(byteBuffer);
             stream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Messages/DisconnectMessageSerializer.cs

@@ -13,7 +13,7 @@ public class DisconnectMessageSerializer : IZeroMessageSerializer<DisconnectMess
         public void Serialize(IByteBuffer byteBuffer, DisconnectMessage msg)
         {
             int length = GetLength(msg, out int contentLength);
-            byteBuffer.EnsureWritable(length);
+            byteBuffer.EnsureWritable(length, force: true);
             NettyRlpStream rlpStream = new(byteBuffer);
 
             rlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Messages/HelloMessageSerializer.cs

@@ -15,7 +15,7 @@ public class HelloMessageSerializer : IZeroMessageSerializer<HelloMessage>
         public void Serialize(IByteBuffer byteBuffer, HelloMessage msg)
         {
             (int totalLength, int innerLength) length = GetLength(msg);
-            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(length.totalLength), true);
+            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(length.totalLength), force: true);
             NettyRlpStream stream = new(byteBuffer);
             stream.StartSequence(length.totalLength);
             stream.Encode(msg.P2PVersion);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/HashesMessageSerializer.cs

@@ -24,7 +24,7 @@ protected static Hash256[] DeserializeHashes(RlpStream rlpStream)
         public void Serialize(IByteBuffer byteBuffer, T message)
         {
             int length = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(length, true);
+            byteBuffer.EnsureWritable(length);
             RlpStream rlpStream = new NettyRlpStream(byteBuffer);
 
             rlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V62/Messages/BlockBodiesMessageSerializer.cs

@@ -16,7 +16,7 @@ public class BlockBodiesMessageSerializer : IZeroInnerMessageSerializer<BlockBod
         public void Serialize(IByteBuffer byteBuffer, BlockBodiesMessage message)
         {
             int totalLength = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(totalLength, true);
+            byteBuffer.EnsureWritable(totalLength);
             NettyRlpStream stream = new(byteBuffer);
             stream.StartSequence(contentLength);
             foreach (BlockBody? body in message.Bodies.Bodies)

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V62/Messages/BlockHeadersMessageSerializer.cs

@@ -14,7 +14,7 @@ public class BlockHeadersMessageSerializer : IZeroInnerMessageSerializer<BlockHe
         public void Serialize(IByteBuffer byteBuffer, BlockHeadersMessage message)
         {
             int length = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(length, true);
+            byteBuffer.EnsureWritable(length);
             RlpStream rlpStream = new NettyRlpStream(byteBuffer);
 
             rlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V62/Messages/GetBlockBodiesMessageSerializer.cs

@@ -12,7 +12,7 @@ public class GetBlockBodiesMessageSerializer : IZeroInnerMessageSerializer<GetBl
         public void Serialize(IByteBuffer byteBuffer, GetBlockBodiesMessage message)
         {
             int length = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(length, true);
+            byteBuffer.EnsureWritable(length);
             NettyRlpStream nettyRlpStream = new(byteBuffer);
 
             nettyRlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V62/Messages/GetBlockHeadersMessageSerializer.cs

@@ -33,7 +33,7 @@ public static GetBlockHeadersMessage Deserialize(RlpStream rlpStream)
         public void Serialize(IByteBuffer byteBuffer, GetBlockHeadersMessage message)
         {
             int length = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(length, true);
+            byteBuffer.EnsureWritable(length);
             RlpStream rlpStream = new NettyRlpStream(byteBuffer);
 
             rlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V62/Messages/NewBlockHashesMessageSerializer.cs

@@ -12,7 +12,7 @@ public class NewBlockHashesMessageSerializer : IZeroInnerMessageSerializer<NewBl
         public void Serialize(IByteBuffer byteBuffer, NewBlockHashesMessage message)
         {
             int length = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(length, true);
+            byteBuffer.EnsureWritable(length);
             NettyRlpStream nettyRlpStream = new(byteBuffer);
 
             nettyRlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V62/Messages/NewBlockMessageSerializer.cs

@@ -14,7 +14,7 @@ public class NewBlockMessageSerializer : IZeroInnerMessageSerializer<NewBlockMes
         public void Serialize(IByteBuffer byteBuffer, NewBlockMessage message)
         {
             int length = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(length, true);
+            byteBuffer.EnsureWritable(length);
             RlpStream rlpStream = new NettyRlpStream(byteBuffer);
 
             rlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V62/Messages/TransactionsMessageSerializer.cs

@@ -14,7 +14,7 @@ public class TransactionsMessageSerializer : IZeroInnerMessageSerializer<Transac
         public void Serialize(IByteBuffer byteBuffer, TransactionsMessage message)
         {
             int length = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(length, true);
+            byteBuffer.EnsureWritable(length);
             NettyRlpStream nettyRlpStream = new(byteBuffer);
 
             nettyRlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V63/Messages/NodeDataMessageSerializer.cs

@@ -11,7 +11,7 @@ public class NodeDataMessageSerializer : IZeroInnerMessageSerializer<NodeDataMes
         public void Serialize(IByteBuffer byteBuffer, NodeDataMessage message)
         {
             int length = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(length, true);
+            byteBuffer.EnsureWritable(length);
             RlpStream rlpStream = new NettyRlpStream(byteBuffer);
 
             rlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V63/Messages/ReceiptsMessageSerializer.cs

@@ -25,7 +25,7 @@ public void Serialize(IByteBuffer byteBuffer, ReceiptsMessage message)
         {
             int totalLength = GetLength(message, out int contentLength);
 
-            byteBuffer.EnsureWritable(totalLength, true);
+            byteBuffer.EnsureWritable(totalLength);
             NettyRlpStream stream = new(byteBuffer);
             stream.StartSequence(contentLength);
 

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V66/Messages/Eth66MessageSerializer.cs

@@ -21,7 +21,7 @@ protected Eth66MessageSerializer(IZeroInnerMessageSerializer<TEthMessage> ethMes
         public void Serialize(IByteBuffer byteBuffer, TEth66Message message)
         {
             int length = GetLength(message, out int contentLength);
-            byteBuffer.EnsureWritable(length, true);
+            byteBuffer.EnsureWritable(length);
             RlpStream rlpStream = new NettyRlpStream(byteBuffer);
             rlpStream.StartSequence(contentLength);
             rlpStream.Encode(message.RequestId);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Eth/V68/Messages/NewPooledTransactionHashesMessageSerializer68.cs

@@ -36,7 +36,7 @@ public void Serialize(IByteBuffer byteBuffer, NewPooledTransactionHashesMessage6
 
             int totalSize = Rlp.LengthOf(message.Types) + Rlp.LengthOfSequence(sizesLength) + Rlp.LengthOfSequence(hashesLength);
 
-            byteBuffer.EnsureWritable(totalSize, true);
+            byteBuffer.EnsureWritable(totalSize);
 
             RlpStream rlpStream = new NettyRlpStream(byteBuffer);
 

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Les/Messages/BlockHeadersMessageSerializer.cs

@@ -20,7 +20,7 @@ public void Serialize(IByteBuffer byteBuffer, BlockHeadersMessage message)
             int totalLength = Rlp.LengthOfSequence(contentLength);
 
             RlpStream rlpStream = new NettyRlpStream(byteBuffer);
-            byteBuffer.EnsureWritable(totalLength, true);
+            byteBuffer.EnsureWritable(totalLength);
 
             rlpStream.StartSequence(contentLength);
             rlpStream.Encode(message.RequestId);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Les/Messages/GetBlockHeadersMessageSerializer.cs

@@ -17,7 +17,7 @@ public void Serialize(IByteBuffer byteBuffer, GetBlockHeadersMessage message)
             int totalLength = Rlp.LengthOfSequence(contentLength);
 
             RlpStream rlpStream = new NettyRlpStream(byteBuffer);
-            byteBuffer.EnsureWritable(totalLength, true);
+            byteBuffer.EnsureWritable(totalLength);
 
             rlpStream.StartSequence(contentLength);
             rlpStream.Encode(message.RequestId);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/NodeData/Messages/NodeDataMessageSerializer.cs

@@ -11,7 +11,7 @@ public class NodeDataMessageSerializer : IZeroInnerMessageSerializer<NodeDataMes
     public void Serialize(IByteBuffer byteBuffer, NodeDataMessage message)
     {
         int length = GetLength(message, out int contentLength);
-        byteBuffer.EnsureWritable(length, true);
+        byteBuffer.EnsureWritable(length);
         RlpStream rlpStream = new NettyRlpStream(byteBuffer);
 
         rlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Snap/Messages/AccountRangeMessageSerializer.cs

@@ -15,7 +15,7 @@ public void Serialize(IByteBuffer byteBuffer, AccountRangeMessage message)
         {
             (int contentLength, int pwasLength, int proofsLength) = GetLength(message);
 
-            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(contentLength), true);
+            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(contentLength));
 
             NettyRlpStream stream = new(byteBuffer);
             stream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Snap/Messages/ByteCodesMessageSerializer.cs

@@ -11,7 +11,7 @@ public class ByteCodesMessageSerializer : IZeroMessageSerializer<ByteCodesMessag
         public void Serialize(IByteBuffer byteBuffer, ByteCodesMessage message)
         {
             (int contentLength, int codesLength) = GetLength(message);
-            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(contentLength), true);
+            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(contentLength));
             RlpStream rlpStream = new NettyRlpStream(byteBuffer);
 
             rlpStream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Snap/Messages/GetTrieNodesMessageSerializer.cs

@@ -13,7 +13,7 @@ public void Serialize(IByteBuffer byteBuffer, GetTrieNodesMessage message)
         {
             (int contentLength, int allPathsLength, int[] pathsLengths) = CalculateLengths(message);
 
-            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(contentLength), true);
+            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(contentLength));
             NettyRlpStream stream = new(byteBuffer);
 
             stream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Snap/Messages/SnapSerializerBase.cs

@@ -15,7 +15,7 @@ public abstract class SnapSerializerBase<T> : IZeroInnerMessageSerializer<T> whe
         protected NettyRlpStream GetRlpStreamAndStartSequence(IByteBuffer byteBuffer, T msg)
         {
             int totalLength = GetLength(msg, out int contentLength);
-            byteBuffer.EnsureWritable(totalLength, true);
+            byteBuffer.EnsureWritable(totalLength);
             NettyRlpStream stream = new(byteBuffer);
             stream.StartSequence(contentLength);
 

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Snap/Messages/StorageRangesMessageSerializer.cs

@@ -25,7 +25,7 @@ public void Serialize(IByteBuffer byteBuffer, StorageRangeMessage message)
         {
             (int contentLength, int allSlotsLength, int[] accountSlotsLengths, int proofsLength) = CalculateLengths(message);
 
-            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(contentLength), true);
+            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(contentLength));
             NettyRlpStream stream = new(byteBuffer);
 
             stream.StartSequence(contentLength);

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Snap/Messages/TrieNodesMessageSerializer.cs

@@ -12,7 +12,7 @@ public void Serialize(IByteBuffer byteBuffer, TrieNodesMessage message)
         {
             (int contentLength, int nodesLength) = GetLength(message);
 
-            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(contentLength), true);
+            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(contentLength));
 
             NettyRlpStream rlpStream = new(byteBuffer);
 

src/Nethermind/Nethermind.Network/P2P/Subprotocols/Wit/Messages/BlockWitnessHashesMessageSerializer.cs

@@ -15,7 +15,7 @@ public void Serialize(IByteBuffer byteBuffer, BlockWitnessHashesMessage message)
 
             int contentLength = GetLength(message, out int totalLength);
 
-            byteBuffer.EnsureWritable(totalLength, true);
+            byteBuffer.EnsureWritable(totalLength);
             nettyRlpStream.StartSequence(contentLength);
             nettyRlpStream.Encode(message.RequestId);
             if (message.Hashes is null)

src/Nethermind/Nethermind.Network/Rlpx/Handshake/AckEip8MessageSerializer.cs

@@ -28,7 +28,7 @@ public void Serialize(IByteBuffer byteBuffer, AckEip8Message msg)
             totalLength += Rlp.LengthOf(msg.Nonce);
             totalLength += Rlp.LengthOf(msg.Version);
 
-            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(totalLength), true);
+            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(totalLength));
             NettyRlpStream stream = new(byteBuffer);
             stream.StartSequence(totalLength);
             stream.Encode(msg.EphemeralPublicKey.Bytes);

src/Nethermind/Nethermind.Network/Rlpx/Handshake/AuthEip8MessageSerializer.cs

@@ -22,7 +22,7 @@ public void Serialize(IByteBuffer byteBuffer, AuthEip8Message msg)
         {
             int totalLength = GetLength(msg);
             // TODO: Account for the padding
-            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(totalLength), true);
+            byteBuffer.EnsureWritable(Rlp.LengthOfSequence(totalLength));
             NettyRlpStream stream = new(byteBuffer);
             stream.StartSequence(totalLength);
             stream.Encode(Bytes.Concat(msg.Signature.Bytes, msg.Signature.RecoveryId));

src/Nethermind/Nethermind.Network/Rlpx/Handshake/AuthMessageSerializer.cs

@@ -37,7 +37,7 @@ public class AuthMessageSerializer : IZeroMessageSerializer<AuthMessage>
 
         public void Serialize(IByteBuffer byteBuffer, AuthMessage msg)
         {
-            byteBuffer.EnsureWritable(Length, true);
+            byteBuffer.EnsureWritable(Length);
             byteBuffer.WriteBytes(msg.Signature.Bytes);
             byteBuffer.WriteByte(msg.Signature.RecoveryId);
             byteBuffer.WriteBytes(msg.EphemeralPublicHash.Bytes);