GlobalThreadPoolList.cpp File Reference

#include <folly/executors/GlobalThreadPoolList.h>
#include <memory>
#include <string>
#include <vector>
#include <folly/CppAttributes.h>
#include <folly/Indestructible.h>
#include <folly/Synchronized.h>
#include <folly/ThreadLocal.h>

Go to the source code of this file.

Namespaces
	folly
	—— Concurrent Priority Queue Implementation ——

Variable Documentation

ThreadPoolListHook* addr

Definition at line 61 of file GlobalThreadPoolList.cpp.

Referenced by folly::IPAddressV4::AddressStorage::AddressStorage(), wangle::LoadShedConfiguration::addWhitelistAddr(), folly::IPAddressV6::bytes(), checkSingleLocation(), folly::ZeroCopyTest::connectAll(), folly::test::createConnectedSocket(), folly::CoreRawAllocator< Stripes >::Allocator::deallocate(), folly::AsyncServerSocket::dispatchSocket(), fizz::tool::fizzClientCommand(), folly::symbolizer::FastStackTracePrinter::flush(), folly::detail::MemoryIdler::flushLocalMallocCaches(), folly::MacAddress::fromHBO(), folly::IPAddressV4::fromLong(), folly::IPAddressV4::fromLongHBO(), fizz::server::test::FizzTestServer::getAddress(), folly::symbolizer::ElfFile::getAddressValue(), proxygen::HTTPSessionAcceptor::getDiagnosticErrorPage(), folly::IPAddressV6::getIPv4For6To4(), wangle::LoadShedConfiguration::getLoadSheddingEnabled(), folly::AsyncTransport::getLocalAddress(), folly::AsyncTransport::getPeerAddress(), folly::MemoryMapping::init(), folly::IPAddressV4::inSubnet(), folly::IPAddressV6::inSubnet(), main(), folly::SocketAddress::makeFromPath(), folly::detail::Bytes::mkAddress4(), folly::detail::Bytes::mkAddress6(), wangle::ServerAcceptor< Pipeline >::onDataAvailable(), folly::AsyncUDPServerSocket::Callback::onListenResumed(), ProxyService::ProxyHandler::onRequest(), folly::SocketAddress::operator=(), AddressData::parseAddress4(), AddressData::parseAddress6(), folly::compression::detail::UpperBitsReader< Encoder, Instructions, SizeType >::prepareSkipTo(), folly::compression::EliasFanoReader< Encoder, Instructions, kUnchecked, SizeType >::prepareSkipTo(), folly::detail::qfind_first_byte_of_sse42(), fizz::detail::readBits24(), folly::AsyncSocket::scheduleInitialReadWrite(), proxygen::ScopedHTTPServer::start< std::unique_ptr< RequestHandlerFactory > >(), folly::AsyncSocket::sendSocketMessage(), folly::test::Server::Server(), proxygen::HTTPMessage::setClientAddress(), proxygen::HTTPMessage::setDstAddress(), BroadcastPoolTest::SetUp(), folly::SocketAddress::SocketAddress(), BroadcastPoolTest::startServer(), folly::small_vector< Observer< T > *, InlineObservers >::swap(), folly::symbolizer::Symbolizer::symbolize(), BroadcastPoolTest::TearDown(), folly::TEST(), wangle::TEST(), TEST(), TEST_F(), TEST_P(), testMAC(), folly::toAppend(), folly::IPAddressV4::toLong(), folly::IPAddressV4::toSockAddr(), folly::IPAddressV6::toSockAddr(), folly::IPAddressV4::tryFromBinary(), folly::IPAddressV6::tryFromBinary(), folly::ssl::OpenSSLUtils::validatePeerCertNames(), and fizz::detail::writeBits24().

folly::Synchronized<GlobalThreadPoolListImpl> globalListImpl_

private

Definition at line 112 of file GlobalThreadPoolList.cpp.

std::string name

Definition at line 62 of file GlobalThreadPoolList.cpp.

ThreadPoolListHook* poolId_

private

Definition at line 39 of file GlobalThreadPoolList.cpp.

Pools pools_

private

Definition at line 87 of file GlobalThreadPoolList.cpp.

std::vector<PoolInfo> poolsInfo_

Definition at line 69 of file GlobalThreadPoolList.cpp.

folly::ThreadLocalPtr<ThreadListHook> threadHook_

private

Definition at line 113 of file GlobalThreadPoolList.cpp.

std::thread::id threadId_

private

Definition at line 40 of file GlobalThreadPoolList.cpp.

std::vector<std::thread::id> threads

Definition at line 63 of file GlobalThreadPoolList.cpp.

Referenced by append(), folly::test::atomic_notify_one(), atomicIncrBaseline(), BENCHMARK(), BENCHMARK_RELATIVE(), bm_impl(), cleanup_test(), contend(), contendedRW(), contendedUse(), contentionAtWidth(), DSchedMixedTest(), folly::gen::detail::Parallel< Ops >::Generator< Input, Source, InputDecayed, Composed, Output, OutputDecayed >::Executor< all >::Executor(), folly::test::fc_test(), wangle::ServerBootstrap< DefaultPipeline >::group(), lifo_test(), main(), multiAttemptExpectDurationWithin(), QueueTest::multiConsumer(), folly::gen::parallel(), std::chrono::PrintTo(), folly::io::test::RandomDataHolder::RandomDataHolder(), run4Threads(), run_mt_sequencer_test(), run_multi(), run_once(), runAllAndValidate(), runContended(), runContendedReaders(), runFairness(), runInThreadsAndWait(), runMixed(), runNeverFailTest(), folly::sync_tests::runParallel(), runPingPong(), runRemoteUnlock(), runTest(), runTestTag(), runTryEnqDeqTest(), folly::runWritesNeverFail(), swmr_test(), folly::futures::test::TEST(), folly::test::TEST(), TEST(), folly::TEST(), TEST_F(), testTryReadUntil(), testTryWriteUntil(), and TYPED_TEST().