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. 194_nextMessageId.Value++; 291_nextMessageId.Value++; 344_nextMessageId.Value++; 624_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)
184if (messageHeader.Id != _nextMessageId.Value || 227if (messageHeader.Id == _nextMessageId.Value && !_messages.IsEmpty) 254if (messageHeader.Id != _nextMessageId.Value || _messages.IsEmpty) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 562header = new DataflowMessageHeader(_nextMessageId.Value); 619if (_nextMessageId.Value != header.Id ||