edg-l/ddnet
1
0
Fork 0
mirror of https://github.com/ddnet/ddnet.git synced 2024-11-09 09:38:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #8066 from Robyt3/Http-Error-Fixes

Browse source 
Fix HTTP client shutdown and deadlock on request error
This commit is contained in:
heinrich5991 2024-03-05 19:46:33 +00:00 committed by GitHub
parent f3de37d9d4 9323e18616
commit 819270c453
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 16 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/engine/shared/http.cpp
View file

@ -471,7 +471,7 @@ void CHttp::RunLoop()
if(PollCode != CURLM_OK) if(PollCode != CURLM_OK)
{ {
Lock.lock(); Lock.lock();
log_error("http", "Failed multi wait: %s", curl_multi_strerror(PollCode)); log_error("http", "curl_multi_poll failed: %s", curl_multi_strerror(PollCode));
m_State = CHttp::ERROR; m_State = CHttp::ERROR;
break; break;
} }
@ -480,7 +480,7 @@ void CHttp::RunLoop()
if(PerformCode != CURLM_OK) if(PerformCode != CURLM_OK)
{ {
Lock.lock(); Lock.lock();
log_error("http", "Failed multi perform: %s", curl_multi_strerror(PerformCode)); log_error("http", "curl_multi_perform failed: %s", curl_multi_strerror(PerformCode));
m_State = CHttp::ERROR; m_State = CHttp::ERROR;
break; break;
} }
@ -514,23 +514,33 @@ void CHttp::RunLoop()
CURL *pEH = curl_easy_init(); CURL *pEH = curl_easy_init();
if(!pEH) if(!pEH)
{
log_error("http", "curl_easy_init failed");
goto error_init; goto error_init;
}
if(!pRequest->ConfigureHandle(pEH)) if(!pRequest->ConfigureHandle(pEH))
goto error_configure; {
curl_easy_cleanup(pEH);
str_copy(pRequest->m_aErr, "Failed to initialize request");
pRequest->OnCompletionInternal(nullptr, CURLE_ABORTED_BY_CALLBACK);
NewRequests.pop_front();
continue;
}
if(curl_multi_add_handle(m_pMultiH, pEH) != CURLM_OK) if(curl_multi_add_handle(m_pMultiH, pEH) != CURLM_OK)
{
log_error("http", "curl_multi_add_handle failed");
goto error_configure; goto error_configure;
}
m_RunningRequests.emplace(pEH, std::move(pRequest)); m_RunningRequests.emplace(pEH, std::move(pRequest));
NewRequests.pop_front(); NewRequests.pop_front();
continue; continue;
error_configure: error_configure:
curl_easy_cleanup(pEH); curl_easy_cleanup(pEH);
error_init: error_init:
log_error("http", "failed to start new request");
Lock.lock(); Lock.lock();
m_State = CHttp::ERROR; m_State = CHttp::ERROR;
break; break;
@ -579,7 +589,7 @@ void CHttp::Run(std::shared_ptr<IHttpRequest> pRequest)
{ {
std::shared_ptr<CHttpRequest> pRequestImpl = std::static_pointer_cast<CHttpRequest>(pRequest); std::shared_ptr<CHttpRequest> pRequestImpl = std::static_pointer_cast<CHttpRequest>(pRequest);
std::unique_lock Lock(m_Lock); std::unique_lock Lock(m_Lock);
if(m_Shutdown) if(m_Shutdown || m_State == CHttp::ERROR)
{ {
str_copy(pRequestImpl->m_aErr, "Shutting down"); str_copy(pRequestImpl->m_aErr, "Shutting down");
pRequestImpl->OnCompletionInternal(nullptr, CURLE_ABORTED_BY_CALLBACK); pRequestImpl->OnCompletionInternal(nullptr, CURLE_ABORTED_BY_CALLBACK);

1
src/engine/shared/http.h
View file

@ -255,7 +255,6 @@ class CHttp : public IHttp
{ {
UNINITIALIZED, UNINITIALIZED,
RUNNING, RUNNING,
STOPPING,
ERROR, ERROR,
}; };