| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/memcache/unit/ |
| H A D | test_workqueue.c | 129 int total_consumed = 0; in run_test() local
146 total_consumed += ((struct threadreturn *) ret)->nrecv; in run_test()
151 return (total_consumed == params->iterations); in run_test()
|
| /dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/boost/boost/asio/detail/ |
| H A D | consuming_buffers.hpp | 147 std::size_t total_consumed() const in total_consumed() function in boost::asio::detail::consuming_buffers
192 std::size_t total_consumed() const in total_consumed() function in boost::asio::detail::consuming_single_buffer
313 std::size_t total_consumed() const in total_consumed() function in boost::asio::detail::consuming_buffers
365 std::size_t total_consumed() const in total_consumed() function in boost::asio::detail::consuming_buffers
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/memcache/unit/ |
| H A D | test_workqueue.cc | 135 int total_consumed = 0; in run_test() local
152 total_consumed += ((struct threadreturn *) ret)->nrecv; in run_test()
157 return (total_consumed == params->iterations); in run_test()
|
| /dports/science/py-scipy/scipy-1.7.1/scipy/_lib/boost/boost/asio/impl/ |
| H A D | write_at.hpp | 55 completion_condition(ec, tmp.total_consumed()))) in write_at_buffer_sequence()
57 tmp.consume(d.write_some_at(offset + tmp.total_consumed(), in write_at_buffer_sequence()
63 return tmp.total_consumed(); in write_at_buffer_sequence()
212 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
218 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
225 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
228 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| H A D | read_at.hpp | 57 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
59 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
65 return tmp.total_consumed(); in read_at_buffer_sequence()
227 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
233 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
240 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
243 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/audio/carla/Carla-2.4.1/source/modules/hylia/link/asio/impl/ |
| H A D | read_at.hpp | 55 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
57 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
63 return tmp.total_consumed();; in read_at_buffer_sequence()
225 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
229 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
235 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
238 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/math/stanmath/math-4.2.0/lib/boost_1.75.0/boost/asio/impl/ |
| H A D | write_at.hpp | 55 completion_condition(ec, tmp.total_consumed()))) in write_at_buffer_sequence()
57 tmp.consume(d.write_some_at(offset + tmp.total_consumed(), in write_at_buffer_sequence()
63 return tmp.total_consumed(); in write_at_buffer_sequence()
212 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
218 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
225 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
228 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/www/restbed/restbed-4.8/dependency/asio/asio/include/asio/impl/ |
| H A D | write_at.hpp | 54 completion_condition(ec, tmp.total_consumed()))) in write_at_buffer_sequence()
56 tmp.consume(d.write_some_at(offset + tmp.total_consumed(), in write_at_buffer_sequence()
62 return tmp.total_consumed(); in write_at_buffer_sequence()
211 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
217 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
224 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
227 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| H A D | read_at.hpp | 56 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
58 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
64 return tmp.total_consumed(); in read_at_buffer_sequence()
226 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
232 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
239 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
242 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/emulators/citra-qt5/citra-ac98458e0/externals/boost/boost/asio/impl/ |
| H A D | read_at.hpp | 56 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
58 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
64 return tmp.total_consumed();; in read_at_buffer_sequence()
226 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
230 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
236 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
239 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/emulators/citra/citra-ac98458e0/externals/boost/boost/asio/impl/ |
| H A D | read_at.hpp | 56 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
58 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
64 return tmp.total_consumed();; in read_at_buffer_sequence()
226 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
230 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
236 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
239 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/emulators/mess/mame-mame0226/3rdparty/asio/include/asio/impl/ |
| H A D | read_at.hpp | 54 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
56 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
62 return tmp.total_consumed();; in read_at_buffer_sequence()
221 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
225 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
231 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
234 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/emulators/mame/mame-mame0226/3rdparty/asio/include/asio/impl/ |
| H A D | read_at.hpp | 54 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
56 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
62 return tmp.total_consumed();; in read_at_buffer_sequence()
221 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
225 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
231 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
234 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/games/devilutionX/devilutionX-1.2.1/3rdParty/asio/include/asio/impl/ |
| H A D | read_at.hpp | 54 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
56 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
62 return tmp.total_consumed();; in read_at_buffer_sequence()
221 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
225 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
231 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
234 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/math/py-pystan/pystan-2.19.0.0/pystan/stan/lib/stan_math/lib/boost_1.69.0/boost/asio/impl/ |
| H A D | read_at.hpp | 55 completion_condition(ec, tmp.total_consumed())))
57 tmp.consume(d.read_some_at(offset + tmp.total_consumed(),
63 return tmp.total_consumed();;
222 max_size = this->check_for_completion(ec, buffers_.total_consumed());
226 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size),
232 max_size = this->check_for_completion(ec, buffers_.total_consumed());
235 handler_(ec, buffers_.total_consumed());
|
| /dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/boost/boost/asio/impl/ |
| H A D | read_at.hpp | 55 completion_condition(ec, tmp.total_consumed())))
57 tmp.consume(d.read_some_at(offset + tmp.total_consumed(),
63 return tmp.total_consumed();;
222 max_size = this->check_for_completion(ec, buffers_.total_consumed());
226 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size),
232 max_size = this->check_for_completion(ec, buffers_.total_consumed());
235 handler_(ec, buffers_.total_consumed());
|
| /dports/devel/hyperscan/boost_1_75_0/boost/asio/impl/ |
| H A D | write_at.hpp | 55 completion_condition(ec, tmp.total_consumed()))) in write_at_buffer_sequence()
57 tmp.consume(d.write_some_at(offset + tmp.total_consumed(), in write_at_buffer_sequence()
63 return tmp.total_consumed(); in write_at_buffer_sequence()
212 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
218 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
225 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
228 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| H A D | read_at.hpp | 57 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
59 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
65 return tmp.total_consumed(); in read_at_buffer_sequence()
227 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
233 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
240 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
243 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/multimedia/obs-websocket/obs-websocket-4.8.0/deps/asio/asio/include/asio/impl/ |
| H A D | read_at.hpp | 54 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
56 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
62 return tmp.total_consumed();; in read_at_buffer_sequence()
221 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
225 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
231 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
234 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/third_party/asio-master/asio/include/asio/impl/ |
| H A D | read_at.hpp | 54 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
56 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
62 return tmp.total_consumed();; in read_at_buffer_sequence()
221 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
225 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
231 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
234 handler_(ec, buffers_.total_consumed()); in operator ()()
|
| /dports/www/firefox-esr/firefox-91.8.0/testing/web-platform/tests/tools/third_party/hyper/hyper/packages/hpack/ |
| H A D | hpack.py | 600 total_consumed = 0
624 total_consumed = consumed
636 total_consumed = consumed + length + 1 # Since we moved forward 1.
648 total_consumed += length + consumed
658 total_consumed,
662 return header, total_consumed
|
| /dports/www/firefox/firefox-99.0/testing/web-platform/tests/tools/third_party/hyper/hyper/packages/hpack/ |
| H A D | hpack.py | 600 total_consumed = 0
624 total_consumed = consumed
636 total_consumed = consumed + length + 1 # Since we moved forward 1.
648 total_consumed += length + consumed
658 total_consumed,
662 return header, total_consumed
|
| /dports/mail/thunderbird/thunderbird-91.8.0/testing/web-platform/tests/tools/third_party/hyper/hyper/packages/hpack/ |
| H A D | hpack.py | 600 total_consumed = 0
624 total_consumed = consumed
636 total_consumed = consumed + length + 1 # Since we moved forward 1.
648 total_consumed += length + consumed
658 total_consumed,
662 return header, total_consumed
|
| /dports/lang/spidermonkey78/firefox-78.9.0/testing/web-platform/tests/tools/third_party/hyper/hyper/packages/hpack/ |
| H A D | hpack.py | 600 total_consumed = 0
624 total_consumed = consumed
636 total_consumed = consumed + length + 1 # Since we moved forward 1.
648 total_consumed += length + consumed
658 total_consumed,
662 return header, total_consumed
|
| /dports/devel/R-cran-BH/BH/inst/include/boost/asio/impl/ |
| H A D | read_at.hpp | 57 completion_condition(ec, tmp.total_consumed()))) in read_at_buffer_sequence()
59 tmp.consume(d.read_some_at(offset + tmp.total_consumed(), in read_at_buffer_sequence()
65 return tmp.total_consumed(); in read_at_buffer_sequence()
233 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
239 offset_ + buffers_.total_consumed(), buffers_.prepare(max_size), in operator ()()
246 max_size = this->check_for_completion(ec, buffers_.total_consumed()); in operator ()()
258 static_cast<const std::size_t&>(buffers_.total_consumed())); in operator ()()
|