Rename buffer_mutex → _buffer_mutex.
All checks were successful
continuous-integration/drone/push Build is passing
All checks were successful
continuous-integration/drone/push Build is passing
This commit is contained in:
parent
cdd7a465d2
commit
185ab91978
@ -172,7 +172,7 @@ protected:
|
|||||||
*
|
*
|
||||||
* @since 0.1.0
|
* @since 0.1.0
|
||||||
*/
|
*/
|
||||||
mutex buffer_mutex;
|
mutex _buffer_mutex;
|
||||||
|
|
||||||
/*!
|
/*!
|
||||||
* @brief Make a HTTP request.
|
* @brief Make a HTTP request.
|
||||||
|
@ -68,17 +68,17 @@ answer_type Connection::del(const endpoint_variant &endpoint,
|
|||||||
|
|
||||||
string Connection::get_new_stream_contents()
|
string Connection::get_new_stream_contents()
|
||||||
{
|
{
|
||||||
buffer_mutex.lock();
|
_buffer_mutex.lock();
|
||||||
auto &buffer{get_buffer()};
|
auto &buffer{get_buffer()};
|
||||||
const string buffer_copy{buffer};
|
const string buffer_copy{buffer};
|
||||||
buffer.clear();
|
buffer.clear();
|
||||||
buffer_mutex.unlock();
|
_buffer_mutex.unlock();
|
||||||
return buffer_copy;
|
return buffer_copy;
|
||||||
}
|
}
|
||||||
|
|
||||||
vector<event_type> Connection::get_new_events()
|
vector<event_type> Connection::get_new_events()
|
||||||
{
|
{
|
||||||
buffer_mutex.lock();
|
_buffer_mutex.lock();
|
||||||
auto &buffer{get_buffer()};
|
auto &buffer{get_buffer()};
|
||||||
vector<event_type> events;
|
vector<event_type> events;
|
||||||
|
|
||||||
@ -103,7 +103,7 @@ vector<event_type> Connection::get_new_events()
|
|||||||
buffer.erase(0, endpos);
|
buffer.erase(0, endpos);
|
||||||
}
|
}
|
||||||
|
|
||||||
buffer_mutex.unlock();
|
_buffer_mutex.unlock();
|
||||||
return events;
|
return events;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -280,9 +280,9 @@ size_t CURLWrapper::writer_body(char *data, size_t size, size_t nmemb)
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
buffer_mutex.lock();
|
_buffer_mutex.lock();
|
||||||
_curl_buffer_body.append(data, size * nmemb);
|
_curl_buffer_body.append(data, size * nmemb);
|
||||||
buffer_mutex.unlock();
|
_buffer_mutex.unlock();
|
||||||
|
|
||||||
return size * nmemb;
|
return size * nmemb;
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user