mirror/musikcube
1
0
Fork 0
mirror of https://github.com/clangen/musikcube.git synced 2024-10-02 04:52:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed a memory leak in WebSocketClient

Browse Source
This commit is contained in:
casey langen 2020-10-08 19:52:20 -07:00
parent c2573fc945
commit e0709afdb3
1 changed files with 20 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
src/core/net/WebSocketClient.cpp
View File

@ -121,21 +121,24 @@ WebSocketClient::WebSocketClient(Listener* listener) {
}
else if (name == "send_raw_query") {
auto query = this->messageIdToQuery[messageId];
auto& options = responseJson["options"];
if (options.find("success") != options.end() && options["success"] == false) {
this->listener->OnClientQueryFailed(
this, messageId, query, ErrorCode::QueryFailed);
}
else {
std::string rawResult;
if (extractRawQueryResult(responseJson, rawResult)) {
if (query) {
query->DeserializeResult(rawResult);
this->listener->OnClientQuerySucceeded(this, messageId, query);
}
else {
this->listener->OnClientQueryFailed(
this, messageId, query, ErrorCode::QueryNotFound);
if (query) {
this->messageIdToQuery.erase(messageId);
auto& options = responseJson["options"];
if (options.find("success") != options.end() && options["success"] == false) {
this->listener->OnClientQueryFailed(
this, messageId, query, ErrorCode::QueryFailed);
}
else {
std::string rawResult;
if (extractRawQueryResult(responseJson, rawResult)) {
if (query) {
query->DeserializeResult(rawResult);
this->listener->OnClientQuerySucceeded(this, messageId, query);
}
else {
this->listener->OnClientQueryFailed(
this, messageId, query, ErrorCode::QueryNotFound);
}
}
}
}
@ -241,6 +244,8 @@ void WebSocketClient::SendPendingQueries() {
createSendRawQueryRequest(query->SerializeQuery(), messageId),
websocketpp::frame::opcode::text);
}
this->messageIdToQuery.clear();
}
void WebSocketClient::SetState(State state) {