Home
last modified time | relevance | path

Searched refs:evb_ (Results 1 – 25 of 120) sorted by relevance

12345

/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/http2/client/
H A DH2ClientConnection.cpp70 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 DEventBaseBackendBase.cpp42 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 DVirtualEventBase.h52 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 DVirtualEventBase.cpp22 : 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 DEventBase.cpp48 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 DHTTPConnectorWithFizzTest.cpp35 : 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 DThreadBoundAdaptorChannel.cpp34 : 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 DRocketClientChannel.cpp332 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 DThriftClientCallback.cpp41 : 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 DFunctionLooper.cpp20 : 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 DZeroCopy.h37 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 DAsyncUDPSocketSendmmsgTest.cpp93 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 DZeroCopy.cpp29 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 DTestSSLServer.cpp34 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 DAsyncUDPSocketTest.cpp52 : 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 DAsyncUDPSocketGSOGROTest.cpp156 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 DAcceptorTest.cpp163 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 DHQClient.cpp37 &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 DSessionPoolTest.cpp34 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 DFakeResponseHandler.cpp32 : 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 DFakeChannel.h34 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 DClientServerTestUtil.cpp141 : 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 DRocketThriftRequests.h79 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 DFizzServerBenchmarkCommand.cpp74 : 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 DSimpleAsyncIO.h80 evb_(nullptr) {} in Config()
94 evb_ = evb; in setEventBase()
102 EventBase* evb_; member
174 std::unique_ptr<ScopedEventBaseThread> evb_; variable

12345