7 writes to Value
System.Threading.Tasks.Dataflow (7)
Internal\SourceCore.cs (5)
81private PaddedInt64 _nextMessageId = new PaddedInt64 { Value = 1 }; // We are going to use this value before incrementing. Protected by ValueLock. 200_nextMessageId.Value++; 297_nextMessageId.Value++; 350_nextMessageId.Value++; 630_nextMessageId.Value++;
Internal\TargetCore.cs (2)
217long messageId = _nextAvailableInputMessageId.Value++; 659messageId = _nextAvailableInputMessageId.Value++; // optimistically assign an ID
5 references to Value
System.Threading.Tasks.Dataflow (5)
Internal\SourceCore.cs (5)
190if (messageHeader.Id != _nextMessageId.Value || 233if (messageHeader.Id == _nextMessageId.Value && !_messages.IsEmpty) 260if (messageHeader.Id != _nextMessageId.Value || _messages.IsEmpty) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 568header = new DataflowMessageHeader(_nextMessageId.Value); 625if (_nextMessageId.Value != header.Id ||