/dports/devel/folly/folly-2021.12.27.00/folly/io/async/test/ |
H A D | EventBaseBenchmark.cpp | 25 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 D | HHWheelTimerTest.cpp | 56 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 D | NotificationQueueTest.cpp | 72 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 D | HHWheelTimerSlowTests.cpp | 59 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 D | AsyncSSLSocketTest.cpp | 385 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 D | SSLSessionTest.cpp | 69 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 D | EventBaseTestLib.h | 1538 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 D | AtomicNotificationQueueTest.cpp | 113 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 D | TEventJobQueueTest.cpp | 54 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 D | EventHandler.cpp | 26 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 D | EventBaseManager.cpp | 43 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 D | AsyncPipe.h | 41 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 D | EventBaseManager.h | 77 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 D | AsyncServerSocket.cpp | 65 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 D | AsyncTimeout.cpp | 41 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 D | InterfaceWaiter.c | 28 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 D | Cpp2Worker.h | 78 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 D | IOWorkerContext.h | 53 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 D | IOThreadPoolExecutor.cpp | 172 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 D | TimerFD.cpp | 28 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 D | HTTPAcceptor.h | 27 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 D | Pinger.c | 44 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 D | Timeout.c | 112 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 D | EventBase.c | 75 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 D | Time.c | 24 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()
|