Home
last modified time | relevance | path

Searched refs:BufferBlock (Results 1 – 25 of 1945) sorted by relevance

12345678910>>...78

/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/
H A DBufferBlockTests.cs16 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 DDataflowBlockExtensionTests.cs370 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 DDebugAttributeTests.cs44 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 DChooseTest.cs38 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 DOutputAvailableTest.cs35 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 DDataflowBlockTest.cs40 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 DGreedyTest.cs38 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 DPropagateCompletionTest.cs35 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 DReceivingTest.cs38 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 Dbuffer.h101 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 Dbuffer.c126 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 Dbuffer_pool.hpp40 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 Dbuffer_pool.cpp40 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 Ddevice.hpp297 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 Dbuffer_pool.hpp40 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 Dbuffer_pool.cpp40 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 Ddevice.hpp297 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 Dbuffer_pool.hpp42 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 Dbuffer_pool.cpp47 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 DBufferBlock.cs26 [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 DBufferBlock.cs25 [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 DvktSSBOLayoutCase.hpp92 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 DGrBufferAllocPool.cpp88 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 DGrBufferAllocPool.cpp90 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 Dmojoshader_common.c624 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 …]

12345678910>>...78