/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Base/ |
H A D | DataflowBlockOptions.cs | 92 BoundedCapacity = this.BoundedCapacity, in DefaultOrClone() 144 public Int32 BoundedCapacity property in System.Threading.Tasks.Dataflow.DataflowBlockOptions 241 BoundedCapacity = this.BoundedCapacity, in DefaultOrClone() 368 BoundedCapacity = this.BoundedCapacity, in DefaultOrClone()
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Base/ |
H A D | DataflowBlockOptions.cs | 99 BoundedCapacity = this.BoundedCapacity, in DefaultOrClone() 152 public Int32 BoundedCapacity property in System.Threading.Tasks.Dataflow.DataflowBlockOptions 270 BoundedCapacity = this.BoundedCapacity, in DefaultOrClone() 402 BoundedCapacity = this.BoundedCapacity, in DefaultOrClone()
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/System.Threading.Tasks.Dataflow/ |
H A D | BoundedCapacityTest.cs | 37 new BufferBlock<int> (new DataflowBlockOptions { BoundedCapacity = 1 }); in PostTest() 49 new BufferBlock<int> (new DataflowBlockOptions { BoundedCapacity = 1 }); in OfferMessageTest() 69 new BufferBlock<int> (new DataflowBlockOptions { BoundedCapacity = 1 }); in OfferMessageWithSourceTest() 99 new ExecutionDataflowBlockOptions { BoundedCapacity = 1 }); in TransformManyBlockTest() 129 { BoundedCapacity = 2, TaskScheduler = scheduler }); in TransformFullTest() 152 { BoundedCapacity = 2, TaskScheduler = scheduler }); in TransformManyOverfullTest() 173 { BoundedCapacity = 100, TaskScheduler = scheduler }); in TransformManyOverfullTest2() 198 new DataflowBlockOptions { BoundedCapacity = 1, TaskScheduler = scheduler }); in MultipleOffersTest() 227 new DataflowBlockOptions { BoundedCapacity = 1, TaskScheduler = scheduler }); in DontConsumePostponedAfterCompleteTest()
|
H A D | BatchBlockTest.cs | 166 { Greedy = false, BoundedCapacity = 2, TaskScheduler = scheduler }); in NonGreedyBatchWithBoundedCapacityTest() 206 { Greedy = true, BoundedCapacity = 3, TaskScheduler = scheduler }); in GreedyBatchWithBoundedCapacityTest() 232 { Greedy = false, BoundedCapacity = 3, TaskScheduler = scheduler }); in NonGreedyBatchWithBoundedCapacityTriggerTest() 270 { Greedy = false, BoundedCapacity = 3, TaskScheduler = scheduler }); in NonGreedyBatchWithBoundedCapacityTriggerTest2()
|
H A D | DataflowBlockTest.cs | 162 new BufferBlock<int> (new DataflowBlockOptions { BoundedCapacity = 1 }); in SendAsyncPostponedAcceptedTest() 180 new BufferBlock<int> (new DataflowBlockOptions { BoundedCapacity = 1 }); in SendAsyncPostponedDeclinedTest() 261 new DataflowBlockOptions { BoundedCapacity = 1, TaskScheduler = scheduler }); in LinkToPredicatePostponed()
|
H A D | BroadcastBlockTest.cs | 94 new DataflowBlockOptions { BoundedCapacity = 1 }); in PostponedTest() 220 new DataflowBlockOptions { TaskScheduler = scheduler, BoundedCapacity = 1 }); in BoundedQueuedTest() 232 new DataflowBlockOptions { TaskScheduler = scheduler, BoundedCapacity = 1 }); in BoundedPostponedTest()
|
H A D | InvalidArgumentsTest.cs | 57 new GroupingDataflowBlockOptions { BoundedCapacity = 1 })); in BatchBlockTest() 70 new GroupingDataflowBlockOptions { BoundedCapacity = 1 })); in BatchedJoinBlockTest() 86 new GroupingDataflowBlockOptions { BoundedCapacity = 1 })); in BatchedJoinBlock3Test() 434 AssertEx.Throws<ArgumentOutOfRangeException>(() => options.BoundedCapacity = -2); in DataflowBlockOptionsTest()
|
H A D | OptionsTest.cs | 282 new DataflowBlockOptions { TaskScheduler = scheduler, BoundedCapacity = 1 }); in MaxMessagesPostponedTest() 316 new DataflowBlockOptions { TaskScheduler = scheduler, BoundedCapacity = 1 }); in MaxMessagesPostponedUnconsumedTest() 353 new DataflowBlockOptions { TaskScheduler = scheduler, BoundedCapacity = 1 }); in MaxMessagesBroadcastTest()
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/ |
H A D | DataflowBlockOptionsTests.cs | 17 …rt.Throws<ArgumentOutOfRangeException>(() => { new DataflowBlockOptions().BoundedCapacity = -2; }); in TestInvalidArguments() 18 …ert.Throws<ArgumentOutOfRangeException>(() => { new DataflowBlockOptions().BoundedCapacity = 0; }); in TestInvalidArguments() 34 Assert.Equal(expected: DataflowBlockOptions.Unbounded, actual: dbo.BoundedCapacity); in TestDefaultValues() 63 SetAndTest(dbo, (o,v) => o.BoundedCapacity = v, o => o.BoundedCapacity, value); in TestPropertyRoundtripping()
|
H A D | BufferBlockTests.cs | 50 () => new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 10 }), in TestOfferMessage() 51 …() => new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 10, MaxMessagesPerTask = 1… in TestOfferMessage() 77 … var bb = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = boundedCapacity }); in TestPost() 168 var bb = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 1 }); in TestBoundedReceives() 218 … var b = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = boundedCapacity }); in TestCircularLinking() 238 BoundedCapacity = boundedCapacity, in TestProducerConsumer() 267 … var b = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = boundedCapacity }); in TestMessagePostponement() 454 …Block<int>(new DataflowBlockOptions { CancellationToken = cts.Token, BoundedCapacity = boundedCapa… in TestFaultingAndCancellation() 510 var bb = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 1 }); in TestFaultySource() 530 var target1 = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 1 }); in TestMultiplePostponesFromSameSource() [all …]
|
H A D | ActionBlockTests.cs | 34 … () => new ActionBlock<int>(i => { }, new ExecutionDataflowBlockOptions { BoundedCapacity = 10 }), in TestOfferMessage() 35 …> new ActionBlock<int>(i => { }, new ExecutionDataflowBlockOptions { BoundedCapacity = 10, MaxMess… in TestOfferMessage() 59 …new ExecutionDataflowBlockOptions { BoundedCapacity = bounded ? 1 : -1 }); // test greedy and then… in TestPost() 110 new ExecutionDataflowBlockOptions { BoundedCapacity = 1 }, in TestBasicMessageProcessing() 116 BoundedCapacity = 2, in TestBasicMessageProcessing() 145 if (option.BoundedCapacity == DataflowBlockOptions.Unbounded) in TestBasicMessageProcessing() 264 var options = new ExecutionDataflowBlockOptions { BoundedCapacity = 1 }; in TestNonGreedy() 447 var options = new ExecutionDataflowBlockOptions { BoundedCapacity = 1 }; in TestReleasingOfPostponedMessages()
|
H A D | TransformManyBlockTests.cs | 69 …int>(DataflowTestHelpers.ToEnumerable, new ExecutionDataflowBlockOptions { BoundedCapacity = 10 }), in TestOfferMessage() 70 …lowTestHelpers.ToEnumerable(i)), new ExecutionDataflowBlockOptions { BoundedCapacity = 10, MaxMess… in TestOfferMessage() 91 …ataflowTestHelpers.ToEnumerable, new ExecutionDataflowBlockOptions { BoundedCapacity = bounded ? 1… in TestPost() 92 …lowTestHelpers.ToEnumerable(i)), new ExecutionDataflowBlockOptions { BoundedCapacity = bounded ? 1… in TestPost() 200 BoundedCapacity = boundedCapacity, in TestProducerConsumer() 239 … var options = new ExecutionDataflowBlockOptions { BoundedCapacity = boundedCapacity }; in TestMessagePostponement() 579 …}, new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = dop, BoundedCapacity = boundedCapa… in TestYieldingNoResults() 604 …var dbo = new ExecutionDataflowBlockOptions { BoundedCapacity = boundedCapacity, MaxDegreeOfParall… in TestArrayListReusePossibleForDop1()
|
H A D | DebugAttributeTests.cs | 22 var dboNoBuffering = new DataflowBlockOptions() { BoundedCapacity = 1 }; in TestDebuggerDisplaysAndTypeProxies() 25 …ng = new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 2, BoundedCapacity = 1, Cancella… in TestDebuggerDisplaysAndTypeProxies() 49 …e, SendAsyncMessages(new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 10 }), 20)), in TestDebuggerDisplaysAndTypeProxies() 78 …ibutes.GetFieldValue(new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 10 }), "_so… in TestDebuggerDisplaysAndTypeProxies()
|
H A D | WriteOnceBlockTests.cs | 20 new WriteOnceBlock<int>(i => i, new DataflowBlockOptions { BoundedCapacity = 2 }), in TestCtor() 109 … () => new WriteOnceBlock<int>(i => i, new DataflowBlockOptions { BoundedCapacity = 10 }), in TestOfferMessage() 110 …() => new WriteOnceBlock<int>(i => i, new DataflowBlockOptions { BoundedCapacity = 10, MaxMessages… in TestOfferMessage() 148 …var wob = new WriteOnceBlock<int>(i => i, new DataflowBlockOptions { BoundedCapacity = boundedCapa… in TestPost()
|
H A D | TransformBlockTests.cs | 68 …> new TransformBlock<int, int>(i => i, new ExecutionDataflowBlockOptions { BoundedCapacity = 10 }), in TestOfferMessage() 69 …nt, int>(i => Task.Run(() => i), new ExecutionDataflowBlockOptions { BoundedCapacity = 10, MaxMess… in TestOfferMessage() 90 …TransformBlock<int, int>(i => i, new ExecutionDataflowBlockOptions { BoundedCapacity = bounded ? 1… in TestPost() 91 …nt, int>(i => Task.Run(() => i), new ExecutionDataflowBlockOptions { BoundedCapacity = bounded ? 1… in TestPost() 196 BoundedCapacity = boundedCapacity, in TestProducerConsumer() 230 … var options = new ExecutionDataflowBlockOptions { BoundedCapacity = boundedCapacity }; in TestMessagePostponement()
|
H A D | BroadcastBlockTests.cs | 245 … var bb = new BroadcastBlock<int>(null, new DataflowBlockOptions { BoundedCapacity = 1 }); in TestBounding() 262 …nt>(null, new GroupingDataflowBlockOptions { CancellationToken = cts.Token, BoundedCapacity = 2 }); in TestFaultingAndCancellation() 285 BoundedCapacity = 1, in TestFaultyScheduler()
|
H A D | BatchBlockTests.cs | 36 …Exception>(() => new BatchBlock<int>(2, new GroupingDataflowBlockOptions { BoundedCapacity = 1 })); in TestArgumentExceptions() 83 … var bb = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = boundedCapacity }); in TestPost() 175 … var bb = new BatchBlock<int>(1, new GroupingDataflowBlockOptions { BoundedCapacity = 1 }); in TestBoundedReceives() 237 BoundedCapacity = boundedCapacity, in TestProducerConsumer() 365 …var bb = new BatchBlock<int>(2, new GroupingDataflowBlockOptions { BoundedCapacity = boundedCapaci… in TestBoundedCapacityFromSends()
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Internal/ |
H A D | TargetCore.cs | 129 …if (_dataflowBlockOptions.BoundedCapacity != System.Threading.Tasks.Dataflow.DataflowBlockOptions.… in TargetCore() 131 …Debug.Assert(_dataflowBlockOptions.BoundedCapacity > 0, "Positive bounding count expected; should … in TargetCore() 132 … _boundingState = new BoundingStateWithPostponed<TInput>(_dataflowBlockOptions.BoundedCapacity); in TargetCore() 414 …bool shouldAttemptPostponedTransfer = _boundingState != null && _boundingState.BoundedCapacity > 1; in ProcessMessagesLoopCore() 627 _dataflowBlockOptions.BoundedCapacity != in TryConsumePostponedMessage()
|
H A D | Common.cs | 618 internal readonly int BoundedCapacity; field in System.Threading.Tasks.Dataflow.Internal.BoundingState 633 BoundedCapacity = boundedCapacity; in BoundingState() 637 internal bool CountIsLessThanBound { get { return CurrentCount < BoundedCapacity; } }
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Internal/ |
H A D | TargetCore.cs | 130 …if (_dataflowBlockOptions.BoundedCapacity != System.Threading.Tasks.Dataflow.DataflowBlockOptions.… in TargetCore() 132 …Debug.Assert(_dataflowBlockOptions.BoundedCapacity > 0, "Positive bounding count expected; should … in TargetCore() 133 … _boundingState = new BoundingStateWithPostponed<TInput>(_dataflowBlockOptions.BoundedCapacity); in TargetCore() 415 …bool shouldAttemptPostponedTransfer = _boundingState != null && _boundingState.BoundedCapacity > 1; in ProcessMessagesLoopCore() 628 _dataflowBlockOptions.BoundedCapacity != in TryConsumePostponedMessage()
|
H A D | Common.cs | 616 internal readonly int BoundedCapacity; field in System.Threading.Tasks.Dataflow.Internal.BoundingState 631 BoundedCapacity = boundedCapacity; in BoundingState() 635 internal bool CountIsLessThanBound { get { return CurrentCount < BoundedCapacity; } }
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Blocks/ |
H A D | BatchBlock.cs | 54 …if (dataflowBlockOptions.BoundedCapacity > 0 && dataflowBlockOptions.BoundedCapacity < batchSize) … in BatchBlock() 63 if (dataflowBlockOptions.BoundedCapacity > 0) in BatchBlock() 334 bool boundingEnabled = dataflowBlockOptions.BoundedCapacity > 0; in BatchBlockTargetCore() 336 … if (boundingEnabled) _boundingState = new BoundingState(dataflowBlockOptions.BoundedCapacity); in BatchBlockTargetCore() 510 … _dataflowBlockOptions.BoundedCapacity - _boundingState.CurrentCount :
|
H A D | BufferBlock.cs | 58 if (dataflowBlockOptions.BoundedCapacity > 0) in BufferBlock() 61 … _boundingState = new BoundingStateWithPostponedAndTask<T>(dataflowBlockOptions.BoundedCapacity); in BufferBlock()
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Blocks/ |
H A D | BatchBlock.cs | 53 …if (dataflowBlockOptions.BoundedCapacity > 0 && dataflowBlockOptions.BoundedCapacity < batchSize) … in BatchBlock() 62 if (dataflowBlockOptions.BoundedCapacity > 0) in BatchBlock() 333 bool boundingEnabled = dataflowBlockOptions.BoundedCapacity > 0; in BatchBlockTargetCore() 335 … if (boundingEnabled) _boundingState = new BoundingState(dataflowBlockOptions.BoundedCapacity); in BatchBlockTargetCore() 509 … _dataflowBlockOptions.BoundedCapacity - _boundingState.CurrentCount :
|
H A D | BufferBlock.cs | 57 if (dataflowBlockOptions.BoundedCapacity > 0) in BufferBlock() 60 … _boundingState = new BoundingStateWithPostponedAndTask<T>(dataflowBlockOptions.BoundedCapacity); in BufferBlock()
|