BeamMP/BeamMP-Server
1
0
Fork 0
mirror of https://github.com/BeamMP/BeamMP-Server.git synced 2025-07-01 15:26:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

reuse http connections

Browse Source
This commit is contained in:
Lion 2023-12-22 13:13:04 +01:00 committed by GitHub
parent 8b79049e7e
commit c836282c0c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/Http.cpp
View File

@ -16,16 +16,24 @@ static std::shared_ptr<httplib::SSLClient> GetOrCreateClient(const std::string&
static thread_local std::unordered_map<std::pair<std::string, int>, std::shared_ptr<httplib::SSLClient>> clients {}; static thread_local std::unordered_map<std::pair<std::string, int>, std::shared_ptr<httplib::SSLClient>> clients {};
const auto idx = std::pair<std::string, int>(host, port); const auto idx = std::pair<std::string, int>(host, port);
if (!clients.contains(idx)) { if (!clients.contains(idx)) {
beammp_tracef("Creating connection to {}:{}", host, port);
clients.emplace(std::make_shared<httplib::SSLClient>(host, port)); clients.emplace(std::make_shared<httplib::SSLClient>(host, port));
auto client = clients.at(idx);
client->enable_server_certificate_verification(false);
client->set_address_family(AF_INET);
client->set_read_timeout(std::chrono::seconds(10));
return client;
} else {
beammp_tracef("Reusing connection to {}:{}", host, port);
return clients.at(idx);
} }
clients.at(idx);
} }
std::string Http::GET(const std::string& host, int port, const std::string& target, unsigned int* status) { std::string Http::GET(const std::string& host, int port, const std::string& target, unsigned int* status) {
httplib::SSLClient client(host, port); auto client = GetOrCreateClient(host, port);
client.enable_server_certificate_verification(false); beammp_assert(client != nullptr);
client.set_address_family(AF_INET); beammp_assert(client.is_valid());
auto res = client.Get(target.c_str()); auto res = client->Get(target.c_str());
if (res) { if (res) {
if (status) { if (status) {
*status = res->status; *status = res->status;
@ -37,12 +45,10 @@ std::string Http::GET(const std::string& host, int port, const std::string& targ
} }
std::string Http::POST(const std::string& host, int port, const std::string& target, const std::string& body, const std::string& ContentType, unsigned int* status, const httplib::Headers& headers) { std::string Http::POST(const std::string& host, int port, const std::string& target, const std::string& body, const std::string& ContentType, unsigned int* status, const httplib::Headers& headers) {
httplib::SSLClient client(host, port); auto client = GetOrCreateClient(host, port);
client.set_read_timeout(std::chrono::seconds(10)); beammp_assert(client != nullptr);
beammp_assert(client.is_valid()); beammp_assert(client.is_valid());
client.enable_server_certificate_verification(false); auto res = client->Post(target.c_str(), headers, body.c_str(), body.size(), ContentType.c_str());
client.set_address_family(AF_INET);
auto res = client.Post(target.c_str(), headers, body.c_str(), body.size(), ContentType.c_str());
if (res) { if (res) {
if (status) { if (status) {
*status = res->status; *status = res->status;