src/type3_AndroidCloud/anbox-master/src/anbox/qemu/pipe_connection_creator.h

   1 /*
   2  * Copyright (C) 2016 Simon Fels <morphis@gravedo.de>
   3  *
   4  * This program is free software: you can redistribute it and/or modify it
   5  * under the terms of the GNU General Public License version 3, as published
   6  * by the Free Software Foundation.
   7  *
   8  * This program is distributed in the hope that it will be useful, but
   9  * WITHOUT ANY WARRANTY; without even the implied warranties of
  10  * MERCHANTABILITY, SATISFACTORY QUALITY, or FITNESS FOR A PARTICULAR
  11  * PURPOSE.  See the GNU General Public License for more details.
  12  *
  13  * You should have received a copy of the GNU General Public License along
  14  * with this program.  If not, see <http://www.gnu.org/licenses/>.
  15  *
  16  */
  17
  18 #ifndef ANBOX_NETWORK_QEMU_PIPE_CONNECTION_CREATOR_H_
  19 #define ANBOX_NETWORK_QEMU_PIPE_CONNECTION_CREATOR_H_
  20
  21 #include <boost/asio.hpp>
  22
  23 #include <memory>
  24
  25 #include "anbox/do_not_copy_or_move.h"
  26 #include "anbox/network/connection_creator.h"
  27 #include "anbox/network/connections.h"
  28 #include "anbox/network/socket_connection.h"
  29 #include "anbox/network/socket_messenger.h"
  30 #include "anbox/runtime.h"
  31
  32 class Renderer;
  33
  34 namespace anbox {
  35 namespace qemu {
  36 class PipeConnectionCreator
  37     : public network::ConnectionCreator<boost::asio::local::stream_protocol> {
  38  public:
  39   PipeConnectionCreator(const std::shared_ptr<Renderer> &renderer, const std::shared_ptr<Runtime> &rt);
  40   ~PipeConnectionCreator() noexcept;
  41
  42   void create_connection_for(
  43       std::shared_ptr<boost::asio::basic_stream_socket<
  44           boost::asio::local::stream_protocol>> const &socket) override;
  45
  46   enum class client_type {
  47     invalid,
  48     opengles,
  49     qemud_boot_properties,
  50     qemud_hw_control,
  51     qemud_sensors,
  52     qemud_camera,
  53     qemud_fingerprint,
  54     qemud_gsm,
  55     qemud_adb,
  56     bootanimation,
  57   };
  58
  59  private:
  60   int next_id();
  61
  62   client_type identify_client(
  63       std::shared_ptr<network::SocketMessenger> const &messenger);
  64   std::shared_ptr<network::MessageProcessor> create_processor(
  65       const client_type &type,
  66       const std::shared_ptr<network::SocketMessenger> &messenger);
  67
  68   std::shared_ptr<Renderer> renderer_;
  69   std::shared_ptr<Runtime> runtime_;
  70   std::atomic<int> next_connection_id_;
  71   std::shared_ptr<network::Connections<network::SocketConnection>> const connections_;
  72 };
  73 }  // namespace qemu
  74 }  // namespace anbox
  75
  76 #endif