1 write to _owningBatch
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
315_owningBatch = owningBatch;
14 references to _owningBatch
System.Threading.Tasks.Dataflow (14)
Blocks\BatchBlock.cs (14)
384messageValue = source.ConsumeMessage(messageHeader, _owningBatch, out consumed)!; 440_owningBatch._source.AddException(exception); 452catch (Exception e) { _owningBatch._source.AddException(e); } 483return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || _owningBatch._source.HasExceptions; 534Common.ReleaseAllPostponedMessages(targetCore._owningBatch, 543targetCore._owningBatch._source.AddExceptions(exceptions); 648_owningBatch, _nonGreedyState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 793if (sourceAndMessage.Key.ReserveMessage(sourceAndMessage.Value, _owningBatch)) 811if (sourceAndMessage.Key.ReserveMessage(sourceAndMessage.Value, _owningBatch)) 999T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value.Key, _owningBatch, out consumed); 1051T? consumedValue = sourceAndMessage.Key.ConsumeMessage(sourceAndMessage.Value.Key, _owningBatch, out consumed); 1100try { source.ReleaseReservation(message.Key, _owningBatch); } 1164var displayBatch = _owningBatch as IDebuggerDisplay; 1165return $"Block = \"{(displayBatch != null ? displayBatch.Content : _owningBatch)}\"";