blob: 7765b5edb9d1947e683d3d701646e1e441f1cf18 [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
Garrick Evans3388a032020-03-24 11:25:55 +09005#ifndef PATCHPANEL_ADB_PROXY_H_
6#define PATCHPANEL_ADB_PROXY_H_
Garrick Evans3cbac7c2019-04-18 15:31:31 +09007
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 Evans3388a032020-03-24 11:25:55 +090016#include "patchpanel/message_dispatcher.h"
17#include "patchpanel/socket.h"
18#include "patchpanel/socket_forwarder.h"
Garrick Evans3cbac7c2019-04-18 15:31:31 +090019
Garrick Evans3388a032020-03-24 11:25:55 +090020namespace patchpanel {
Garrick Evans3cbac7c2019-04-18 15:31:31 +090021
Jason Jeremy Iman3081d0e2020-03-04 15:52:06 +090022// Running the proxy on port 5555 will cause ADBD to see it as an Android
23// emulator rather than an attached device. This means, whenever host ADBD
24// server runs a device named "emulator-5554" will show up.
25// Connections to ARC via ADB (including by Tast) should now be done by
26// starting ADB server (e.g. 'adb devices') instead of
27// 'adb connect 127.0.0.1:5555' to avoid seeing multiple devices.
28constexpr uint16_t kAdbProxyTcpListenPort = 5555;
Jason Jeremy Imanfa8b6d22020-02-20 03:44:21 +000029
Garrick Evans3cbac7c2019-04-18 15:31:31 +090030// Subprocess for proxying ADB traffic.
Hidehiko Abede129222019-08-16 00:55:04 +090031class AdbProxy : public brillo::Daemon {
Garrick Evans3cbac7c2019-04-18 15:31:31 +090032 public:
Garrick Evans96e03042019-05-28 14:30:52 +090033 explicit AdbProxy(base::ScopedFD control_fd);
Qijiang Fan6bc59e12020-11-11 02:51:06 +090034 AdbProxy(const AdbProxy&) = delete;
35 AdbProxy& operator=(const AdbProxy&) = delete;
36
Garrick Evans3cbac7c2019-04-18 15:31:31 +090037 virtual ~AdbProxy();
38
39 protected:
Garrick Evans3cbac7c2019-04-18 15:31:31 +090040 int OnInit() override;
41
Garrick Evans96e03042019-05-28 14:30:52 +090042 void OnParentProcessExit();
43 void OnGuestMessage(const GuestMessage& msg);
Garrick Evans3cbac7c2019-04-18 15:31:31 +090044
Garrick Evans96e03042019-05-28 14:30:52 +090045 private:
Garrick Evansbdf1f982019-06-07 09:46:49 +090046 void Reset();
Hidehiko Abede129222019-08-16 00:55:04 +090047 void OnFileCanReadWithoutBlocking();
Garrick Evansbdf1f982019-06-07 09:46:49 +090048
Garrick Evans3cbac7c2019-04-18 15:31:31 +090049 // Attempts to establish a connection to ADB at well-known destinations.
50 std::unique_ptr<Socket> Connect() const;
51
Garrick Evans96e03042019-05-28 14:30:52 +090052 MessageDispatcher msg_dispatcher_;
Garrick Evans3cbac7c2019-04-18 15:31:31 +090053 std::unique_ptr<Socket> src_;
54 std::deque<std::unique_ptr<SocketForwarder>> fwd_;
Hidehiko Abede129222019-08-16 00:55:04 +090055 std::unique_ptr<base::FileDescriptorWatcher::Controller> src_watcher_;
Garrick Evans3cbac7c2019-04-18 15:31:31 +090056
Garrick Evansbdf1f982019-06-07 09:46:49 +090057 GuestMessage::GuestType arc_type_;
Garrick Evans1cce71a2019-06-21 10:43:14 +090058 uint32_t arcvm_vsock_cid_;
Garrick Evansbdf1f982019-06-07 09:46:49 +090059
Garrick Evans3cbac7c2019-04-18 15:31:31 +090060 base::WeakPtrFactory<AdbProxy> weak_factory_{this};
Garrick Evans3cbac7c2019-04-18 15:31:31 +090061};
62
Garrick Evans3388a032020-03-24 11:25:55 +090063} // namespace patchpanel
Garrick Evans3cbac7c2019-04-18 15:31:31 +090064
Garrick Evans3388a032020-03-24 11:25:55 +090065#endif // PATCHPANEL_ADB_PROXY_H_