Skip to content

Commit cae0d65

Browse files
committed
Merge branch 'sprint/24Q4' of https://github.com/madanagopalt/rdkservices into sprint/24Q4
2 parents d6be1fc + 5a63af2 commit cae0d65

File tree

1 file changed

+20
-20
lines changed

1 file changed

+20
-20
lines changed

AppManager/WebSocket.cpp

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,9 @@
66
namespace WPEFramework {
77
namespace Plugin {
88

9-
ConnectionMetaData::ConnectionMetaData(int id, websocketpp::connection_hdl handle, std::string uri)
9+
ConnectionMetaData::ConnectionMetaData(int id, websocketpp::connection_hdl connectionHandle, std::string uri)
1010
: mIdentifier(id)
11-
, mHandle(handle)
11+
, mHandle(connectionHandle)
1212
, mStatus("Connecting")
1313
, mURI(uri)
1414
, mServerResponse("N/A")
@@ -21,47 +21,47 @@ namespace Plugin {
2121
sem_destroy(&mEventSem);
2222
}
2323

24-
void ConnectionMetaData::onOpen(WebSocketAsioClient * c, websocketpp::connection_hdl handle)
24+
void ConnectionMetaData::onOpen(WebSocketAsioClient * webSocketClient, websocketpp::connection_hdl connectionHandle)
2525
{
2626
mStatus = "Open";
2727

28-
WebSocketAsioClient::connection_ptr con = c->get_con_from_hdl(handle);
29-
mServerResponse = con->get_response_header("Server");
28+
WebSocketAsioClient::connection_ptr clientConnection = webSocketClient->get_con_from_hdl(connectionHandle);
29+
mServerResponse = clientConnection->get_response_header("Server");
3030
sem_post(&mEventSem);
3131
}
3232

33-
void ConnectionMetaData::onFail(WebSocketAsioClient * c, websocketpp::connection_hdl handle)
33+
void ConnectionMetaData::onFail(WebSocketAsioClient * webSocketClient, websocketpp::connection_hdl connectionHandle)
3434
{
3535
mStatus = "Failed";
3636

37-
WebSocketAsioClient::connection_ptr con = c->get_con_from_hdl(handle);
38-
mServerResponse = con->get_response_header("Server");
39-
mErrorReason = con->get_ec().message();
37+
WebSocketAsioClient::connection_ptr clientConnection = webSocketClient->get_con_from_hdl(connectionHandle);
38+
mServerResponse = clientConnection->get_response_header("Server");
39+
mErrorReason = clientConnection->get_ec().message();
4040
sem_post(&mEventSem);
4141
}
4242

43-
void ConnectionMetaData::onClose(WebSocketAsioClient * c, websocketpp::connection_hdl handle)
43+
void ConnectionMetaData::onClose(WebSocketAsioClient * webSocketClient, websocketpp::connection_hdl connectionHandle)
4444
{
4545
mStatus = "Closed";
46-
WebSocketAsioClient::connection_ptr con = c->get_con_from_hdl(handle);
47-
std::stringstream s;
48-
s << "close code: " << con->get_remote_close_code() << " ("
49-
<< websocketpp::close::status::get_string(con->get_remote_close_code())
50-
<< "), close reason: " << con->get_remote_close_reason();
51-
mErrorReason = s.str();
46+
WebSocketAsioClient::connection_ptr clientConnection = webSocketClient->get_con_from_hdl(connectionHandle);
47+
std::stringstream errorReason;
48+
errorReason << "close code: " << clientConnection->get_remote_close_code() << " ("
49+
<< websocketpp::close::status::get_string(clientConnection->get_remote_close_code())
50+
<< "), close reason: " << clientConnection->get_remote_close_reason();
51+
mErrorReason = errorReason.str();
5252
sem_post(&mEventSem);
5353
}
5454

55-
void ConnectionMetaData::onMessage(websocketpp::connection_hdl, WebSocketAsioClient::message_ptr msg)
55+
void ConnectionMetaData::onMessage(websocketpp::connection_hdl connectionHandle, WebSocketAsioClient::message_ptr serverMessage)
5656
{
5757
mStatus = "Response";
58-
if (msg->get_opcode() == websocketpp::frame::opcode::text)
58+
if (serverMessage->get_opcode() == websocketpp::frame::opcode::text)
5959
{
60-
mLastMessage = msg->get_payload();
60+
mLastMessage = serverMessage->get_payload();
6161
}
6262
else
6363
{
64-
mLastMessage = websocketpp::utility::to_hex(msg->get_payload());
64+
mLastMessage = websocketpp::utility::to_hex(serverMessage->get_payload());
6565
}
6666
sem_post(&mEventSem);
6767
}

0 commit comments

Comments
 (0)