cheng/wxWidgets
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Collect mutex and data protected by it in a single struct

Browse Source 
Also use critical section instead of a mutex, as this is more efficient
under MSW.

Main purpose of this commit is to make it clear that this mutex/critical
section is only used together with the data from the same struct.

No real changes.
This commit is contained in:
Vadim Zeitlin 2021-01-10 20:42:38 +01:00
parent 7d1a7ef942
commit d88762d2f1
2 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
include/wx/private/webrequest_curl.h
View File

@ -145,8 +145,13 @@ private:
wxMutex m_mutex;
wxCondition m_condition;
bool m_shuttingDown;
wxMutex m_cancelledMutex;
wxVector< wxObjectDataPtr<wxWebRequestCURL> > m_cancelledRequests;
// MT-safe vector of requests for which Cancel() was called.
struct CancelledData
{
wxCriticalSection cs;
wxVector< wxObjectDataPtr<wxWebRequestCURL> > requests;
} m_cancelled;
static int ms_activeSessions;

12
src/common/webrequest_curl.cpp
View File

@ -448,11 +448,11 @@ wxThread::ExitCode wxWebSessionCURL::Entry()
{
// Handle cancelled requests
{
wxMutexLocker lock(m_cancelledMutex);
while ( !m_cancelledRequests.empty() )
wxCriticalSectionLocker lock(m_cancelled.cs);
while ( !m_cancelled.requests.empty() )
{
wxObjectDataPtr<wxWebRequestCURL> request(m_cancelledRequests.back());
m_cancelledRequests.pop_back();
wxObjectDataPtr<wxWebRequestCURL> request(m_cancelled.requests.back());
m_cancelled.requests.pop_back();
curl_multi_remove_handle(m_handle, request->GetHandle());
request->SetState(wxWebRequest::State_Cancelled);
}
@ -527,9 +527,9 @@ void wxWebSessionCURL::CancelRequest(wxWebRequestCURL* request)
{
// Add the request to a list of threads that will be removed from the curl
// multi handle in the worker thread
wxMutexLocker lock(m_cancelledMutex);
wxCriticalSectionLocker lock(m_cancelled.cs);
request->IncRef();
m_cancelledRequests.push_back(wxObjectDataPtr<wxWebRequestCURL>(request));
m_cancelled.requests.push_back(wxObjectDataPtr<wxWebRequestCURL>(request));
}
wxVersionInfo wxWebSessionCURL::GetLibraryVersionInfo()