summaryrefslogtreecommitdiffstats
path: root/src/SocketWriter.cpp
diff options
context:
space:
mode:
authorDavid Robillard <d@drobilla.net>2015-02-07 01:05:13 +0000
committerDavid Robillard <d@drobilla.net>2015-02-07 01:05:13 +0000
commit82ab6f73fab060860addb30691d0e926b4723ee2 (patch)
treed468ccbcae5479161e3f2c899d9e302848ce4e8f /src/SocketWriter.cpp
parent8dad2d6e0805d0db2cca66f5901235884aad92da (diff)
downloadingen-82ab6f73fab060860addb30691d0e926b4723ee2.tar.gz
ingen-82ab6f73fab060860addb30691d0e926b4723ee2.tar.bz2
ingen-82ab6f73fab060860addb30691d0e926b4723ee2.zip
Demodularize socket stuff.
git-svn-id: http://svn.drobilla.net/lad/trunk/ingen@5535 a436a847-0d15-0410-975c-d299462d15a1
Diffstat (limited to 'src/SocketWriter.cpp')
-rw-r--r--src/SocketWriter.cpp96
1 files changed, 96 insertions, 0 deletions
diff --git a/src/SocketWriter.cpp b/src/SocketWriter.cpp
new file mode 100644
index 00000000..8ce8354a
--- /dev/null
+++ b/src/SocketWriter.cpp
@@ -0,0 +1,96 @@
+/*
+ This file is part of Ingen.
+ Copyright 2012-2015 David Robillard <http://drobilla.net/>
+
+ Ingen is free software: you can redistribute it and/or modify it under the
+ terms of the GNU Affero General Public License as published by the Free
+ Software Foundation, either version 3 of the License, or any later version.
+
+ Ingen is distributed in the hope that it will be useful, but WITHOUT ANY
+ WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
+ A PARTICULAR PURPOSE. See the GNU Affero General Public License for details.
+
+ You should have received a copy of the GNU Affero General Public License
+ along with Ingen. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#include <errno.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+
+#include "ingen/SocketWriter.hpp"
+#include "ingen/URIMap.hpp"
+
+#ifndef MSG_NOSIGNAL
+# define MSG_NOSIGNAL 0
+#endif
+
+namespace Ingen {
+
+static size_t
+socket_sink(const void* buf, size_t len, void* stream)
+{
+ SocketWriter* writer = (SocketWriter*)stream;
+ ssize_t ret = send(writer->fd(), buf, len, MSG_NOSIGNAL);
+ if (ret < 0) {
+ return 0;
+ }
+ return ret;
+}
+
+SocketWriter::SocketWriter(URIMap& map,
+ URIs& uris,
+ const Raul::URI& uri,
+ SPtr<Raul::Socket> sock)
+ : AtomWriter(map, uris, *this)
+ , _map(map)
+ , _sratom(sratom_new(&map.urid_map_feature()->urid_map))
+ , _uri(uri)
+ , _socket(sock)
+{
+ // Use <ingen:/root/> as base URI so e.g. </foo/bar> will be a path
+ _base = serd_node_from_string(SERD_URI, (const uint8_t*)"ingen:/root/");
+
+ serd_uri_parse(_base.buf, &_base_uri);
+
+ _env = serd_env_new(&_base);
+ _writer = serd_writer_new(
+ SERD_TURTLE,
+ (SerdStyle)(SERD_STYLE_RESOLVED|SERD_STYLE_ABBREVIATED|SERD_STYLE_CURIED),
+ _env,
+ &_base_uri,
+ socket_sink,
+ this);
+
+ sratom_set_sink(_sratom,
+ (const char*)_base.buf,
+ (SerdStatementSink)serd_writer_write_statement,
+ (SerdEndSink)serd_writer_end_anon,
+ _writer);
+}
+
+SocketWriter::~SocketWriter()
+{
+ sratom_free(_sratom);
+}
+
+bool
+SocketWriter::write(const LV2_Atom* msg)
+{
+ sratom_write(_sratom, &_map.urid_unmap_feature()->urid_unmap, 0,
+ NULL, NULL, msg->type, msg->size, LV2_ATOM_BODY_CONST(msg));
+ serd_writer_finish(_writer);
+ return true;
+}
+
+void
+SocketWriter::bundle_end()
+{
+ AtomWriter::bundle_end();
+
+ // Send a NULL byte to indicate end of bundle
+ const char end[] = { 0 };
+ send(fd(), end, 1, MSG_NOSIGNAL);
+}
+
+} // namespace Ingen