blob: 661c43efb73835d10f92aa44a8bcb35b4bfa9fd9 [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);
Garrick Evans3cbac7c2019-04-18 15:31:31 +090034 virtual ~AdbProxy();
35
36 protected:
Garrick Evans3cbac7c2019-04-18 15:31:31 +090037 int OnInit() override;
38
Garrick Evans96e03042019-05-28 14:30:52 +090039 void OnParentProcessExit();
40 void OnGuestMessage(const GuestMessage& msg);
Garrick Evans3cbac7c2019-04-18 15:31:31 +090041
Garrick Evans96e03042019-05-28 14:30:52 +090042 private:
Garrick Evansbdf1f982019-06-07 09:46:49 +090043 void Reset();
Hidehiko Abede129222019-08-16 00:55:04 +090044 void OnFileCanReadWithoutBlocking();
Garrick Evansbdf1f982019-06-07 09:46:49 +090045
Garrick Evans3cbac7c2019-04-18 15:31:31 +090046 // Attempts to establish a connection to ADB at well-known destinations.
47 std::unique_ptr<Socket> Connect() const;
48
Garrick Evans96e03042019-05-28 14:30:52 +090049 MessageDispatcher msg_dispatcher_;
Garrick Evans3cbac7c2019-04-18 15:31:31 +090050 std::unique_ptr<Socket> src_;
51 std::deque<std::unique_ptr<SocketForwarder>> fwd_;
Hidehiko Abede129222019-08-16 00:55:04 +090052 std::unique_ptr<base::FileDescriptorWatcher::Controller> src_watcher_;
Garrick Evans3cbac7c2019-04-18 15:31:31 +090053
Garrick Evansbdf1f982019-06-07 09:46:49 +090054 GuestMessage::GuestType arc_type_;
Garrick Evans1cce71a2019-06-21 10:43:14 +090055 uint32_t arcvm_vsock_cid_;
Garrick Evansbdf1f982019-06-07 09:46:49 +090056
Garrick Evans3cbac7c2019-04-18 15:31:31 +090057 base::WeakPtrFactory<AdbProxy> weak_factory_{this};
58 DISALLOW_COPY_AND_ASSIGN(AdbProxy);
59};
60
Garrick Evans3388a032020-03-24 11:25:55 +090061} // namespace patchpanel
Garrick Evans3cbac7c2019-04-18 15:31:31 +090062
Garrick Evans3388a032020-03-24 11:25:55 +090063#endif // PATCHPANEL_ADB_PROXY_H_