22 references to ReceiveCoreByLinkingCleanupReason
System.Threading.Tasks.Dataflow (22)
Base\DataflowBlock.cs (22)
1093
target.TryCleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError);
1110
receiveTarget.TryCleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.Timer);
1118
receiveTarget.TryCleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.Cancellation);
1189
CleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.Success);
1193
CleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError);
1205
internal bool TryCleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
reason)
1225
private void CleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
reason)
1235
if (reason !=
ReceiveCoreByLinkingCleanupReason
.SourceCompletion && unlink != null)
1250
reason =
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError;
1269
if (reason !=
ReceiveCoreByLinkingCleanupReason
.Cancellation)
1272
if (reason ==
ReceiveCoreByLinkingCleanupReason
.SourceCompletion &&
1275
reason =
ReceiveCoreByLinkingCleanupReason
.Cancellation;
1289
case
ReceiveCoreByLinkingCleanupReason
.Success:
1300
case
ReceiveCoreByLinkingCleanupReason
.Cancellation:
1311
goto case
ReceiveCoreByLinkingCleanupReason
.Cancellation;
1314
case
ReceiveCoreByLinkingCleanupReason
.SourceCompletion:
1316
goto case
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError;
1317
case
ReceiveCoreByLinkingCleanupReason
.Timer:
1319
goto case
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError;
1320
case
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError:
1321
case
ReceiveCoreByLinkingCleanupReason
.ErrorDuringCleanup:
1350
TryCleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.SourceCompletion);