blob: 7eaf4556d6ae30e482586dd967f47c6f729e32c0 [file] [log] [blame]
Garrick Evans3cbac7c2019-04-18 15:31:31 +09001// Copyright 2019 The Chromium OS Authors. All rights reserved.
2// Use of this source code is governed by a BSD-style license that can be
3// found in the LICENSE file.
4
5#ifndef ARC_NETWORK_ADB_PROXY_H_
6#define ARC_NETWORK_ADB_PROXY_H_
7
8#include <deque>
9#include <memory>
10
Hidehiko Abede129222019-08-16 00:55:04 +090011#include <base/files/file_descriptor_watcher_posix.h>
Garrick Evans96e03042019-05-28 14:30:52 +090012#include <base/files/scoped_file.h>
Garrick Evans3cbac7c2019-04-18 15:31:31 +090013#include <base/memory/weak_ptr.h>
14#include <brillo/daemons/daemon.h>
Garrick Evans3cbac7c2019-04-18 15:31:31 +090015
Garrick Evans96e03042019-05-28 14:30:52 +090016#include "arc/network/message_dispatcher.h"
Garrick Evans3cbac7c2019-04-18 15:31:31 +090017#include "arc/network/socket.h"
18#include "arc/network/socket_forwarder.h"
19
20namespace arc_networkd {
21
22// Subprocess for proxying ADB traffic.
Hidehiko Abede129222019-08-16 00:55:04 +090023class AdbProxy : public brillo::Daemon {
Garrick Evans3cbac7c2019-04-18 15:31:31 +090024 public:
Garrick Evans96e03042019-05-28 14:30:52 +090025 explicit AdbProxy(base::ScopedFD control_fd);
Garrick Evans3cbac7c2019-04-18 15:31:31 +090026 virtual ~AdbProxy();
27
28 protected:
Garrick Evans3cbac7c2019-04-18 15:31:31 +090029 int OnInit() override;
30
Garrick Evans96e03042019-05-28 14:30:52 +090031 void OnParentProcessExit();
32 void OnGuestMessage(const GuestMessage& msg);
Garrick Evans3cbac7c2019-04-18 15:31:31 +090033
Garrick Evans96e03042019-05-28 14:30:52 +090034 private:
Garrick Evansbdf1f982019-06-07 09:46:49 +090035 void Reset();
Hidehiko Abede129222019-08-16 00:55:04 +090036 void OnFileCanReadWithoutBlocking();
Garrick Evansbdf1f982019-06-07 09:46:49 +090037
Garrick Evans3cbac7c2019-04-18 15:31:31 +090038 // Attempts to establish a connection to ADB at well-known destinations.
39 std::unique_ptr<Socket> Connect() const;
40
Garrick Evans96e03042019-05-28 14:30:52 +090041 MessageDispatcher msg_dispatcher_;
Garrick Evans3cbac7c2019-04-18 15:31:31 +090042 std::unique_ptr<Socket> src_;
43 std::deque<std::unique_ptr<SocketForwarder>> fwd_;
Hidehiko Abede129222019-08-16 00:55:04 +090044 std::unique_ptr<base::FileDescriptorWatcher::Controller> src_watcher_;
Garrick Evans3cbac7c2019-04-18 15:31:31 +090045
Garrick Evansbdf1f982019-06-07 09:46:49 +090046 GuestMessage::GuestType arc_type_;
Garrick Evans1cce71a2019-06-21 10:43:14 +090047 uint32_t arcvm_vsock_cid_;
Garrick Evansbdf1f982019-06-07 09:46:49 +090048
Garrick Evans3cbac7c2019-04-18 15:31:31 +090049 base::WeakPtrFactory<AdbProxy> weak_factory_{this};
50 DISALLOW_COPY_AND_ASSIGN(AdbProxy);
51};
52
53} // namespace arc_networkd
54
55#endif // ARC_NETWORK_ADB_PROXY_H_