diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/connection.cpp | 8 | ||||
-rw-r--r-- | src/curl_wrapper.cpp | 4 |
2 files changed, 6 insertions, 6 deletions
diff --git a/src/connection.cpp b/src/connection.cpp index 1b19833..81297ce 100644 --- a/src/connection.cpp +++ b/src/connection.cpp @@ -68,17 +68,17 @@ answer_type Connection::del(const endpoint_variant &endpoint, string Connection::get_new_stream_contents() { - buffer_mutex.lock(); + _buffer_mutex.lock(); auto &buffer{get_buffer()}; const string buffer_copy{buffer}; buffer.clear(); - buffer_mutex.unlock(); + _buffer_mutex.unlock(); return buffer_copy; } vector<event_type> Connection::get_new_events() { - buffer_mutex.lock(); + _buffer_mutex.lock(); auto &buffer{get_buffer()}; vector<event_type> events; @@ -103,7 +103,7 @@ vector<event_type> Connection::get_new_events() buffer.erase(0, endpos); } - buffer_mutex.unlock(); + _buffer_mutex.unlock(); return events; } diff --git a/src/curl_wrapper.cpp b/src/curl_wrapper.cpp index 97c519d..bfa59ee 100644 --- a/src/curl_wrapper.cpp +++ b/src/curl_wrapper.cpp @@ -280,9 +280,9 @@ size_t CURLWrapper::writer_body(char *data, size_t size, size_t nmemb) return 0; } - buffer_mutex.lock(); + _buffer_mutex.lock(); _curl_buffer_body.append(data, size * nmemb); - buffer_mutex.unlock(); + _buffer_mutex.unlock(); return size * nmemb; } |