X-Git-Url: https://gerrit.akraino.org/r/gitweb?a=blobdiff_plain;f=src%2Ftype3_AndroidCloud%2Fanbox-master%2Fsrc%2Fanbox%2Faudio%2Fserver.cpp;fp=src%2Ftype3_AndroidCloud%2Fanbox-master%2Fsrc%2Fanbox%2Faudio%2Fserver.cpp;h=ad13968087fc2613d63e9a013de892c302a6d06f;hb=e26c1ec581be598521517829adba8c8dd23a768f;hp=0000000000000000000000000000000000000000;hpb=6699c1aea74eeb0eb400e6299079f0c7576f716f;p=iec.git

diff --git a/src/type3_AndroidCloud/anbox-master/src/anbox/audio/server.cpp b/src/type3_AndroidCloud/anbox-master/src/anbox/audio/server.cpp
new file mode 100644
index 0000000..ad13968
--- /dev/null
+++ b/src/type3_AndroidCloud/anbox-master/src/anbox/audio/server.cpp
@@ -0,0 +1,109 @@
+/*
+ * Copyright (C) 2017 Simon Fels <morphis@gravedo.de>
+ *
+ * This program is free software: you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License version 3, as published
+ * by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranties of
+ * MERCHANTABILITY, SATISFACTORY QUALITY, or FITNESS FOR A PARTICULAR
+ * PURPOSE.  See the GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
+#include "anbox/audio/server.h"
+#include "anbox/audio/sink.h"
+#include "anbox/network/published_socket_connector.h"
+#include "anbox/network/delegate_connection_creator.h"
+#include "anbox/network/local_socket_messenger.h"
+#include "anbox/network/message_processor.h"
+#include "anbox/common/type_traits.h"
+#include "anbox/system_configuration.h"
+#include "anbox/utils.h"
+#include "anbox/logger.h"
+
+using namespace std::placeholders;
+
+namespace {
+class AudioForwarder : public anbox::network::MessageProcessor {
+ public:
+  AudioForwarder(const std::shared_ptr<anbox::audio::Sink> &sink) :
+    sink_(sink) {
+  }
+
+  bool process_data(const std::vector<std::uint8_t> &data) override {
+    sink_->write_data(data);
+    return true;
+  }
+
+ private:
+  std::shared_ptr<anbox::audio::Sink> sink_;
+};
+}
+
+namespace anbox {
+namespace audio {
+Server::Server(const std::shared_ptr<Runtime>& rt, const std::shared_ptr<platform::BasePlatform> &platform) :
+  platform_(platform),
+  socket_file_(utils::string_format("%s/anbox_audio", SystemConfiguration::instance().socket_dir())),
+  connector_(std::make_shared<network::PublishedSocketConnector>(
+             socket_file_, rt,
+             std::make_shared<network::DelegateConnectionCreator<boost::asio::local::stream_protocol>>(std::bind(&Server::create_connection_for, this, _1)))),
+  connections_(std::make_shared<network::Connections<network::SocketConnection>>()),
+  next_id_(0) {
+
+  // FIXME: currently creating the socket creates it with the rights of
+  // the user we're running as. As this one is mapped into the container
+  ::chmod(socket_file_.c_str(), 0777);
+}
+
+Server::~Server() {}
+
+void Server::create_connection_for(std::shared_ptr<boost::asio::basic_stream_socket<boost::asio::local::stream_protocol>> const& socket) {
+  auto const messenger =
+      std::make_shared<network::LocalSocketMessenger>(socket);
+
+  // We have to read the client flags first before we can continue
+  // processing the actual commands
+  ClientInfo client_info;
+  auto err = messenger->receive_msg(
+      boost::asio::buffer(&client_info, sizeof(ClientInfo)));
+  if (err) {
+    ERROR("Failed to read client info: %s", err.message());
+    return;
+  }
+
+  std::shared_ptr<network::MessageProcessor> processor;
+
+  switch (client_info.type) {
+  case ClientInfo::Type::Playback:
+    processor = std::make_shared<AudioForwarder>(platform_->create_audio_sink());
+    break;
+  case ClientInfo::Type::Recording:
+    break;
+  default:
+    ERROR("Invalid client type %d", static_cast<int>(client_info.type));
+    return;
+  }
+
+  // Everything ok, so approve the client by sending the requesting client
+  // info back. Once we have more things to negotiate we will send a modified
+  // client info struct back.
+  messenger->send(reinterpret_cast<char*>(&client_info), sizeof(client_info));
+
+  auto connection = std::make_shared<network::SocketConnection>(
+        messenger, messenger, next_id(), connections_, processor);
+  connections_->add(connection);
+
+  connection->read_next_message();
+}
+
+int Server::next_id() {
+  return next_id_.fetch_add(1);
+}
+} // namespace audio
+} // namespace anbox