flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2025-12-15 18:26:35 +00:00
Code Issues Releases Wiki Activity

Update SymbolOrderBook.cs

Browse Source
This commit is contained in:
JKorf 2025-12-08 21:47:38 +01:00
parent dedb17b166
commit 23efb3f432
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
CryptoExchange.Net/OrderBook/SymbolOrderBook.cs
View File

@ -477,15 +477,13 @@ namespace CryptoExchange.Net.OrderBook
/// </summary> /// </summary>
protected void CheckProcessBuffer() protected void CheckProcessBuffer()
{ {
var pbList = _processBuffer.ToList(); if (_processBuffer.Count > 0)
if (pbList.Count > 0) _logger.OrderBookProcessingBufferedUpdates(Api, Symbol, _processBuffer.Count);
_logger.OrderBookProcessingBufferedUpdates(Api, Symbol, pbList.Count);
foreach (var bufferEntry in pbList) foreach (var bufferEntry in _processBuffer)
{
ProcessRangeUpdates(bufferEntry.FirstUpdateId, bufferEntry.LastUpdateId, bufferEntry.Bids, bufferEntry.Asks); ProcessRangeUpdates(bufferEntry.FirstUpdateId, bufferEntry.LastUpdateId, bufferEntry.Bids, bufferEntry.Asks);
_processBuffer.Remove(bufferEntry);
} _processBuffer.Clear();
} }
/// <summary> /// <summary>
@ -731,6 +729,8 @@ namespace CryptoExchange.Net.OrderBook
LastUpdateId = item.EndUpdateId, LastUpdateId = item.EndUpdateId,
}); });
if (_logger.IsEnabled(LogLevel.Trace))
_logger.OrderBookUpdateBuffered(Api, Symbol, item.StartUpdateId, item.EndUpdateId, item.Asks.Length, item.Bids.Length); _logger.OrderBookUpdateBuffered(Api, Symbol, item.StartUpdateId, item.EndUpdateId, item.Asks.Length, item.Bids.Length);
} }
else else
@ -844,6 +844,7 @@ namespace CryptoExchange.Net.OrderBook
LastSequenceNumber = lastUpdateId; LastSequenceNumber = lastUpdateId;
if (_logger.IsEnabled(LogLevel.Trace))
_logger.OrderBookProcessedMessage(Api, Symbol, firstUpdateId, lastUpdateId); _logger.OrderBookProcessedMessage(Api, Symbol, firstUpdateId, lastUpdateId);
} }
} }