| /third_party/boost/boost/coroutine2/detail/ |
| D | pull_coroutine.ipp | 34 cb_{ cb } {
40 return nullptr != cb_->other->t;
54 …cb_{ create_control_block< control_block >( std::forward< StackAllocator >( salloc), std::forward<…
55 if ( ! cb_->valid() ) {
56 cb_->deallocate();
57 cb_ = nullptr;
63 if ( nullptr != cb_) {
64 cb_->deallocate();
70 cb_{ nullptr } {
71 std::swap( cb_, other.cb_);
[all …]
|
| D | push_coroutine.ipp | 33 cb_{ cb } {
47 …cb_{ create_control_block< control_block >( std::forward< StackAllocator >( salloc), std::forward<…
52 if ( nullptr != cb_) {
53 cb_->deallocate();
59 cb_{ nullptr } {
60 std::swap( cb_, other.cb_);
66 cb_->resume( t);
73 cb_->resume( std::forward< T >( t) );
79 return nullptr != cb_ && cb_->valid();
85 return nullptr == cb_ || ! cb_->valid();
[all …]
|
| D | pull_coroutine.hpp | 35 control_block * cb_; member in boost::coroutines2::detail::pull_coroutine
58 std::swap( cb_, other.cb_); in operator =()
124 return c_->cb_->get(); in operator *()
128 return std::addressof( c_->cb_->get() ); in operator ->()
143 control_block * cb_; member in boost::coroutines2::detail::pull_coroutine
166 std::swap( cb_, other.cb_); in operator =()
232 return c_->cb_->get(); in operator *()
236 return std::addressof( c_->cb_->get() ); in operator ->()
251 control_block * cb_; member in boost::coroutines2::detail::pull_coroutine
272 std::swap( cb_, other.cb_); in operator =()
|
| D | push_coroutine.hpp | 35 control_block * cb_; member in boost::coroutines2::detail::push_coroutine
57 std::swap( cb_, other.cb_); in operator =()
120 control_block * cb_; member in boost::coroutines2::detail::push_coroutine
142 std::swap( cb_, other.cb_); in operator =()
203 control_block * cb_; member in boost::coroutines2::detail::push_coroutine
225 std::swap( cb_, other.cb_); in operator =()
|
| /third_party/grpc/test/core/util/ |
| D | test_lb_policies.cc | 118 : delegate_picker_(std::move(delegate_picker)), cb_(std::move(cb)) {} in Picker()
125 cb_(args_seen); in Pick()
132 TestPickArgsCallback cb_; member in grpc_core::__anond0099b2a0111::TestPickArgsLb::Picker
138 : parent_(std::move(parent)), cb_(std::move(cb)) {} in Helper()
148 state, absl::make_unique<Picker>(std::move(picker), cb_)); in UpdateState()
162 TestPickArgsCallback cb_; member in grpc_core::__anond0099b2a0111::TestPickArgsLb::Helper
174 : cb_(std::move(cb)) {} in TestPickArgsLbFactory()
178 return MakeOrphanable<TestPickArgsLb>(std::move(args), cb_); in CreateLoadBalancingPolicy()
189 TestPickArgsCallback cb_; member in grpc_core::__anond0099b2a0111::TestPickArgsLbFactory
224 : delegate_picker_(std::move(delegate_picker)), cb_(std::move(cb)) {} in Picker()
[all …]
|
| /third_party/node/deps/npm/lib/ |
| D | version.js | 31 function version (args, silent, cb_) { argument
32 if (typeof cb_ !== 'function') {
33 cb_ = silent
36 if (args.length > 1) return cb_(version.usage)
39 if (!args.length) return dump(data, cb_)
43 return cb_(er)
47 retrieveTagVersion(silent, data, cb_)
51 if (!newVersion) return cb_(version.usage)
52 persistVersion(newVersion, silent, data, cb_)
57 function retrieveTagVersion (silent, data, cb_) { argument
[all …]
|
| D | npm.js | 209 npm.load = function (cli, cb_) { argument
210 if (!cb_ && typeof cli === 'function') {
211 cb_ = cli
214 if (!cb_) cb_ = function () {}
216 loadListeners.push(cb_)
225 if (er) return cb_(er)
|
| D | unbuild.js | 28 return function (folder, cb_) { argument
30 cb_(er, path.relative(npm.root, folder))
|
| D | link.js | 136 function linkPkg (folder, cb_) { argument
144 return cb_(er, [[d && d._id, target, null, null]])
|
| /third_party/node/deps/npm/node_modules/slide/lib/ |
| D | async-map.js | 17 , cb_ = steps.pop()
18 if (typeof cb_ !== "function") throw new Error(
20 if (!list) return cb_(null, [])
27 if (!a) return cb_(null, [])
47 if (--a === 0) cb_.apply(null, [errState].concat(data))
|
| D | async-map-ordered.js | 13 function asyncMapOrdered (list, fn, cb_) { argument
14 if (typeof cb_ !== "function") throw new Error(
20 if (list === undefined || list === null) return cb_(null, [])
22 if (!list.length) return cb_(null, [])
51 cb_.apply(null, [errState].concat(flip(res, resCount, maxArgLen)))
|
| /third_party/boost/libs/beast/include/boost/beast/websocket/impl/ |
| D | write.hpp | 56 buffers_suffix<Buffers> cb_; member in boost::beast::websocket::stream::write_some_op
81 , cb_(bs) in write_some_op()
117 remain_ = buffer_bytes(cb_); in write_some_op()
133 remain_ = buffer_bytes(cb_); in write_some_op()
210 fh_.len = buffer_bytes(cb_); in operator ()()
228 cb_, in operator ()()
229 buffers_prefix(0, cb_) in operator ()()
264 buffers_suffix<Buffers> empty_cb(cb_); in operator ()()
272 buffers_prefix(clamp(fh_.len), cb_) in operator ()()
282 cb_.consume(n); in operator ()()
[all …]
|
| D | read.hpp | 55 buffers_suffix<MutableBufferSequence> cb_; member in boost::beast::websocket::stream::read_some_op
75 , cb_(bs) in read_some_op()
410 buffer_bytes(cb_)))
438 bytes_transferred = net::buffer_copy(cb_,
441 bytes_transferred, cb_);
463 BOOST_ASSERT(buffer_bytes(cb_) > 0);
465 clamp(impl.rd_remain), cb_)) > 0);
473 clamp(impl.rd_remain), cb_), std::move(*this));
480 bytes_transferred, cb_);
509 while(buffer_bytes(cb_) > 0)
[all …]
|
| /third_party/boost/boost/beast/websocket/impl/ |
| D | write.hpp | 56 buffers_suffix<Buffers> cb_; member in boost::beast::websocket::stream::write_some_op
81 , cb_(bs) in write_some_op()
117 remain_ = buffer_bytes(cb_); in write_some_op()
133 remain_ = buffer_bytes(cb_); in write_some_op()
210 fh_.len = buffer_bytes(cb_); in operator ()()
228 cb_, in operator ()()
229 buffers_prefix(0, cb_) in operator ()()
264 buffers_suffix<Buffers> empty_cb(cb_); in operator ()()
272 buffers_prefix(clamp(fh_.len), cb_) in operator ()()
282 cb_.consume(n); in operator ()()
[all …]
|
| D | read.hpp | 55 buffers_suffix<MutableBufferSequence> cb_; member in boost::beast::websocket::stream::read_some_op
75 , cb_(bs) in read_some_op()
410 buffer_bytes(cb_)))
438 bytes_transferred = net::buffer_copy(cb_,
441 bytes_transferred, cb_);
463 BOOST_ASSERT(buffer_bytes(cb_) > 0);
465 clamp(impl.rd_remain), cb_)) > 0);
473 clamp(impl.rd_remain), cb_), std::move(*this));
480 bytes_transferred, cb_);
509 while(buffer_bytes(cb_) > 0)
[all …]
|
| /third_party/grpc/test/core/iomgr/ |
| D | threadpool_test.cc | 88 : num_add_(num_add), cb_(cb), pool_(pool) { in WorkThread()
101 pool_->Add(cb_); in Run()
106 SimpleFunctorForAdd* cb_; member in WorkThread
|
| /third_party/boost/libs/coroutine2/example/ |
| D | parser.cpp | 47 Parser(std::istream& is_,std::function<void(char)> cb_) : in Parser() argument
48 next(), is(is_), cb(cb_) in Parser()
|
| /third_party/boost/libs/context/example/fiber/ |
| D | parser.cpp | 43 Parser(std::istream& is_,std::function<void(char)> cb_) : in Parser() argument
44 next(), is(is_), cb(cb_) in Parser()
|
| /third_party/boost/libs/context/example/callcc/ |
| D | parser.cpp | 43 Parser(std::istream& is_,std::function<void(char)> cb_) : in Parser() argument
44 next(), is(is_), cb(cb_) in Parser()
|
| /third_party/grpc/src/core/lib/security/credentials/external/ |
| D | url_external_account_credentials.cc | 125 cb_ = cb; in RetrieveSubjectToken()
203 auto cb = cb_; in FinishRetrieveSubjectToken()
204 cb_ = nullptr; in FinishRetrieveSubjectToken()
|
| D | url_external_account_credentials.h | 53 std::function<void(std::string, grpc_error*)> cb_ = nullptr; variable
|
| D | aws_external_account_credentials.cc | 133 cb_ = cb; in RetrieveSubjectToken()
403 auto cb = cb_; in FinishRetrieveSubjectToken()
404 cb_ = nullptr; in FinishRetrieveSubjectToken()
|
| D | aws_external_account_credentials.h | 75 std::function<void(std::string, grpc_error*)> cb_ = nullptr; variable
|
| /third_party/node/deps/npm/node_modules/tar/lib/ |
| D | replace.js | 106 const getPos = (fd, size, cb_) => { argument
109 fs.close(fd, _ => cb_(er))
111 cb_(null, pos)
|
| /third_party/boost/libs/beast/test/beast/core/ |
| D | buffers_prefix.cpp | 43 net::const_buffer cb_; in testInPlaceInit() member in boost::beast::buffers_prefix_test::testInPlaceInit::test_buffers
57 return &cb_; in testInPlaceInit()
|