Home
last modified time | relevance | path

Searched refs:eventBase (Results 1 – 25 of 773) sorted by relevance

12345678910>>...31

/dports/devel/folly/folly-2021.12.27.00/folly/io/async/test/
H A DEventBaseBenchmark.cpp25 CountedLoopCallback(EventBase* eventBase, unsigned int count) in CountedLoopCallback() argument
26 : eventBase_(eventBase), count_(count) {} in CountedLoopCallback()
41 EventBase eventBase; in BENCHMARK() local
44 CountedLoopCallback c(&eventBase, 10); in BENCHMARK()
45 eventBase.runInLoop(&c); in BENCHMARK()
46 eventBase.loop(); in BENCHMARK()
51 EventBase eventBase(/* enableTimeMeasurement */ false); in BENCHMARK_RELATIVE() local
54 CountedLoopCallback c(&eventBase, 10); in BENCHMARK_RELATIVE()
55 eventBase.runInLoop(&c); in BENCHMARK_RELATIVE()
56 eventBase.loop(); in BENCHMARK_RELATIVE()
H A DHHWheelTimerTest.cpp56 EventBase eventBase; member
81 eventBase.loop(); in TEST_F()
154 eventBase.loop(); in TEST_F()
227 eventBase.loop(); in TEST_F()
280 eventBase.loop(); in TEST_F()
312 eventBase.loop(); in TEST_F()
342 eventBase.loop(); in TEST_F()
371 eventBase.loop(); in TEST_F()
386 &eventBase, in TEST_F()
403 eventBase.loop(); in TEST_F()
[all …]
H A DNotificationQueueTest.cpp72 EventBase eventBase; in sendOne() local
86 eventBase.loop(); in sendOne()
94 EventBase eventBase; in putMessages() local
124 eventBase.loop(); in putMessages()
159 eventBase->runInEventBaseThread([eventBase, consumer, this] { in multiConsumer()
189 EventBase eventBase; in multiConsumer() local
191 eventBase.loop(); in multiConsumer()
281 EventBase eventBase; in maxReadAtOnce() local
320 eventBase.loop(); in maxReadAtOnce()
371 EventBase eventBase; in destroyCallback() local
[all …]
H A DHHWheelTimerSlowTests.cpp59 EventBase eventBase; member
64 HHWheelTimer& t = eventBase.timer(); in TEST_F()
77 eventBase.loop(); in TEST_F()
138 eventBase.loop(); in TEST_F()
198 eventBase.runInLoop([]() { in TEST_F()
207 eventBase.loop(); in TEST_F()
217 eventBase.runInLoop([]() { in TEST_F()
226 eventBase.loop(); in TEST_F()
255 eventBase.loop(); in TEST_F()
283 eventBase.runAfterDelay( in TEST_F()
[all …]
H A DAsyncSSLSocketTest.cpp385 eventBase.loop(); in TEST()
703 eventBase.loop(); in TEST()
740 eventBase.loop(); in TEST()
774 eventBase.loop(); in TEST()
807 eventBase.loop(); in TEST()
849 eventBase.loop(); in TEST()
875 eventBase.loop(); in TEST()
902 eventBase.loop(); in TEST()
929 eventBase.loop(); in TEST()
1045 eventBase.loop(); in TEST()
[all …]
H A DSSLSessionTest.cpp69 folly::EventBase eventBase; member in folly::SSLSessionTest
87 new AsyncSSLSocket(clientCtx, &eventBase, fds[0], serverName)); in TEST_F()
99 new AsyncSSLSocket(dfServerCtx, &eventBase, fds[1], true)); in TEST_F()
104 eventBase.loop(); in TEST_F()
120 new AsyncSSLSocket(clientCtx, &eventBase, fds[0], serverName)); in TEST_F()
126 new AsyncSSLSocket(dfServerCtx, &eventBase, fds[1], true)); in TEST_F()
131 eventBase.loop(); in TEST_F()
143 new AsyncSSLSocket(clientCtx, &eventBase, fds[0], serverName)); in TEST_F()
149 new AsyncSSLSocket(dfServerCtx, &eventBase, fds[1], true)); in TEST_F()
154 eventBase.loop(); in TEST_F()
H A DEventBaseTestLib.h1538 eventBase.runInLoop(&c); in TYPED_TEST_P()
1541 eventBase.loop(); in TYPED_TEST_P()
1556 eventBase.runInLoop(&c); in TYPED_TEST_P()
1559 eventBase.loop(); in TYPED_TEST_P()
1574 &eventBase, 10, std::bind(&EventBase::terminateLoopSoon, &eventBase)); in TYPED_TEST_P()
1581 eventBase.loopForever(); in TYPED_TEST_P()
1629 &eventBase, 1, std::bind(&EventBase::terminateLoopSoon, &eventBase)); in TYPED_TEST_P()
1677 eventBase.loop(); in TYPED_TEST_P()
1777 eventBase.loop(); in TYPED_TEST_P()
1784 eventBase.loop(); in TYPED_TEST_P()
[all …]
H A DAtomicNotificationQueueTest.cpp113 EventBase eventBase; in TEST() local
114 queue.startConsuming(&eventBase); in TEST()
120 eventBase.loopOnce(); in TEST()
129 eventBase.loopOnce(); in TEST()
166 EventBase eventBase; in TEST() local
167 queue.startConsuming(&eventBase); in TEST()
173 eventBase.loopOnce(); in TEST()
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp/test/
H A DTEventJobQueueTest.cpp54 EventBaseAborter(folly::EventBase* eventBase, uint32_t timeoutMS) in EventBaseAborter() argument
56 eventBase, folly::AsyncTimeout::InternalEnum::INTERNAL), in EventBaseAborter()
57 eventBase_(eventBase) { in EventBaseAborter()
75 folly::EventBase eventBase; in TEST() local
76 EventBaseAborter eba(&eventBase, 1000); in TEST()
84 jobQueue.enqueueJob(new SimpleRunnable(&eventBase, x, &sum)); in TEST()
87 eventBase.loopForever(); in TEST()
98 folly::EventBase eventBase; in TEST() local
99 EventBaseAborter eba(&eventBase, 1000); in TEST()
112 jobQueue.enqueueJob(new SimpleRunnable(&eventBase, x, &sum)); in TEST()
[all …]
/dports/devel/folly/folly-2021.12.27.00/folly/io/async/
H A DEventHandler.cpp26 EventHandler::EventHandler(EventBase* eventBase, NetworkSocket fd) { in EventHandler() argument
28 if (eventBase != nullptr) { in EventHandler()
29 setEventBase(eventBase); in EventHandler()
106 void EventHandler::attachEventBase(EventBase* eventBase) { in attachEventBase() argument
111 eventBase->dcheckIsInEventBaseThread(); in attachEventBase()
113 setEventBase(eventBase); in attachEventBase()
130 void EventHandler::initHandler(EventBase* eventBase, NetworkSocket fd) { in initHandler() argument
133 setEventBase(eventBase); in initHandler()
166 void EventHandler::setEventBase(EventBase* eventBase) { in setEventBase() argument
167 event_.eb_event_base_set(eventBase); in setEventBase()
[all …]
H A DEventBaseManager.cpp43 void EventBaseManager::setEventBase(EventBase* eventBase, bool takeOwnership) { in setEventBase() argument
51 info = new EventBaseInfo(eventBase, takeOwnership); in setEventBase()
53 this->trackEventBase(eventBase); in setEventBase()
59 this->untrackEventBase(info->eventBase); in clearEventBase()
75 info->eventBase->setObserver(observer_); in getEventBase()
85 (const_cast<EventBaseManager*>(this))->trackEventBase(info->eventBase); in getEventBase()
88 return info->eventBase; in getEventBase()
H A DAsyncPipe.h41 folly::EventBase* eventBase, NetworkSocket pipeFd) { in newReader() argument
42 return UniquePtr(new AsyncPipeReader(eventBase, pipeFd)); in newReader()
45 AsyncPipeReader(folly::EventBase* eventBase, NetworkSocket pipeFd) in AsyncPipeReader() argument
46 : EventHandler(eventBase, pipeFd), fd_(pipeFd) {} in AsyncPipeReader()
100 folly::EventBase* eventBase, NetworkSocket pipeFd) { in newWriter() argument
101 return UniquePtr(new AsyncPipeWriter(eventBase, pipeFd)); in newWriter()
104 AsyncPipeWriter(folly::EventBase* eventBase, NetworkSocket pipeFd) in AsyncPipeWriter() argument
105 : EventHandler(eventBase, pipeFd), fd_(pipeFd) {} in AsyncPipeWriter()
H A DEventBaseManager.h77 return info->eventBase; in getExistingEventBase()
92 void setEventBase(EventBase* eventBase, bool takeOwnership);
118 EventBaseInfo(EventBase* evb, bool owned) : eventBase(evb), owned_(owned) {} in EventBaseInfo()
119 EventBaseInfo() : eventBase(new EventBase), owned_(true) {} in EventBaseInfo()
121 EventBase* eventBase; member
125 delete eventBase; in ~EventBaseInfo() local
H A DAsyncServerSocket.cpp65 eventBase->runInEventBaseThread([=]() { in start()
67 queue_.startConsuming(eventBase); in start()
73 eventBase->runInEventBaseThread([=]() { in stop()
124 : eventBase_(eventBase), in AsyncServerSocket()
212 DCHECK(callback.eventBase); in stopAccepting()
237 eventBase_ = eventBase; in attachEventBase()
621 if (!eventBase) { in addAcceptCallback()
668 (it->eventBase == eventBase || eventBase == nullptr)) { in removeAcceptCallback()
699 DCHECK(info.eventBase); in removeAcceptCallback()
1074 if (info->eventBase == nullptr || info->eventBase == this->eventBase_) { in dispatchSocket()
[all …]
H A DAsyncTimeout.cpp41 AsyncTimeout::AsyncTimeout(EventBase* eventBase) : timeoutManager_(eventBase) { in AsyncTimeout() argument
48 if (eventBase) { in AsyncTimeout()
66 AsyncTimeout::AsyncTimeout(EventBase* eventBase, InternalEnum internal) in AsyncTimeout() argument
67 : timeoutManager_(eventBase) { in AsyncTimeout()
134 EventBase* eventBase, InternalEnum internal) { in attachEventBase() argument
135 attachTimeoutManager(eventBase, internal); in attachEventBase()
/dports/net/cjdns/cjdns-cjdns-v21.1/admin/angel/
H A DInterfaceWaiter.c28 struct EventBase* eventBase; member
41 EventBase_endLoop(ctx->eventBase); in timeout()
51 EventBase_endLoop(ctx->eventBase); in receiveMessage()
57 struct EventBase* eventBase, in InterfaceWaiter_waitForData() argument
63 .eventBase = eventBase, in InterfaceWaiter_waitForData()
70 ctx.timeout = Timeout_setTimeout(timeout, &ctx, 10000, eventBase, tempAlloc); in InterfaceWaiter_waitForData()
71 EventBase_beginLoop(eventBase); in InterfaceWaiter_waitForData()
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/server/
H A DCpp2Worker.h78 folly::EventBase* eventBase = nullptr,
92 worker->Acceptor::init(nullptr, eventBase); in createDummy()
93 worker->IOWorkerContext::init(*eventBase); in createDummy()
99 folly::EventBase* eventBase, in init() argument
105 IOWorkerContext::init(*eventBase); in init()
257 folly::EventBase* eventBase, in construct() argument
262 eventBase = serverChannel->getEventBase(); in construct()
263 } else if (!eventBase) { in construct()
266 init(nullptr, eventBase, nullptr, fizzContext); in construct()
275 eventBase->add([eventBase, observer = std::move(observer)] { in construct()
[all …]
H A DIOWorkerContext.h53 void init(folly::EventBase& eventBase) { in init() argument
54 eventBase_ = &eventBase; in init()
55 replyQueue_ = std::make_unique<ReplyQueue>(ReplyInfoConsumer(eventBase)); in init()
57 eventBase.runInEventBaseThread( in init()
58 [queue = replyQueue_.get(), &evb = eventBase, alive = alive_] { in init()
/dports/devel/folly/folly-2021.12.27.00/folly/executors/
H A DIOThreadPoolExecutor.cpp172 return pickThread()->eventBase; in getEventBase()
180 return thread->eventBase; in getEventBase()
209 ioThread->eventBase = eventBaseManager_->getEventBase(); in threadRun()
213 ioThread->eventBase->runBeforeLoop(idler.get()); in threadRun()
215 ioThread->eventBase->runInEventBaseThread( in threadRun()
221 ioThread->eventBase->loopForever(); in threadRun()
225 ioThread->eventBase->loopOnce(); in threadRun()
232 ioThread->eventBase->loop(); in threadRun()
237 ioThread->eventBase = nullptr; in threadRun()
254 if (ioThread->eventBase) { in stopThreads()
[all …]
/dports/devel/folly/folly-2021.12.27.00/folly/experimental/
H A DTimerFD.cpp28 TimerFD::TimerFD(folly::EventBase* eventBase) in TimerFD() argument
29 : TimerFD(eventBase, createTimerFd()) {} in TimerFD()
31 TimerFD::TimerFD(folly::EventBase* eventBase, int fd) in TimerFD() argument
32 : folly::EventHandler(eventBase, NetworkSocket::fromFd(fd)), fd_(fd) { in TimerFD()
110 TimerFD::TimerFD(folly::EventBase* eventBase) : timeout_(eventBase, this) {}
125 folly::EventBase* eventBase, TimerFD* timerFd)
126 : folly::AsyncTimeout(eventBase), timerFd_(timerFd) {}
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/services/
H A DHTTPAcceptor.h27 folly::EventBase* eventBase,
31 timer_ = createTransactionTimeoutSet(eventBase);
32 Acceptor::init(serverSocket, eventBase, nullptr, fizzCtx);
54 folly::EventBase* eventBase) { in createTransactionTimeoutSet() argument
56 accConfig_.transactionIdleTimeout, eventBase); in createTransactionTimeoutSet()
/dports/net/cjdns/cjdns-cjdns-v21.1/util/
H A DPinger.c44 struct EventBase* eventBase; member
55 uint32_t now = Time_currentTimeMilliseconds(ping->pinger->eventBase); in callback()
71 int64_t now = Time_currentTimeMilliseconds(p->pinger->eventBase); in timeoutCallback()
115 .timeSent = Time_currentTimeMilliseconds(pinger->eventBase), in Pinger_newPing()
137 Timeout_setTimeout(timeoutCallback, ping, timeoutMilliseconds, pinger->eventBase, alloc); in Pinger_newPing()
139 Timeout_setTimeout(asyncSendPing, ping, 0, pinger->eventBase, alloc); in Pinger_newPing()
180 struct Pinger* Pinger_new(struct EventBase* eventBase, in Pinger_new() argument
190 .eventBase = eventBase, in Pinger_new()
/dports/net/cjdns/cjdns-cjdns-v21.1/util/events/libuv/
H A DTimeout.c112 struct EventBase* eventBase, in setTimeout() argument
117 struct EventBase_pvt* base = EventBase_privatize(eventBase); in setTimeout()
145 struct EventBase* eventBase, in Timeout__setTimeout() argument
150 return setTimeout(callback, callbackContext, milliseconds, 0, eventBase, allocator, file, line); in Timeout__setTimeout()
157 struct EventBase* eventBase, in Timeout__setInterval() argument
162 return setTimeout(callback, callbackContext, milliseconds, 1, eventBase, allocator, file, line); in Timeout__setInterval()
183 void Timeout_clearAll(struct EventBase* eventBase) in Timeout_clearAll() argument
185 struct EventBase_pvt* base = EventBase_privatize(eventBase); in Timeout_clearAll()
H A DEventBase.c75 void EventBase_beginLoop(struct EventBase* eventBase) in EventBase_beginLoop() argument
77 struct EventBase_pvt* ctx = Identity_check((struct EventBase_pvt*) eventBase); in EventBase_beginLoop()
94 void EventBase_endLoop(struct EventBase* eventBase) in EventBase_endLoop() argument
96 struct EventBase_pvt* ctx = Identity_check((struct EventBase_pvt*) eventBase); in EventBase_endLoop()
108 int EventBase_eventCount(struct EventBase* eventBase) in EventBase_eventCount() argument
111 struct EventBase_pvt* ctx = Identity_check((struct EventBase_pvt*) eventBase); in EventBase_eventCount()
H A DTime.c24 uint64_t Time_currentTimeMilliseconds(struct EventBase* eventBase) in Time_currentTimeMilliseconds() argument
26 struct EventBase_pvt* base = EventBase_privatize(eventBase); in Time_currentTimeMilliseconds()
30 uint64_t Time_currentTimeSeconds(struct EventBase* eventBase) in Time_currentTimeSeconds() argument
32 return Time_currentTimeMilliseconds(eventBase) / 1024; in Time_currentTimeSeconds()

12345678910>>...31