summaryrefslogtreecommitdiffstats
path: root/src/SocketReader.cpp
diff options
context:
space:
mode:
authorDavid Robillard <d@drobilla.net>2019-03-07 22:41:35 +0100
committerDavid Robillard <d@drobilla.net>2019-03-08 09:07:18 +0100
commit8eba534e99cd8db29cca03035a115312935a22a3 (patch)
treecc13f89d5bdad33935fa4e8c396a740229be6b1e /src/SocketReader.cpp
parentacb958e95d0e8ca1b0dd912fe8bbf2e14e5f74e9 (diff)
downloadingen-8eba534e99cd8db29cca03035a115312935a22a3.tar.gz
ingen-8eba534e99cd8db29cca03035a115312935a22a3.tar.bz2
ingen-8eba534e99cd8db29cca03035a115312935a22a3.zip
Use smart pointers to handle FILE streams
Diffstat (limited to 'src/SocketReader.cpp')
-rw-r--r--src/SocketReader.cpp10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/SocketReader.cpp b/src/SocketReader.cpp
index de2f3342..590b40cd 100644
--- a/src/SocketReader.cpp
+++ b/src/SocketReader.cpp
@@ -15,6 +15,7 @@
*/
#include <cerrno>
+#include <memory>
#include <poll.h>
@@ -93,7 +94,8 @@ SocketReader::run()
LV2_URID_Map* map = &_world.uri_map().urid_map_feature()->urid_map;
// Open socket as a FILE for reading directly with serd
- FILE* f = fdopen(_socket->fd(), "r");
+ std::unique_ptr<FILE, decltype(&fclose)> f{fdopen(_socket->fd(), "r"),
+ &fclose};
if (!f) {
_world.log().error(fmt("Failed to open connection (%1%)\n")
% strerror(errno));
@@ -134,7 +136,7 @@ SocketReader::run()
nullptr);
serd_env_set_base_uri(_env, sord_node_to_serd_node(base_uri));
- serd_reader_start_stream(reader, f, (const uint8_t*)"(socket)", false);
+ serd_reader_start_stream(reader, f.get(), (const uint8_t*)"(socket)", false);
// Make an AtomReader to call Ingen Interface methods based on Atom
AtomReader ar(_world.uri_map(), _world.uris(), _world.log(), _iface);
@@ -145,7 +147,7 @@ SocketReader::run()
pfd.revents = 0;
while (!_exit_flag) {
- if (feof(f)) {
+ if (feof(f.get())) {
break; // Lost connection
}
@@ -187,7 +189,7 @@ SocketReader::run()
std::lock_guard<std::mutex> lock(_world.rdf_mutex());
// Destroy everything
- fclose(f);
+ f.reset();
sord_inserter_free(_inserter);
serd_reader_end_stream(reader);
sratom_free(sratom);