5 writes to _blockedReadersHead
System.Threading.Channels (5)
System\Threading\Channels\RendezvousChannel.cs (5)
161
ChannelUtilities.Enqueue(ref parent.
_blockedReadersHead
, reader);
279
parent.
_blockedReadersHead
= null;
315
blockedReader = ChannelUtilities.TryDequeueAndReserveCompletionIfCancelable(ref parent.
_blockedReadersHead
);
395
blockedReader = ChannelUtilities.TryDequeueAndReserveCompletionIfCancelable(ref parent.
_blockedReadersHead
);
462
ChannelUtilities.Remove(ref state.Key.
_blockedReadersHead
, blockedReader);
5 references to _blockedReadersHead
System.Threading.Channels (5)
System\Threading\Channels\RendezvousChannel.cs (5)
229
blockedReaderCount = ChannelUtilities.CountOperations(_parent.
_blockedReadersHead
);
275
blockedReadersHead = parent.
_blockedReadersHead
;
357
if (parent.
_blockedReadersHead
is not null || parent._dropWrites)
495
if (
_blockedReadersHead
is not null)
503
Debug.Assert(
_blockedReadersHead
is null, "There shouldn't be any blocked readers if there's a blocked writer.");