Lines Matching defs:std
37 void EventManager::AddListener(napi_env env, const std::string &type, napi_value callback, bool once,
40 std::lock_guard lock(mutexForListenersAndEmitByUv_);
41 auto it = std::remove_if(listeners_.begin(), listeners_.end(),
50 void EventManager::DeleteListener(const std::string &type, napi_value callback)
52 std::lock_guard lock(mutexForListenersAndEmitByUv_);
54 std::remove_if(listeners_.begin(), listeners_.end(), [type, callback](const EventListener &listener) -> bool {
60 void EventManager::Emit(const std::string &type, const std::pair<napi_value, napi_value> &argv)
62 std::lock_guard lock(mutexForEmitAndEmitByUv_);
64 std::for_each(listeners.begin(), listeners.end(), [type, argv](const EventListener &listener) {
76 auto it = std::remove_if(listeners_.begin(), listeners_.end(),
83 std::lock_guard<std::mutex> lock(dataMutex_);
89 std::lock_guard<std::mutex> lock(dataMutex_);
93 void EventManager::EmitByUvWithoutCheckShared(const std::string &type, void *data, void (*Handler)(uv_work_t *, int))
95 std::lock_guard lock1(mutexForEmitAndEmitByUv_);
96 std::lock_guard lock2(mutexForListenersAndEmitByUv_);
97 bool foundHeader = std::find_if(listeners_.begin(), listeners_.end(), [](const EventListener &listener) {
101 bool foundHeaders = std::find_if(listeners_.begin(), listeners_.end(), [](const EventListener &listener) {
106 auto tempMap = static_cast<std::map<std::string, std::string> *>(data);
111 auto tempMap = static_cast<std::map<std::string, std::string> *>(data);
116 auto tempMap = static_cast<std::map<std::string, std::string> *>(data);
121 std::for_each(listeners_.begin(), listeners_.end(), [type, data, Handler, this](const EventListener &listener) {
131 std::lock_guard<std::mutex> lock(dataQueueMutex_);
137 std::lock_guard<std::mutex> lock(dataQueueMutex_);
147 void EventManager::EmitByUvWithoutCheck(const std::string &type, void *data, void(Handler)(uv_work_t *, int status))
149 std::lock_guard lock1(mutexForEmitAndEmitByUv_);
150 std::lock_guard lock2(mutexForListenersAndEmitByUv_);
151 bool foundHeader = std::find_if(listeners_.begin(), listeners_.end(), [](const EventListener &listener) {
154 bool foundHeaders = std::find_if(listeners_.begin(), listeners_.end(), [](const EventListener &listener) {
159 auto tempMap = static_cast<std::map<std::string, std::string> *>(data);
164 auto tempMap = static_cast<std::map<std::string, std::string> *>(data);
169 auto tempMap = static_cast<std::map<std::string, std::string> *>(data);
174 std::for_each(listeners_.begin(), listeners_.end(), [type, data, Handler, this](const EventListener &listener) {
182 void EventManager::EmitByUv(const std::string &type, void *data, void(Handler)(uv_work_t *, int status))
184 std::lock_guard lock1(mutexForEmitAndEmitByUv_);
185 std::lock_guard lock2(mutexForListenersAndEmitByUv_);
189 bool foundHeader = std::find_if(listeners_.begin(), listeners_.end(), [](const EventListener &listener) {
192 bool foundHeaders = std::find_if(listeners_.begin(), listeners_.end(), [](const EventListener &listener) {
197 auto tempMap = static_cast<std::map<std::string, std::string> *>(data);
202 auto tempMap = static_cast<std::map<std::string, std::string> *>(data);
207 auto tempMap = static_cast<std::map<std::string, std::string> *>(data);
212 std::for_each(listeners_.begin(), listeners_.end(), [type, data, Handler, this](const EventListener &listener) {
220 bool EventManager::HasEventListener(const std::string &type)
222 std::lock_guard lock(mutexForListenersAndEmitByUv_);
223 return std::any_of(listeners_.begin(), listeners_.end(),
227 void EventManager::DeleteListener(const std::string &type)
229 std::lock_guard lock(mutexForListenersAndEmitByUv_);
230 auto it = std::remove_if(listeners_.begin(), listeners_.end(),
235 std::unordered_set<EventManager *> EventManager::validManager_;
236 std::mutex EventManager::mutexForManager_;
244 std::lock_guard lock(mutexForManager_);
260 std::lock_guard lock(mutexForManager_);
269 std::lock_guard lock(mutexForManager_);
298 const std::string &EventManager::GetWebSocketTextData()
308 const std::string &EventManager::GetWebSocketBinaryData()
330 std::unique_lock<std::mutex> lock(sockRcvThdMtx_);
337 std::unique_lock<std::mutex> lock(sockRcvThdMtx_);
351 void EventManager::SetWebSocketUserData(const std::shared_ptr<Websocket::UserData> &userData)
353 std::lock_guard<std::mutex> lock(dataMutex_);
357 std::shared_ptr<Websocket::UserData> EventManager::GetWebSocketUserData()
359 std::lock_guard<std::mutex> lock(dataMutex_);
363 UvWorkWrapper::UvWorkWrapper(void *theData, napi_env theEnv, std::string eventType, EventManager *eventManager)
364 : data(theData), env(theEnv), type(std::move(eventType)), manager(eventManager)
368 UvWorkWrapperShared::UvWorkWrapperShared(void *theData, napi_env theEnv, std::string eventType,
369 const std::shared_ptr<EventManager> &eventManager)
370 : data(theData), env(theEnv), type(std::move(eventType)), manager(eventManager)