diff options
Diffstat (limited to 'src/components/hmi_message_handler/src/mb_controller.cc')
| -rw-r--r-- | src/components/hmi_message_handler/src/mb_controller.cc | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/src/components/hmi_message_handler/src/mb_controller.cc b/src/components/hmi_message_handler/src/mb_controller.cc index 681e57906a..b0388a5bf2 100644 --- a/src/components/hmi_message_handler/src/mb_controller.cc +++ b/src/components/hmi_message_handler/src/mb_controller.cc @@ -159,14 +159,13 @@ bool CMessageBrokerController::isResponse(Json::Value& message) { } void CMessageBrokerController::sendResponse(Json::Value& message) { - WebsocketSession* ws; std::map<std::string, WebsocketSession*>::iterator it; sync_primitives::AutoLock request_lock(mRequestListLock); std::string id = message["id"].asString(); it = mRequestList.find(id); if (it != mRequestList.end()) { - ws = it->second; + WebsocketSession* ws = it->second; ws->sendJsonMessage(message); mRequestList.erase(it); } @@ -182,7 +181,6 @@ void CMessageBrokerController::sendJsonMessage(Json::Value& message) { } // Send request - WebsocketSession* ws; std::map<std::string, WebsocketSession*>::iterator it; std::string method = message["method"].asString(); std::string component_name = GetComponentName(method); @@ -190,7 +188,7 @@ void CMessageBrokerController::sendJsonMessage(Json::Value& message) { sync_primitives::AutoLock lock(mControllersListLock); it = mControllersList.find(component_name); if (it != mControllersList.end()) { - ws = it->second; + WebsocketSession* ws = it->second; ws->sendJsonMessage(message); } } @@ -359,7 +357,6 @@ void CMessageBrokerController::deleteSubscriber(WebsocketSession* ws, int CMessageBrokerController::getSubscribersFd( std::string name, std::vector<WebsocketSession*>& result) { int res = 0; - std::map<std::string, WebsocketSession*>::iterator it; sync_primitives::AutoLock lock(mSubscribersListLock); std::pair<std::multimap<std::string, WebsocketSession*>::iterator, |