/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/http2/client/ |
H A D | H2ClientConnection.cpp | 70 DCHECK(evb_ && evb_->isInEventBaseThread()); in H2ClientConnection() 95 DCHECK(evb_ && evb_->isInEventBaseThread()); in getChannel() 101 DCHECK(evb_ && evb_->isInEventBaseThread()); in setMaxPendingRequests() 117 return evb_; in getEventBase() 121 DCHECK(evb_ && evb_->isInEventBaseThread()); in newTransaction() 142 DCHECK(!evb_ || evb_->isInEventBaseThread()); in getTransport() 151 DCHECK(evb_ && evb_->isInEventBaseThread()); in good() 158 DCHECK(evb_ && evb_->isInEventBaseThread()); in getSaturationStatus() 180 evb_ = evb; in attachEventBase() 222 DCHECK(!evb_ || evb_->isInEventBaseThread()); in closeNow() [all …]
|
/dports/devel/folly/folly-2021.12.27.00/folly/io/async/ |
H A D | EventBaseBackendBase.cpp | 42 evb_ = evb; in eb_ev_base() 47 evb_ = evb; in eb_event_base_set() 48 auto* base = evb_ ? (evb_->getLibeventBase()) : nullptr; in eb_event_base_set() 57 auto* backend = evb_ ? (evb_->getBackend()) : nullptr; in eb_event_add() 66 auto* backend = evb_ ? (evb_->getBackend()) : nullptr; in eb_event_del() 75 auto* backend = evb_ ? (evb_->getBackend()) : nullptr; in eb_event_active() 95 auto* base = evb_ ? (evb_->getLibeventBase()) : nullptr; in setEdgeTriggered()
|
H A D | VirtualEventBase.h | 52 EventBase& getEventBase() { return *evb_; } in getEventBase() 82 HHWheelTimer& timer() { return evb_->timer(); } in timer() 86 evb_->attachTimeoutManager(obj, internal); in attachTimeoutManager() 90 evb_->detachTimeoutManager(obj); in detachTimeoutManager() 95 return evb_->scheduleTimeout(obj, timeout); in scheduleTimeout() 103 return evb_->isInTimeoutManagerThread(); in isInTimeoutManagerThread() 112 return evb_->inRunningEventBaseThread(); in inRunningEventBaseThread() 117 if (evb_->inRunningEventBaseThread()) { in keepAliveAcquire() 138 if (!evb_->inRunningEventBaseThread()) { in keepAliveRelease() 139 evb_->add([this] { keepAliveReleaseEvb(); }); in keepAliveRelease() [all …]
|
H A D | VirtualEventBase.cpp | 22 : evb_(getKeepAliveToken(evb)) {} in VirtualEventBase() 25 evb_->runInEventBaseThread([this] { loopKeepAlive_.reset(); }); in destroy() 35 SCOPE_EXIT { evb_.reset(); }; in destroyImpl() 62 CHECK(!evb_->inRunningEventBaseThread()); in ~VirtualEventBase()
|
H A D | EventBase.cpp | 48 event_base* getEventBase() override { return evb_; } in getEventBase() 59 event_base* evb_; member in __anon884221720111::EventBaseBackend 63 evb_ = event_base_new(); in EventBaseBackend() 67 if (UNLIKELY(evb_ == nullptr)) { in EventBaseBackend() 74 return event_base_loop(evb_, flags); in eb_event_base_loop() 78 return event_base_loopbreak(evb_); in eb_event_base_loopbreak() 96 event_base_free(evb_); in ~EventBaseBackend() 163 evb_ = in EventBase() 225 evb_.reset(); in ~EventBase() 381 res = evb_->eb_event_base_loop(EVLOOP_ONCE); in loopBody() [all …]
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/test/ |
H A D | HTTPConnectorWithFizzTest.cpp | 35 : evb_(true), factory_(&handshakeCb_), server_(evb_, &factory_) { in HTTPConnectorWithFizzTest() 42 &evb_, in SetUp() 70 evb_.terminateLoopSoon(); in SetupFailureCallbacks() 78 evb_.terminateLoopSoon(); in SetupFailureCallbacks() 82 EventBase evb_; member in HTTPConnectorWithFizzTest 99 connector.connectFizz(&evb_, server_.getAddress(), context, nullptr); in TEST_F() 101 evb_.terminateLoopSoon(); in TEST_F() 103 evb_.loop(); in TEST_F() 119 connector.connectFizz(&evb_, server_.getAddress(), context, nullptr); in TEST_F() 122 evb_.terminateLoopSoon(); in TEST_F() [all …]
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/async/ |
H A D | ThreadBoundAdaptorChannel.cpp | 34 : evb_(std::move(evb)), cb_(std::move(cb)) {} in EvbRequestCallback() 38 evb_->runInEventBaseThread( in onRequestSent() 47 evb_->runInEventBaseThread([requestSent = requestSent_, in onResponse() 59 evb_->runInEventBaseThread([requestSent = requestSent_, in onResponseError() 72 folly::Executor::KeepAlive<folly::EventBase> evb_; member in apache::thrift::__anon10b78bbd0111::EvbRequestCallback 89 evb_(folly::Executor::getKeepAliveToken(evb)) {} in EvbStreamCallback() 138 eventBaseRunHelper(evb_, [this]() mutable { in onStreamComplete() 225 folly::Executor::KeepAlive<folly::EventBase> evb_; member in apache::thrift::__anon10b78bbd0111::EvbStreamCallback 247 std::move(cob), folly::Executor::getKeepAliveToken(evb_))); in sendRequestResponse() 280 cob = new EvbStreamCallback(std::move(cob), evb_); in sendRequestStream() [all …]
|
H A D | RocketClientChannel.cpp | 332 evb_(evb) {} in FirstRequestProcessorStream() 648 DCHECK(!evb_ || evb_->isInEventBaseThread()); in ~RocketClientChannel() 738 evb_)); in sendRequestStream() 777 evb_), in sendRequestSink() 946 DCHECK(evb_ && evb_->isInEventBaseThread()); in getSaturationStatus() 952 DCHECK(!evb_ || evb_->isInEventBaseThread()); in closeNow() 973 DCHECK(!evb_ || evb_->isInEventBaseThread()); in good() 982 DCHECK(!evb_ || evb_->isInEventBaseThread()); in setTimeout() 994 evb_ = evb; in attachEventBase() 1004 evb_ = nullptr; in detachEventBase() [all …]
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/core/ |
H A D | ThriftClientCallback.cpp | 41 : evb_(evb), in ThriftClientCallback() 53 DCHECK(!evb_ || evb_->isInEventBaseThread()); in onThriftRequestSent() 58 evb_->timer().scheduleTimeout(this, timeout_); in onThriftRequestSent() 65 DCHECK(!evb_ || evb_->isInEventBaseThread()); in onThriftResponse() 79 DCHECK(!evb_ || evb_->isInEventBaseThread()); in onError() 88 return evb_; in getEventBase()
|
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/common/ |
H A D | FunctionLooper.cpp | 20 : evb_(evb), func_(std::move(func)), type_(type) {} in FunctionLooper() 51 evb_->runInLoop(this); in commonLoopBody() 85 evb_->runInLoop(this, thisIteration); in run() 101 DCHECK(!evb_); in attachEventBase() 103 evb_ = evb; in attachEventBase() 108 DCHECK(evb_ && evb_->isInEventBaseThread()); in detachEventBase() 111 evb_ = nullptr; in detachEventBase()
|
/dports/devel/folly/folly-2021.12.27.00/folly/io/async/test/ |
H A D | ZeroCopy.h | 37 evb_(evb), in ZeroCopyTestAsyncSocket() 54 evb_(evb), in ZeroCopyTestAsyncSocket() 156 evb_->runInLoop( in onDataReady() 159 evb_->terminateLoopSoon(); in onDataReady() 171 evb_->terminateLoopSoon(); in onDataFinish() 195 folly::EventBase* evb_; variable 215 : evb_(evb), in ZeroCopyTestServer() 221 sock.addAcceptCallback(this, evb_); in addCallbackToServerSocket() 229 nullptr, evb_, fd, numLoops_, bufferSize_, zeroCopy_); in connectionAccepted() 236 folly::EventBase* evb_; [all …]
|
H A D | AsyncUDPSocketSendmmsgTest.cpp | 93 UDPAcceptor(EventBase* evb) : evb_(evb) {} in UDPAcceptor() 110 EventBase* const evb_{nullptr}; member in UDPAcceptor 116 : evb_(evb), addr_(addr), evbs_(n) {} in UDPServer() 119 CHECK(evb_->isInEventBaseThread()); in start() 153 CHECK(evb_->isInEventBaseThread()); in shutdown() 171 EventBase* const evb_{nullptr}; member in UDPServer 186 CHECK(evb_->isInEventBaseThread()); in start() 188 socket_ = std::make_unique<AsyncUDPSocket>(evb_); in start() 212 CHECK(evb_->isInEventBaseThread()); in shutdown() 216 evb_->terminateLoopSoon(); in shutdown() [all …]
|
H A D | ZeroCopy.cpp | 29 listenSock_(new folly::AsyncServerSocket(&evb_)), in ZeroCopyTest() 30 server_(&evb_, numLoops_, bufferSize_, zeroCopy) { in ZeroCopyTest() 35 &counter_, &evb_, numLoops_, bufferSize_, zeroCopy)); in ZeroCopyTest() 43 evb_.runInEventBaseThread([this]() { in run() 54 evb_.loopForever(); in run()
|
H A D | TestSSLServer.cpp | 34 evb_.runInEventBaseThread([&]() { socket_->stopAccepting(); }); in ~TestSSLServer() 68 socket_ = AsyncServerSocket::newSocket(&evb_); in init() 71 acb_->base_ = &evb_; in init() 83 socket_->addAcceptCallback(acb_, &evb_); in init() 87 evb_.loop(); in init()
|
H A D | AsyncUDPSocketTest.cpp | 52 : evb_(evb), in UDPAcceptor() 95 EventBase* const evb_{nullptr}; member in UDPAcceptor 172 EventBase* const evb_{nullptr}; member in UDPServer 230 evb_->terminateLoopSoon(); in shutdown() 702 EventBase evb_; member in AsyncUDPSocketTest 746 evb_.loopForever(); in TEST_F() 759 evb_.loopForever(); in TEST_F() 770 evb_.terminateLoopSoon(); in TEST_F() 774 evb_.loopForever(); in TEST_F() 796 evb_.loopForever(); in TEST_F() [all …]
|
H A D | AsyncUDPSocketGSOGROTest.cpp | 156 UDPAcceptor(EventBase* evb) : evb_(evb) {} in UDPAcceptor() 185 EventBase* const evb_{nullptr}; member in UDPAcceptor 191 : evb_(evb), addr_(addr), evbs_(n) {} in UDPServer() 194 CHECK(evb_->isInEventBaseThread()); in start() 231 CHECK(evb_->isInEventBaseThread()); in shutdown() 249 EventBase* const evb_{nullptr}; member in UDPServer 264 CHECK(evb_->isInEventBaseThread()); in start() 266 socket_ = std::make_unique<AsyncUDPSocket>(evb_); in start() 304 CHECK(evb_->isInEventBaseThread()); in shutdown() 308 evb_->terminateLoopSoon(); in shutdown() [all …]
|
/dports/net/wangle/wangle-2021.12.27.00/wangle/acceptor/test/ |
H A D | AcceptorTest.cpp | 163 evb_.loop(); in TEST_P() 269 evb_.loop(); in TEST_P() 286 evb_.loop(); in TEST_P() 297 evb_.loop(); in TEST_P() 310 evb_.loop(); in TEST_P() 341 evb_.loop(); in TEST_P() 367 evb_.loop(); in TEST_P() 385 evb_.loop(); in TEST_P() 408 evb_.loop(); in TEST_P() 420 evb_.loop(); in TEST_P() [all …]
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/httpserver/samples/hq/ |
H A D | HQClient.cpp | 37 &evb_, params_.transportSettings.pacingTimerTickInterval); in HQClient() 67 evb_.loopForever(); in start() 70 std::make_unique<folly::AsyncUDPSocket>(&evb_)); in start() 73 evb_.loop(); in start() 81 std::make_unique<CurlService::CurlClient>(&evb_, in sendRequest() 156 evb_.timer().scheduleTimeoutFn( in connectSuccess() 186 evb_.terminateLoopSoon(); in onReplaySafe() 193 evb_.terminateLoopSoon(); in connectError() 197 auto sock = std::make_unique<folly::AsyncUDPSocket>(&evb_); in initializeQuicClient() 199 &evb_, in initializeQuicClient()
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/connpool/test/ |
H A D | SessionPoolTest.cpp | 34 evb_.loop(); in TEST_F() 39 evb_.loop(); in TEST_F() 58 evb_.loop(); in TEST_F() 85 evb_.loop(); in TEST_F() 102 evb_.loop(); in TEST_F() 129 evb_.loop(); in TEST_F() 185 evb_.loop(); in TEST_F() 204 evb_.loop(); in TEST_F() 210 evb_.loop(); in TEST_F() 230 evb_.loop(); in TEST_F() [all …]
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/http2/common/testutil/ |
H A D | FakeResponseHandler.cpp | 32 : evb_(getKeepAliveToken(evb)), in FakeResponseHandler() 40 EXPECT_TRUE(evb_->inRunningEventBaseThread()); in FakeResponseHandler() 48 EXPECT_TRUE(evb_->inRunningEventBaseThread()); in FakeResponseHandler() 56 EXPECT_TRUE(evb_->inRunningEventBaseThread()); in FakeResponseHandler() 59 evb_.reset(); in FakeResponseHandler()
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/core/testutil/ |
H A D | FakeChannel.h | 34 explicit FakeChannel(folly::EventBase* evb) : evb_(getKeepAliveToken(evb)) {} in FakeChannel() 44 evb_.reset(); in sendThriftResponse() 54 folly::EventBase* getEventBase() noexcept override { return evb_.get(); } in getEventBase() 63 folly::Executor::KeepAlive<folly::EventBase> evb_; variable
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/rocket/test/network/ |
H A D | ClientServerTestUtil.cpp | 141 : evb_(*evbThread_.getEventBase()), in RocketTestClient() 142 fm_(folly::fibers::getFiberManager(evb_)), in RocketTestClient() 158 evb_.runInEventBaseThread([&] { in sendRequestResponseSync() 178 evb_.runInEventBaseThread([&] { in sendRequestFnfSync() 247 evb_.runInEventBaseThread([&] { in sendRequestStreamSync() 265 evb_.runInEventBaseThread( in sendRequestSink() 281 evb_.runInEventBaseThreadAndWait([this] { in connect() 285 evb_, in connect() 562 : evb_(*ioThread_.getEventBase()), in RocketTestServer() 570 evb_, expectedSetupMetadata_); in RocketTestServer() [all …]
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/rocket/server/ |
H A D | RocketThriftRequests.h | 79 folly::EventBase* getEventBase() noexcept override { return &evb_; } in getEventBase() 86 folly::EventBase& evb_; 125 folly::EventBase* getEventBase() noexcept override { return &evb_; } in getEventBase() 130 folly::EventBase& evb_; 181 folly::EventBase* getEventBase() noexcept override { return &evb_; } in getEventBase() 188 folly::EventBase& evb_; 242 folly::EventBase* getEventBase() noexcept override { return &evb_; } in getEventBase() 249 folly::EventBase& evb_;
|
/dports/security/fizz/fizz-2021.12.27.00/fizz/tool/ |
H A D | FizzServerBenchmarkCommand.cpp | 74 : evb_(evb), serverContext_(serverContext) {} in ServerTask() 77 auto sock = new AsyncSocket(evb_, folly::NetworkSocket::fromFd(fd)); in start() 103 EventBase* evb_; member in fizz::tool::__anon458e56f10111::ServerTask 116 : evb_(evb), serverContext_(serverContext), threadExe_(threadExe) { in FizzServerAcceptor() 117 socket_ = AsyncServerSocket::UniquePtr(new AsyncServerSocket(evb_)); in FizzServerAcceptor() 120 socket_->addAcceptCallback(this, evb_); in FizzServerAcceptor() 144 EventBase* evb_; member in fizz::tool::__anon458e56f10111::FizzServerAcceptor
|
/dports/devel/folly/folly-2021.12.27.00/folly/experimental/io/ |
H A D | SimpleAsyncIO.h | 80 evb_(nullptr) {} in Config() 94 evb_ = evb; in setEventBase() 102 EventBase* evb_; member 174 std::unique_ptr<ScopedEventBaseThread> evb_; variable
|