summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/connection.cpp8
-rw-r--r--src/curl_wrapper.cpp4
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;
}