/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/ |
H A D | BufferBlockTests.cs | 16 var block = new BufferBlock<int>(); in TestCtor() 41 new BufferBlock<int>()); in TestToString() 49 () => new BufferBlock<int>(), in TestOfferMessage() 96 var bb = new BufferBlock<int>(); in TestLinkToOptions() 290 var bb = new BufferBlock<int>(); in TestReserveReleaseConsume() 294 bb = new BufferBlock<int>(); in TestReserveReleaseConsume() 349 buffer = new BufferBlock<int>(); in TestCountZeroAtCompletion() 359 var bb = new BufferBlock<int>(); in TestCount() 380 … var network = DataflowTestHelpers.Chain<BufferBlock<int>, int>(4, () => new BufferBlock<int>()); in TestChainedSendReceive() 402 … var network = DataflowTestHelpers.Chain<BufferBlock<int>, int>(4, () => new BufferBlock<int>()); in TestSendAllThenReceive() [all …]
|
H A D | DataflowBlockExtensionTests.cs | 370 BufferBlock<int> b; in TestAsObservableAndAsObserver_AsObservableDoesntLeak() 382 new BufferBlock<int>(), in TestAsObservableAndAsObserver_BroadcastBackPressure() 384 new BufferBlock<int>() in TestAsObservableAndAsObserver_BroadcastBackPressure() 428 new BufferBlock<int>() in TestAsObservableAndAsObserver_BroadcastFaultyTarget() 1214 …ataflowBlock.Choose<int, int, int>(new BufferBlock<int>(), null, new BufferBlock<int>(), i => { },… in TestChoose_ArgumentValidation() 1216 …ataflowBlock.Choose<int, int, int>(new BufferBlock<int>(), i => { }, new BufferBlock<int>(), null,… in TestChoose_ArgumentValidation() 1218 …aflowBlock.Choose<int, int, int>(new BufferBlock<int>(), i => { }, new BufferBlock<int>(), i => { … in TestChoose_ArgumentValidation() 1220 …aflowBlock.Choose<int, int, int>(new BufferBlock<int>(), i => { }, new BufferBlock<int>(), i => { … in TestChoose_ArgumentValidation() 1297 var sources = new[] { new BufferBlock<int>(), new BufferBlock<int>() }; in TestChoose2_DataAlreadyAvailable() 1344 … var sources = new[] { new BufferBlock<int>(), new BufferBlock<int>(), new BufferBlock<int>() }; in TestChoose3_DataAlreadyAvailable() [all …]
|
H A D | DebugAttributeTests.cs | 44 Tuple.Create<bool,bool,object>(true, true, new BufferBlock<int>()), in TestDebuggerDisplaysAndTypeProxies() 45 …Tuple.Create<bool,bool,object>(true, true, new BufferBlock<int>(new DataflowBlockOptions() { NameF… in TestDebuggerDisplaysAndTypeProxies() 46 …Tuple.Create<bool,bool,object>(true, true, new BufferBlock<int>(new DataflowBlockOptions() { NameF… in TestDebuggerDisplaysAndTypeProxies() 48 Tuple.Create<bool,bool,object>(true, true, new BufferBlock<int>(dboBuffering)), in TestDebuggerDisplaysAndTypeProxies() 68 …object>(true, true, DataflowBlock.Encapsulate<int,int>(new BufferBlock<int>(),new BufferBlock<int>… in TestDebuggerDisplaysAndTypeProxies() 69 … Tuple.Create<bool,bool,object>(true, true, new BufferBlock<int>().AsObservable()), in TestDebuggerDisplaysAndTypeProxies() 77 …te<bool,bool,object>(true, false, DebuggerAttributes.GetFieldValue(new BufferBlock<int>(), "_sourc… in TestDebuggerDisplaysAndTypeProxies() 92 …Tuple.Create<bool,bool,object>(true, false, new BufferBlock<int>().LinkTo(new ActionBlock<int>(i =… in TestDebuggerDisplaysAndTypeProxies() 133 var bb = new BufferBlock<T>(); in CreateNopLinkSource() 142 var bb = new BufferBlock<T>(); in CreateFilteringSource() [all …]
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/System.Threading.Tasks.Dataflow/ |
H A D | ChooseTest.cs | 38 var source1 = new BufferBlock<int> (); in BasicTest() 39 var source2 = new BufferBlock<long> (); in BasicTest() 58 var source1 = new BufferBlock<int> (); in OnlyOneConsumedTest() 59 var source2 = new BufferBlock<long> (); in OnlyOneConsumedTest() 83 var source1 = new BufferBlock<int> (); in RaceTest() 84 var source2 = new BufferBlock<int> (); in RaceTest() 117 var source1 = new BufferBlock<int> (); in BlockCompletionTest() 136 var source1 = new BufferBlock<int> (); in CancellationTest() 159 var source2 = new BufferBlock<int> (); in ConsumeToAcceptTest() 178 var source1 = new BufferBlock<int> (); in ExceptionTest() [all …]
|
H A D | OutputAvailableTest.cs | 35 var source = new BufferBlock<int>(new DataflowBlockOptions{TaskScheduler = scheduler}); in ImmediateTest() 51 var source = new BufferBlock<int>(new DataflowBlockOptions()); in PostponedTest() 66 var source = new BufferBlock<int>(); in CompletedImmediateTest() 78 var source = new BufferBlock<int>(new DataflowBlockOptions()); in CompletedPostponedTest() 93 var source = new BufferBlock<int>(); in FaultedImmediateTest() 105 var source = new BufferBlock<int>(); in FaultedPostponedTest() 120 var source = new BufferBlock<int>(); in WithTargetTest() 121 var target = new BufferBlock<int>(); in WithTargetTest() 134 var source = new BufferBlock<int>(); in WithDecliningTargetTest() 135 var target = new BufferBlock<int>(); in WithDecliningTargetTest() [all …]
|
H A D | DataflowBlockTest.cs | 40 var block = new BufferBlock<int> (); in TryReceiveTest() 52 var block = new BufferBlock<int> (); in ReceiveTest() 60 var block = new BufferBlock<int> (); in ReceiveCompletedTest() 69 var block = new BufferBlock<int> (); in ReceiveTimeoutTest() 77 var block = new BufferBlock<int> (); in ReceiveCancelledTest() 140 var target = new BufferBlock<int> (); in SendAsyncAcceptedTest() 150 var target = new BufferBlock<int> (); in SendAsyncDeclinedTest() 198 var source = new BufferBlock<int> ( in LinkToPredicateTest() 227 var source = new BufferBlock<int> ( in LinkToPredicateMaxMessagesTest() 258 var source = new BufferBlock<int> ( in LinkToPredicatePostponed() [all …]
|
H A D | GreedyTest.cs | 38 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in GreedyJoinTest() 40 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in GreedyJoinTest() 68 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in GreedyJoin3Test() 70 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in GreedyJoin3Test() 72 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in GreedyJoin3Test() 103 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyJoinTest() 105 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyJoinTest() 135 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyJoin3Test() 137 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyJoin3Test() 139 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in NonGreedyJoin3Test() [all …]
|
H A D | PropagateCompletionTest.cs | 35 var source = new BufferBlock<int> (); in PropagateCompletionSimpleTest() 36 var target = new BufferBlock<int> (); in PropagateCompletionSimpleTest() 48 ISourceBlock<int> source = new BufferBlock<int> (); in PropagateFaultTest() 49 var target = new BufferBlock<int> (); in PropagateFaultTest() 69 var source = new BufferBlock<int> ( in PropagateCancellationTest() 71 var target = new BufferBlock<int> (); in PropagateCancellationTest() 97 var target = new BufferBlock<int> (); in PropagateCompletionAfterWaitTest() 118 var source = new BufferBlock<int>(); in PropagateCompletionLinkDisposeTest() 119 var target = new BufferBlock<int>(); in PropagateCompletionLinkDisposeTest()
|
H A D | ReceivingTest.cs | 38 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in PostponeTest() 57 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in PostponeTwoTargetsTest() 83 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in DecliningTest() 102 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in ConditionalDecliningTest() 124 var source = new BufferBlock<int> (); in TryReceiveWithPredicateTest() 143 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in ReserveTest() 173 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in ConsumeAfterReceiveTest() 203 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in FaultConsume() 299 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in ReserveFaultConsume() 347 new BufferBlock<int> (new DataflowBlockOptions { TaskScheduler = scheduler }); in PostAfterTimeout() [all …]
|
/dports/editors/hexer/hexer-1.0.3/ |
H A D | buffer.h | 101 typedef struct BufferBlock struct 103 struct BufferBlock *next_block; argument 111 BufferBlock; typedef 118 BufferBlock *first_block; 152 BufferBlock * 170 delete_buffer_block(BufferBlock *block); 191 BufferBlock *
|
H A D | buffer.c | 126 BufferBlock * 131 new_block = (BufferBlock *)malloc_fatal(sizeof(BufferBlock)); in new_buffer_block() 172 BufferBlock *i, *j; in delete_buffer() 183 BufferBlock * 186 BufferBlock *i; in find_block() 236 BufferBlock *block; in b_read() 259 BufferBlock *block; in b_write() 298 BufferBlock *block; in b_count_lines() 439 BufferBlock *i, *j; in b_clear() 500 BufferBlock *i; in b_write_buffer_to_file() [all …]
|
/dports/games/kodi-addon-game.libretro.beetle-psx/game.libretro.beetle-psx-0.9.44.22-Matrix/depends/common/beetle-psx/parallel-psx/vulkan/ |
H A D | buffer_pool.hpp | 40 struct BufferBlock struct 42 ~BufferBlock(); 76 BufferBlock request_block(VkDeviceSize minimum_size); 77 void recycle_block(BufferBlock &&block); 84 std::vector<BufferBlock> blocks; 85 BufferBlock allocate_block(VkDeviceSize size);
|
H A D | buffer_pool.cpp | 40 BufferBlock::~BufferBlock() in ~BufferBlock() 49 BufferBlock BufferPool::allocate_block(VkDeviceSize size) in allocate_block() 54 BufferBlock block; in allocate_block() 89 BufferBlock BufferPool::request_block(VkDeviceSize minimum_size) in request_block() 106 void BufferPool::recycle_block(BufferBlock &&block) in recycle_block()
|
H A D | device.hpp | 297 void request_vertex_block(BufferBlock &block, VkDeviceSize size); 298 void request_index_block(BufferBlock &block, VkDeviceSize size); 299 void request_uniform_block(BufferBlock &block, VkDeviceSize size); 300 void request_staging_block(BufferBlock &block, VkDeviceSize size); 358 std::vector<BufferBlock> vbo_blocks; 359 std::vector<BufferBlock> ibo_blocks; 360 std::vector<BufferBlock> ubo_blocks; 361 std::vector<BufferBlock> staging_blocks; 405 std::vector<BufferBlock> vbo; 406 std::vector<BufferBlock> ibo; [all …]
|
/dports/games/libretro-beetle_psx/beetle-psx-libretro-3ec155d/parallel-psx/vulkan/ |
H A D | buffer_pool.hpp | 40 struct BufferBlock struct 42 ~BufferBlock(); 76 BufferBlock request_block(VkDeviceSize minimum_size); 77 void recycle_block(BufferBlock &&block); 84 std::vector<BufferBlock> blocks; 85 BufferBlock allocate_block(VkDeviceSize size);
|
H A D | buffer_pool.cpp | 40 BufferBlock::~BufferBlock() in ~BufferBlock() 49 BufferBlock BufferPool::allocate_block(VkDeviceSize size) in allocate_block() 54 BufferBlock block; in allocate_block() 89 BufferBlock BufferPool::request_block(VkDeviceSize minimum_size) in request_block() 106 void BufferPool::recycle_block(BufferBlock &&block) in recycle_block()
|
H A D | device.hpp | 297 void request_vertex_block(BufferBlock &block, VkDeviceSize size); 298 void request_index_block(BufferBlock &block, VkDeviceSize size); 299 void request_uniform_block(BufferBlock &block, VkDeviceSize size); 300 void request_staging_block(BufferBlock &block, VkDeviceSize size); 358 std::vector<BufferBlock> vbo_blocks; 359 std::vector<BufferBlock> ibo_blocks; 360 std::vector<BufferBlock> ubo_blocks; 361 std::vector<BufferBlock> staging_blocks; 405 std::vector<BufferBlock> vbo; 406 std::vector<BufferBlock> ibo; [all …]
|
/dports/games/libretro-paralleln64/parallel-n64-6e26fbb/mupen64plus-video-paraLLEl/parallel-rdp/vulkan/ |
H A D | buffer_pool.hpp | 42 struct BufferBlock struct 44 ~BufferBlock(); 87 BufferBlock request_block(VkDeviceSize minimum_size); 88 void recycle_block(BufferBlock &&block); 96 std::vector<BufferBlock> blocks; 97 BufferBlock allocate_block(VkDeviceSize size);
|
H A D | buffer_pool.cpp | 47 BufferBlock::~BufferBlock() in ~BufferBlock() 56 BufferBlock BufferPool::allocate_block(VkDeviceSize size) in allocate_block() 64 BufferBlock block; in allocate_block() 100 BufferBlock BufferPool::request_block(VkDeviceSize minimum_size) in request_block() 117 void BufferPool::recycle_block(BufferBlock &&block) in recycle_block()
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Blocks/ |
H A D | BufferBlock.cs | 26 [DebuggerTypeProxy(typeof(BufferBlock<>.DebugView))] 27 …public sealed class BufferBlock<T> : IPropagatorBlock<T, T>, IReceivableSourceBlock<T>, IDebuggerD… class 41 public BufferBlock() : in BufferBlock() method in System.Threading.Tasks.Dataflow.BufferBlock 48 public BufferBlock(DataflowBlockOptions dataflowBlockOptions) in BufferBlock() method in System.Threading.Tasks.Dataflow.BufferBlock 60 … onItemsRemoved = (owningSource, count) => ((BufferBlock<T>)owningSource).OnItemsRemoved(count); in BufferBlock() 66 owningSource => ((BufferBlock<T>)owningSource).Complete(), in BufferBlock() 75 var thisBlock = ((BufferBlock<T>)state) as IDataflowBlock; in BufferBlock() 263 new Task(state => ((BufferBlock<T>)state).ConsumeMessagesLoopCore(), this, in ConsumeAsyncIfNecessary() 398 var thisBufferBlock = (BufferBlock<T>)state; in CompleteTargetIfPossible() 452 private readonly BufferBlock<T> _bufferBlock; [all …]
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Blocks/ |
H A D | BufferBlock.cs | 25 [DebuggerTypeProxy(typeof(BufferBlock<>.DebugView))] 26 …public sealed class BufferBlock<T> : IPropagatorBlock<T, T>, IReceivableSourceBlock<T>, IDebuggerD… class 40 public BufferBlock() : in BufferBlock() method in System.Threading.Tasks.Dataflow.BufferBlock 47 public BufferBlock(DataflowBlockOptions dataflowBlockOptions) in BufferBlock() method in System.Threading.Tasks.Dataflow.BufferBlock 59 … onItemsRemoved = (owningSource, count) => ((BufferBlock<T>)owningSource).OnItemsRemoved(count); in BufferBlock() 65 owningSource => ((BufferBlock<T>)owningSource).Complete(), in BufferBlock() 74 var thisBlock = ((BufferBlock<T>)state) as IDataflowBlock; in BufferBlock() 262 new Task(state => ((BufferBlock<T>)state).ConsumeMessagesLoopCore(), this, in ConsumeAsyncIfNecessary() 396 var thisBufferBlock = (BufferBlock<T>)state; in CompleteTargetIfPossible() 450 private readonly BufferBlock<T> _bufferBlock; [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/angle/third_party/VK-GL-CTS/src/external/vulkancts/modules/vulkan/ssbo/ |
H A D | vktSSBOLayoutCase.hpp | 92 class BufferBlock class 98 BufferBlock (const char* blockName); 138 BufferBlock& allocBlock (const char* name); 141 const BufferBlock& getBlock (int ndx) const { return *m_bufferBlocks[ndx]; } in getBlock() 142 BufferBlock& getBlock (int ndx) { return *m_bufferBlocks[ndx]; } in getBlock() 149 std::vector<BufferBlock*> m_bufferBlocks;
|
/dports/lang/spidermonkey60/firefox-60.9.0/gfx/skia/skia/src/gpu/ |
H A D | GrBufferAllocPool.cpp | 88 BufferBlock& block = fBlocks.back(); in unmap() 150 BufferBlock& back = fBlocks.back(); in makeSpace() 179 BufferBlock& back = fBlocks.back(); in makeSpace() 200 BufferBlock& back = fBlocks.back(); in makeSpaceAtLeast() 236 BufferBlock& back = fBlocks.back(); in makeSpaceAtLeast() 251 BufferBlock& block = fBlocks.back(); in putBack() 280 BufferBlock& block = fBlocks.push_back(); in createBlock() 291 BufferBlock& prev = fBlocks.fromBack(1); in createBlock() 326 BufferBlock& block = fBlocks.back(); in destroyBlock() 349 void GrBufferAllocPool::flushCpuData(const BufferBlock& block, size_t flushSize) { in flushCpuData()
|
/dports/www/firefox-legacy/firefox-52.8.0esr/gfx/skia/skia/src/gpu/ |
H A D | GrBufferAllocPool.cpp | 90 BufferBlock& block = fBlocks.back(); 152 BufferBlock& back = fBlocks.back(); 181 BufferBlock& back = fBlocks.back(); 195 BufferBlock& block = fBlocks.back(); 224 BufferBlock& block = fBlocks.push_back(); 235 BufferBlock& prev = fBlocks.fromBack(1); 270 BufferBlock& block = fBlocks.back(); 293 void GrBufferAllocPool::flushCpuData(const BufferBlock& block, size_t flushSize) {
|
/dports/graphics/urho3d/Urho3D-1.7.1/Source/ThirdParty/MojoShader/ |
H A D | mojoshader_common.c | 624 typedef struct BufferBlock struct 628 struct BufferBlock *next; argument 629 } BufferBlock; typedef 634 BufferBlock *head; 635 BufferBlock *tail; 683 BufferBlock *item = (BufferBlock *) buffer->m(malloc_len, buffer->d); in buffer_reserve() 733 BufferBlock *item = (BufferBlock *) buffer->m(malloc_len, buffer->d); in buffer_append() 796 BufferBlock *item = buffer->head; in buffer_empty() 799 BufferBlock *next = item->next; in buffer_empty() 812 BufferBlock *item = buffer->head; in buffer_flatten() [all …]
|