diff options
| -rw-r--r-- | engines/scumm/he/moonbase/net_main.cpp | 18 |
1 files changed, 12 insertions, 6 deletions
diff --git a/engines/scumm/he/moonbase/net_main.cpp b/engines/scumm/he/moonbase/net_main.cpp index 28f865f06d..f93f018ef8 100644 --- a/engines/scumm/he/moonbase/net_main.cpp +++ b/engines/scumm/he/moonbase/net_main.cpp @@ -20,6 +20,8 @@ * */ +#include "backends/networking/curl/connectionmanager.h" + #include "scumm/he/intern_he.h" #include "scumm/he/moonbase/moonbase.h" #include "scumm/he/moonbase/net_main.h" @@ -270,13 +272,15 @@ int32 Net::startQuerySessions() { if (!_sessionsBeingQueried) { // Do not run parallel queries debug(1, "Net::startQuerySessions()"); // StartQuerySessions - Networking::PostRequest rq(_serverprefix + "/lobbies", + Networking::PostRequest *rq = new Networking::PostRequest(_serverprefix + "/lobbies", new Common::Callback<Net, Common::JSONValue *>(this, &Net::startQuerySessionsCallback), new Common::Callback<Net, Networking::ErrorResponse>(this, &Net::startQuerySessionsErrorCallback)); _sessionsBeingQueried = true; - rq.start(); + rq->start(); + + ConnMan.addRequest(rq); } if (!_sessions) @@ -388,14 +392,16 @@ int Net::remoteSendData(int typeOfSend, int sendTypeParam, int type, Common::Str debug("Package to send: %s", res.c_str()); - Networking::PostRequest rq(_serverprefix + "/packet", + Networking::PostRequest *rq = new Networking::PostRequest(_serverprefix + "/packet", new Common::Callback<Net, Common::JSONValue *>(this, &Net::remoteSendDataCallback), new Common::Callback<Net, Networking::ErrorResponse>(this, &Net::remoteSendDataErrorCallback)); - rq.setPostData(buf, res.size()); - rq.setContentType("application/json"); + rq->setPostData(buf, res.size()); + rq->setContentType("application/json"); - rq.start(); + rq->start(); + + ConnMan.addRequest(rq); if (!wait) return 0; |