Home
last modified time | relevance | path

Searched refs:new_round (Results 1 – 25 of 29) sorted by relevance

12

/dports/devel/caf/actor-framework-0.18.5/libcaf_core/test/intrusive/
H A Ddrr_cached_queue.cpp80 CAF_TEST(new_round) { in CAF_TEST() argument
99 auto round_result = queue.new_round(3, f); in CAF_TEST()
104 round_result = queue.new_round(4, g); in CAF_TEST()
120 CAF_CHECK_EQUAL(queue.new_round(10, f), make_new_round_result(0, false)); in CAF_TEST()
123 CAF_CHECK_EQUAL(queue.new_round(10, f), make_new_round_result(0, false)); in CAF_TEST()
126 CAF_CHECK_EQUAL(queue.new_round(10, f), make_new_round_result(1, false)); in CAF_TEST()
130 CAF_CHECK_EQUAL(queue.new_round(10, f), make_new_round_result(1, false)); in CAF_TEST()
134 CAF_CHECK_EQUAL(queue.new_round(10, f), make_new_round_result(1, false)); in CAF_TEST()
187 auto round_result = queue.new_round(1000, h); in CAF_TEST()
H A Ddrr_queue.cpp94 CAF_TEST(new_round) { in CAF_TEST() argument
102 auto round_result = queue.new_round(7, f); in CAF_TEST()
107 round_result = queue.new_round(8, f); in CAF_TEST()
112 round_result = queue.new_round(1000, f); in CAF_TEST()
117 round_result = queue.new_round(1000, f); in CAF_TEST()
H A Dwdrr_fixed_multiplexed_queue.cpp116 queue.new_round(quantum, f); in fetch()
133 CAF_TEST(new_round) { in CAF_TEST() argument
137 auto round_result = queue.new_round(2, f); in CAF_TEST()
143 round_result = queue.new_round(1, f); in CAF_TEST()
149 round_result = queue.new_round(1000, f); in CAF_TEST()
H A Dfifo_inbox.cpp72 inbox.new_round(1000, f); in fetch()
83 inbox.queue().new_round(1000, f); in close_and_fetch()
H A Dwdrr_dynamic_multiplexed_queue.cpp125 queue.new_round(quantum, f); in fetch()
149 CAF_TEST(new_round) { in CAF_TEST() argument
/dports/devel/caf/actor-framework-0.18.5/libcaf_core/caf/intrusive/
H A Ddrr_queue.hpp68 auto res = new_round(0, f); in consume()
82 new_round_result new_round(deficit_type quantum, F& consumer) { in new_round() function in caf::intrusive::drr_queue
H A Dfifo_inbox.hpp154 new_round_result new_round(deficit_type quantum, F& consumer) { in new_round() function in caf::intrusive::fifo_inbox
156 return queue_.new_round(quantum, consumer); in new_round()
H A Ddrr_cached_queue.hpp165 return new_round(0, f).consumed_items > 0; in consume()
170 new_round_result new_round(deficit_type quantum, F& consumer) noexcept( in new_round() function in caf::intrusive::drr_cached_queue
H A Dwdrr_dynamic_multiplexed_queue.hpp100 new_round_result new_round(deficit_type quantum, F& f) { in new_round() function in caf::intrusive::wdrr_dynamic_multiplexed_queue
108 auto res = q.new_round(policy_.quantum(q, quantum), g); in new_round()
H A Dwdrr_fixed_multiplexed_queue.hpp75 new_round_result new_round(deficit_type quantum, F& f) { in new_round() function in caf::intrusive::wdrr_fixed_multiplexed_queue
189 auto res = q.new_round(policy_.quantum(q, quantum), g); in new_round_recursion()
/dports/math/spot/spot-2.10.2/bin/
H A Dcommon_trans.hh80 void new_round(unsigned serial) in new_round() function
98 void new_round(spot::const_twa_graph_ptr aut, unsigned serial) in new_round() function
H A Dcommon_trans.cc422 filename_formula.new_round(serial); in round_formula()
460 filename_automaton.new_round(aut, serial); in round_automaton()
/dports/math/py-spot/spot-2.10.2/bin/
H A Dcommon_trans.hh80 void new_round(unsigned serial) in new_round() function
98 void new_round(spot::const_twa_graph_ptr aut, unsigned serial) in new_round() function
H A Dcommon_trans.cc422 filename_formula.new_round(serial); in round_formula()
460 filename_automaton.new_round(aut, serial); in round_automaton()
/dports/devel/caf/actor-framework-0.18.5/libcaf_core/src/
H A Dblocking_actor.cpp317 mailbox_.new_round(3, f); in receive_impl()
383 auto dropped = mailbox_.queue().new_round(1000, bounce).consumed_items; in cleanup()
389 dropped = mailbox_.queue().new_round(1000, bounce).consumed_items; in cleanup()
H A Dscheduled_actor.cpp239 auto dropped = mailbox_.queue().new_round(1000, bounce).consumed_items; in cleanup()
245 dropped = mailbox_.queue().new_round(1000, bounce).consumed_items; in cleanup()
385 get_urgent_queue().new_round(quantum * 3, handle_async); in resume()
386 get_normal_queue().new_round(quantum, handle_async); in resume()
390 get_upstream_queue().new_round(tts, handle_umsg); in resume()
399 if (get_downstream_queue().new_round(quantum, handle_dmsg).consumed_items in resume()
411 && get_downstream_queue().new_round(0, handle_dmsg).consumed_items > 0); in resume()
/dports/devel/caf/actor-framework-0.18.5/libcaf_core/test/policy/
H A Dcategorized.cpp80 mbox.new_round(1000, f); in CAF_TEST_FIXTURE_SCOPE()
/dports/games/3omns/3omns-0.2/src/
H A Dmain.c348 static void new_round(struct round *restrict round) { in new_round() function
383 new_round(&round); in main()
/dports/shells/ion/ion-a8872014dbce730ccd00aaa722397dc394a52bf4/cargo-crates/piston2d-graphics-0.32.0/src/
H A Dline.rs40 pub fn new_round(color: Color, radius: Radius) -> Line { in new_round() method
H A Drectangle.rs102 pub fn new_round(color: Color, round_radius: Radius) -> Rectangle { in new_round() method
/dports/games/moonlander/moon-lander/
H A Dmoon_lander.c1015 void new_round(Game *game, int died_won) { in new_round() function
1904 new_round(&game, 0); in main()
1911 new_round(&game, 1); in main()
1918 new_round(&game, 1); in main()
1926 new_round(&game, 3); in main()
1933 new_round(&game, 3); in main()
/dports/games/legesmotus/legesmotus-0.4.0/client/
H A DClientNetwork.cpp160 m_controller.new_round(reader); in process_server_packet()
/dports/devel/caf/actor-framework-0.18.5/libcaf_core/test/
H A Dmock_streaming_classes.cpp491 bob.mbox.new_round(1, f); in CAF_TEST_FIXTURE_SCOPE()
492 alice.mbox.new_round(1, g); in CAF_TEST_FIXTURE_SCOPE()
H A Dnative_streaming_classes.cpp521 f.self->mbox.new_round(1, f); in loop()
541 f.self->mbox.new_round(1, f); in loop_until()
H A Dbroadcast_downstream_manager.cpp119 void new_round(int num, bool force_emit) { in new_round() function in __anon3f5618840111::entity
307 .new_round(CONCAT(amount, __LINE__), CONCAT(force, __LINE__)); \

12