23 references to SerializedLogRecord
Microsoft.AspNetCore.Diagnostics.Middleware (9)
Buffering\IncomingRequestLogBuffer.cs (9)
23private static readonly ObjectPool<List<SerializedLogRecord>> _recordsToEmitListPool = 24PoolFactory.CreateListPoolWithCapacity<SerializedLogRecord>(MaxBatchSize); 32private ConcurrentQueue<SerializedLogRecord> _activeBuffer = new(); 33private ConcurrentQueue<SerializedLogRecord> _standbyBuffer = new(); 73SerializedLogRecord serializedLogRecord = SerializedLogRecordFactory.Create( 104ConcurrentQueue<SerializedLogRecord> tempBuffer; 120List<SerializedLogRecord> recordsToEmit = _recordsToEmitListPool.Get(); 123for (int i = 0; i < currentBatchSize && tempBuffer.TryDequeue(out SerializedLogRecord? bufferedRecord); i++) 140_activeBuffer.TryDequeue(out SerializedLogRecord? item))
Microsoft.Extensions.Telemetry (14)
Buffering\GlobalBuffer.cs (9)
24private static readonly ObjectPool<List<SerializedLogRecord>> _recordsToEmitListPool = 25PoolFactory.CreateListPoolWithCapacity<SerializedLogRecord>(MaxBatchSize); 35private ConcurrentQueue<SerializedLogRecord> _activeBuffer = new(); 36private ConcurrentQueue<SerializedLogRecord> _standbyBuffer = new(); 95SerializedLogRecord serializedLogRecord = SerializedLogRecordFactory.Create( 125ConcurrentQueue<SerializedLogRecord> tempBuffer; 141List<SerializedLogRecord> recordsToEmit = _recordsToEmitListPool.Get(); 144for (int i = 0; i < currentBatchSize && tempBuffer.TryDequeue(out SerializedLogRecord? bufferedRecord); i++) 173_activeBuffer.TryDequeue(out SerializedLogRecord? item))
src\Shared\LogBuffering\SerializedLogRecordFactory.cs (5)
21private static readonly ObjectPool<SerializedLogRecord> _recordPool = 22PoolFactory.CreateResettingPool<SerializedLogRecord>(); 24public static SerializedLogRecord Create( 33SerializedLogRecord record = _recordPool.Get(); 103public static void Return(SerializedLogRecord bufferedRecord)