22 references to ReceiveCoreByLinkingCleanupReason
System.Threading.Tasks.Dataflow (22)
Base\DataflowBlock.cs (22)
1126
target.TryCleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError);
1143
receiveTarget.TryCleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.Timer);
1151
receiveTarget.TryCleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.Cancellation);
1222
CleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.Success);
1226
CleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError);
1238
internal bool TryCleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
reason)
1258
private void CleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
reason)
1268
if (reason !=
ReceiveCoreByLinkingCleanupReason
.SourceCompletion && unlink != null)
1283
reason =
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError;
1302
if (reason !=
ReceiveCoreByLinkingCleanupReason
.Cancellation)
1305
if (reason ==
ReceiveCoreByLinkingCleanupReason
.SourceCompletion &&
1308
reason =
ReceiveCoreByLinkingCleanupReason
.Cancellation;
1322
case
ReceiveCoreByLinkingCleanupReason
.Success:
1333
case
ReceiveCoreByLinkingCleanupReason
.Cancellation:
1344
goto case
ReceiveCoreByLinkingCleanupReason
.Cancellation;
1347
case
ReceiveCoreByLinkingCleanupReason
.SourceCompletion:
1349
goto case
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError;
1350
case
ReceiveCoreByLinkingCleanupReason
.Timer:
1352
goto case
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError;
1353
case
ReceiveCoreByLinkingCleanupReason
.SourceProtocolError:
1354
case
ReceiveCoreByLinkingCleanupReason
.ErrorDuringCleanup:
1383
TryCleanupAndComplete(
ReceiveCoreByLinkingCleanupReason
.SourceCompletion);