Home
last modified time | relevance | path

Searched refs:incomingQueue_ (Results 1 – 4 of 4) sorted by relevance

/ohos5.0/foundation/communication/netstack/utils/http_over_curl/src/
H A Depoll_request_handler.cpp29 incomingQueue_(std::make_shared<HttpOverCurl::ThreadSafeStorage<RequestInfo *>>()) in EpollRequestHandler()
42 incomingQueue_->Push(requestInfo); in Process()
62 EpollMultiDriver requestHandler(incomingQueue_); in WorkingThread()
H A Depoll_multi_driver.cpp26 : incomingQueue_(incomingQueue) in EpollMultiDriver()
34 incomingQueue_->GetSyncEvent().RegisterForPolling(poller_); in Initialize()
73 if (incomingQueue_->GetSyncEvent().IsItYours(events[idx].data.fd)) { in Step()
85 auto requestsToAdd = incomingQueue_->Flush(); in IncomingRequestCallback()
/ohos5.0/foundation/communication/netstack/utils/http_over_curl/include/
H A Depoll_request_handler.h46 std::shared_ptr<HttpOverCurl::ThreadSafeStorage<RequestInfo *>> incomingQueue_; variable
H A Depoll_multi_driver.h63 std::shared_ptr<HttpOverCurl::ThreadSafeStorage<RequestInfo *>> incomingQueue_; variable