Home
last modified time | relevance | path

Searched refs:BoundedCapacity (Results 1 – 25 of 70) sorted by relevance

123

/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Base/
H A DDataflowBlockOptions.cs92 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 DDataflowBlockOptions.cs99 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 DBoundedCapacityTest.cs37 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 DBatchBlockTest.cs166 { 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 DDataflowBlockTest.cs162 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 DBroadcastBlockTest.cs94 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 DInvalidArgumentsTest.cs57 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 DOptionsTest.cs282 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 DDataflowBlockOptionsTests.cs17 …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 DBufferBlockTests.cs50 () => 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 DActionBlockTests.cs34 … () => 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 DTransformManyBlockTests.cs69 …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 DDebugAttributeTests.cs22 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 DWriteOnceBlockTests.cs20 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 DTransformBlockTests.cs68 …> 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 DBroadcastBlockTests.cs245 … 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 DBatchBlockTests.cs36 …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 DTargetCore.cs129 …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 DCommon.cs618 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 DTargetCore.cs130 …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 DCommon.cs616 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 DBatchBlock.cs54 …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 DBufferBlock.cs58 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 DBatchBlock.cs53 …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 DBufferBlock.cs57 if (dataflowBlockOptions.BoundedCapacity > 0) in BufferBlock()
60 … _boundingState = new BoundingStateWithPostponedAndTask<T>(dataflowBlockOptions.BoundedCapacity); in BufferBlock()

123