blob: 2c4d569261d29332a8600b831b9d804107e227d6 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
// Copyright (c) 2013 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CHROME_BROWSER_DEVTOOLS_ADB_WEB_SOCKET_H_
#define CHROME_BROWSER_DEVTOOLS_ADB_WEB_SOCKET_H_
#include "chrome/browser/devtools/devtools_adb_bridge.h"
class AdbWebSocket : public base::RefCountedThreadSafe<AdbWebSocket> {
public:
class Delegate {
public:
virtual void OnSocketOpened() = 0;
virtual void OnFrameRead(const std::string& message) = 0;
virtual void OnSocketClosed(bool closed_by_device) = 0;
virtual bool ProcessIncomingMessage(const std::string& message) = 0;
protected:
virtual ~Delegate() {}
};
AdbWebSocket(scoped_refptr<DevToolsAdbBridge::AndroidDevice> device,
const std::string& socket_name,
const std::string& url,
base::MessageLoop* adb_message_loop,
Delegate* delegate);
void Disconnect();
void SendFrame(const std::string& message);
void SendFrameOnHandlerThread(const std::string& message);
private:
friend class base::RefCountedThreadSafe<AdbWebSocket>;
virtual ~AdbWebSocket();
void ConnectOnHandlerThread();
void ConnectedOnHandlerThread(int result, net::StreamSocket* socket);
void StartListeningOnHandlerThread();
void OnBytesRead(scoped_refptr<net::IOBuffer> response_buffer, int result);
void SendPendingRequests(int result);
void DisconnectOnHandlerThread(bool closed_by_device);
void OnSocketOpened();
void OnFrameRead(const std::string& message);
void OnSocketClosed(bool closed_by_device);
scoped_refptr<DevToolsAdbBridge::AndroidDevice> device_;
std::string socket_name_;
std::string url_;
base::MessageLoop* adb_message_loop_;
scoped_ptr<net::StreamSocket> socket_;
Delegate* delegate_;
std::string response_buffer_;
std::string request_buffer_;
DISALLOW_COPY_AND_ASSIGN(AdbWebSocket);
};
#endif // CHROME_BROWSER_DEVTOOLS_ADB_WEB_SOCKET_H_
|
