Home
last modified time | relevance | path

Searched refs:pool_ (Results 1 – 25 of 42) sorted by relevance

12

/third_party/boost/boost/asio/impl/
Dthread_pool.hpp57 thread_pool* old_thread_pool = pool_; in operator =()
58 pool_ = other.pool_; in operator =()
63 if (pool_) in operator =()
64 pool_->scheduler_.work_started(); in operator =()
80 pool_ = other.pool_; in operator =()
84 other.pool_ = 0; in operator =()
94 return pool_->scheduler_.can_dispatch(); in running_in_this_thread()
106 if ((bits_ & blocking_never) == 0 && pool_->scheduler_.can_dispatch()) in do_execute()
125 pool_->scheduler_.capture_current_exception(); in do_execute()
140 BOOST_ASIO_HANDLER_CREATION((*pool_, *p.p, in do_execute()
[all …]
/third_party/boost/libs/beast/example/http/server/fast/
Dfields_alloc.hpp107 detail::static_pool* pool_; member
134 : pool_(&detail::static_pool::construct(size)) in fields_alloc()
139 : pool_(&other.pool_->share()) in fields_alloc()
145 : pool_(&other.pool_->share()) in fields_alloc()
151 pool_->destroy(); in ~fields_alloc()
158 pool_->alloc(n * sizeof(T))); in allocate()
164 pool_->dealloc(); in deallocate()
191 return &lhs.pool_ == &rhs.pool_; in operator ==()
/third_party/nghttp2/src/
Dshrpx_downstream_connection_pool.cc35 for (auto dconn : pool_) { in remove_all()
39 pool_.clear(); in remove_all()
44 pool_.insert(dconn.release()); in add_downstream_connection()
49 if (pool_.empty()) { in pop_downstream_connection()
53 auto it = std::begin(pool_); in pop_downstream_connection()
55 pool_.erase(it); in pop_downstream_connection()
62 pool_.erase(dconn); in remove_downstream_connection()
Dshrpx_downstream_connection_pool.h48 std::set<DownstreamConnection *> pool_;
/third_party/grpc/src/cpp/server/
Ddynamic_thread_pool.cc29 : pool_(pool), in DynamicThread()
41 pool_->ThreadFunc(); in ThreadFunc()
43 grpc_core::MutexLock lock(&pool_->mu_); in ThreadFunc()
44 pool_->nthreads_--; in ThreadFunc()
46 pool_->dead_threads_.push_back(this); in ThreadFunc()
48 if ((pool_->shutdown_) && (pool_->nthreads_ == 0)) { in ThreadFunc()
49 pool_->shutdown_cv_.Signal(); in ThreadFunc()
/third_party/boost/boost/asio/
Dthread_pool.hpp195 : pool_(other.pool_), in basic_executor_type()
200 if (pool_) in basic_executor_type()
201 pool_->scheduler_.work_started(); in basic_executor_type()
207 : pool_(other.pool_), in basic_executor_type()
212 other.pool_ = 0; in basic_executor_type()
220 if (pool_) in ~basic_executor_type()
221 pool_->scheduler_.work_finished(); in ~basic_executor_type()
249 pool_, allocator_, bits_ & ~blocking_mask); in require()
268 pool_, allocator_, bits_ & ~blocking_mask); in require()
286 pool_, allocator_, (bits_ & ~blocking_mask) | blocking_never); in require()
[all …]
/third_party/boost/boost/lockfree/detail/
Dfreelist.hpp59 pool_(tagged_node_ptr(NULL)) in freelist_stack()
126 tagged_node_ptr current = pool_.load(); in ~freelist_stack()
138 return pool_.is_lock_free(); in is_lock_free()
180 tagged_node_ptr old_pool = pool_.load(memory_order_consume); in allocate_impl()
196 if (pool_.compare_exchange_weak(old_pool, new_pool)) { in allocate_impl()
206 tagged_node_ptr old_pool = pool_.load(memory_order_relaxed); in allocate_impl_unsafe()
221 pool_.store(new_pool, memory_order_relaxed); in allocate_impl_unsafe()
240 tagged_node_ptr old_pool = pool_.load(memory_order_consume); in deallocate_impl()
247 if (pool_.compare_exchange_weak(old_pool, new_pool)) in deallocate_impl()
255 tagged_node_ptr old_pool = pool_.load(memory_order_relaxed); in deallocate_impl_unsafe()
[all …]
/third_party/boost/libs/asio/example/cpp11/executors/
Dbank_account_1.cpp14 mutable static_thread_pool pool_{1}; member in bank_account
20 pool_.executor(), in deposit()
30 pool_.executor(), in withdraw()
41 pool_.executor(), in print_balance()
50 pool_.wait(); in ~bank_account()
Dbank_account_2.cpp14 mutable static_thread_pool pool_{1}; member in bank_account
20 boost::asio::require(pool_.executor(), in deposit()
31 boost::asio::require(pool_.executor(), in withdraw()
44 boost::asio::require(pool_.executor(), in balance()
/third_party/boost/doc/html/boost_asio/example/cpp11/executors/
Dbank_account_1.cpp14 mutable static_thread_pool pool_{1}; member in bank_account
20 pool_.executor(), in deposit()
30 pool_.executor(), in withdraw()
41 pool_.executor(), in print_balance()
50 pool_.wait(); in ~bank_account()
Dbank_account_2.cpp14 mutable static_thread_pool pool_{1}; member in bank_account
20 boost::asio::require(pool_.executor(), in deposit()
31 boost::asio::require(pool_.executor(), in withdraw()
44 boost::asio::require(pool_.executor(), in balance()
/third_party/boost/libs/asio/example/cpp14/executors/
Dbank_account_1.cpp14 mutable static_thread_pool pool_{1}; member in bank_account
20 pool_.executor(), in deposit()
30 pool_.executor(), in withdraw()
41 pool_.executor(), in print_balance()
50 pool_.wait(); in ~bank_account()
Dbank_account_2.cpp14 mutable static_thread_pool pool_{1}; member in bank_account
20 boost::asio::require(pool_.executor(), in deposit()
31 boost::asio::require(pool_.executor(), in withdraw()
44 boost::asio::require(pool_.executor(), in balance()
/third_party/protobuf/src/google/protobuf/
Ddynamic_message_unittest.cc62 DescriptorPool pool_; member in google::protobuf::DynamicMessageTest
75 DynamicMessageTest() : factory_(&pool_) {} in DynamicMessageTest()
95 ASSERT_TRUE(pool_.BuildFile(unittest_import_public_file) != NULL); in SetUp()
96 ASSERT_TRUE(pool_.BuildFile(unittest_import_file) != NULL); in SetUp()
97 ASSERT_TRUE(pool_.BuildFile(unittest_file) != NULL); in SetUp()
98 ASSERT_TRUE(pool_.BuildFile(unittest_no_field_presence_file) != NULL); in SetUp()
100 descriptor_ = pool_.FindMessageTypeByName("protobuf_unittest.TestAllTypes"); in SetUp()
105 pool_.FindMessageTypeByName("protobuf_unittest.TestAllExtensions"); in SetUp()
110 pool_.FindMessageTypeByName("protobuf_unittest.TestPackedTypes"); in SetUp()
115 pool_.FindMessageTypeByName("protobuf_unittest.TestOneof2"); in SetUp()
[all …]
Ddescriptor_unittest.cc345 foo_file_ = pool_.BuildFile(foo_file); in SetUp()
348 bar_file_ = pool_.BuildFile(bar_file); in SetUp()
351 baz_file_ = pool_.BuildFile(baz_file); in SetUp()
377 DescriptorPool pool_; member in google::protobuf::descriptor_unittest::FileDescriptorTest
474 EXPECT_EQ(foo_extension_, pool_.FindExtensionByNumber(foo_message_, 1)); in TEST_F()
475 EXPECT_EQ(bar_extension_, pool_.FindExtensionByNumber(bar_message_, 1)); in TEST_F()
477 EXPECT_TRUE(pool_.FindExtensionByNumber(foo_message_, 2) == nullptr); in TEST_F()
486 EXPECT_EQ(foo_file_, pool_.BuildFile(file)); in TEST_F()
490 EXPECT_TRUE(pool_.BuildFile(file) == nullptr); in TEST_F()
500 const FileDescriptor* proto2_descriptor = pool_.BuildFile(proto_syntax2); in TEST_F()
[all …]
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_threadpool.cc69 : pool_(pool), counter_(counter), num_add_(num_add) { in AddAnotherFunctor()
80 callback->pool_->Add(new AddAnotherFunctor( in Run()
81 callback->pool_, callback->counter_, callback->num_add_)); in Run()
90 grpc_core::ThreadPool* pool_; member in grpc::testing::AddAnotherFunctor
186 : pool_(pool), counter_(counter), num_add_(num_add) { in AddSelfFunctor()
197 callback->pool_->Add(cb); in Run()
206 grpc_core::ThreadPool* pool_; member in grpc::testing::AddSelfFunctor
/third_party/boost/boost/smart_ptr/detail/
Dspinlock_pool.hpp38 static spinlock pool_[ 41 ]; member in boost::detail::spinlock_pool
49 return pool_[ i ]; in spinlock_for()
75 template< int M > spinlock spinlock_pool< M >::pool_[ 41 ] = member in boost::detail::spinlock_pool< M >
/third_party/gn/src/gn/
Daction_values.h56 const LabelPtrPair<Pool>& pool() const { return pool_; } in pool()
57 void set_pool(LabelPtrPair<Pool> pool) { pool_ = std::move(pool); } in set_pool()
65 LabelPtrPair<Pool> pool_; variable
Dtool.h196 const LabelPtrPair<Pool>& pool() const { return pool_; } in pool()
197 void set_pool(LabelPtrPair<Pool> pool) { pool_ = std::move(pool); } in set_pool()
272 LabelPtrPair<Pool> pool_; variable
/third_party/flutter/engine/flutter/vulkan/
Dvulkan_command_buffer.cc15 : vk(p_vk), device_(device), pool_(pool), valid_(false) { in VulkanCommandBuffer()
19 .commandPool = pool_, in VulkanCommandBuffer()
33 vk.FreeCommandBuffers(device_, pool_, 1, &buffer); in VulkanCommandBuffer()
/third_party/gstreamer/gstreamer/gst/
Dgsttaskpool.c84 GThreadPool *pool_; in default_cleanup() local
87 pool_ = pool->pool; in default_cleanup()
91 if (pool_) { in default_cleanup()
95 g_thread_pool_free (pool_, FALSE, TRUE); in default_cleanup()
/third_party/grpc/test/core/iomgr/
Dthreadpool_test.cc88 : num_add_(num_add), cb_(cb), pool_(pool) { in WorkThread()
101 pool_->Add(cb_); in Run()
107 grpc_core::ThreadPool* pool_; member in WorkThread
/third_party/protobuf/src/google/protobuf/compiler/
Dimporter.cc223 pool_(&database_, database_.GetValidationErrorCollector()) { in Importer()
224 pool_.EnforceWeakDependencies(true); in Importer()
231 return pool_.FindFileByName(filename); in Import()
236 pool_.AddUnusedImportTrackFile(file_name, is_error); in AddUnusedImportTrackFile()
240 pool_.ClearUnusedImportTrackFiles(); in ClearUnusedImportTrackFiles()
/third_party/ninja/src/
Dgraph.h147 Edge() : rule_(NULL), pool_(NULL), dyndep_(NULL), env_(NULL), in Edge()
174 Pool* pool_; member
185 Pool* pool() const { return pool_; } in pool()
/third_party/protobuf/src/google/protobuf/util/
Dtype_resolver_util.cc74 : url_prefix_(url_prefix), pool_(pool) {} in DescriptorPoolTypeResolver()
83 const Descriptor* descriptor = pool_->FindMessageTypeByName(type_name); in ResolveMessageType()
100 const EnumDescriptor* descriptor = pool_->FindEnumTypeByName(type_name); in ResolveEnumType()
360 const DescriptorPool* pool_; member in google::protobuf::util::__anon3d2c2d7b0111::DescriptorPoolTypeResolver

12