OLD | NEW |
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 #ifndef BIN_DBG_CONNECTION_H_ | 5 #ifndef BIN_DBG_CONNECTION_H_ |
6 #define BIN_DBG_CONNECTION_H_ | 6 #define BIN_DBG_CONNECTION_H_ |
7 | 7 |
8 #include "bin/builtin.h" | 8 #include "bin/builtin.h" |
9 #include "bin/utils.h" | 9 #include "bin/utils.h" |
10 | 10 |
(...skipping 19 matching lines...) Expand all Loading... |
30 namespace dart { | 30 namespace dart { |
31 namespace bin { | 31 namespace bin { |
32 | 32 |
33 // Forward declarations. | 33 // Forward declarations. |
34 class DbgMessage; | 34 class DbgMessage; |
35 class MessageBuffer; | 35 class MessageBuffer; |
36 | 36 |
37 | 37 |
38 class DebuggerConnectionHandler { | 38 class DebuggerConnectionHandler { |
39 public: | 39 public: |
40 explicit DebuggerConnectionHandler(int debug_fd); | 40 explicit DebuggerConnectionHandler(intptr_t debug_fd); |
41 ~DebuggerConnectionHandler(); | 41 ~DebuggerConnectionHandler(); |
42 | 42 |
43 // Accessors. | 43 // Accessors. |
44 int debug_fd() const { return debug_fd_; } | 44 intptr_t debug_fd() const { return debug_fd_; } |
45 | 45 |
46 // Return message id of current debug command message. | 46 // Return message id of current debug command message. |
47 int MessageId(); | 47 int MessageId(); |
48 | 48 |
49 // Starts the native thread which listens for connections from | 49 // Starts the native thread which listens for connections from |
50 // debugger clients, reads and dispatches debug command messages | 50 // debugger clients, reads and dispatches debug command messages |
51 // from the client. | 51 // from the client. |
52 static int StartHandler(const char* address, int port_number); | 52 static int StartHandler(const char* address, int port_number); |
53 | 53 |
54 // Initializes the parts of the debugger which are needed by the vm | 54 // Initializes the parts of the debugger which are needed by the vm |
55 // service. This function should only be called when StartHandler | 55 // service. This function should only be called when StartHandler |
56 // is not called. | 56 // is not called. |
57 static void InitForVmService(); | 57 static void InitForVmService(); |
58 | 58 |
59 // Called by Isolates when they need to wait for a connection | 59 // Called by Isolates when they need to wait for a connection |
60 // from debugger clients. | 60 // from debugger clients. |
61 static void WaitForConnection(); | 61 static void WaitForConnection(); |
62 | 62 |
63 // Sends a reply or an error message to a specific debugger client. | 63 // Sends a reply or an error message to a specific debugger client. |
64 static void SendMsg(int debug_fd, dart::TextBuffer* msg); | 64 static void SendMsg(intptr_t debug_fd, dart::TextBuffer* msg); |
65 static void SendError(int debug_fd, int msg_id, const char* err_msg); | 65 static void SendError(intptr_t debug_fd, int msg_id, const char* err_msg); |
66 | 66 |
67 // Sends an event message to all debugger clients that are connected. | 67 // Sends an event message to all debugger clients that are connected. |
68 static void BroadcastMsg(dart::TextBuffer* msg); | 68 static void BroadcastMsg(dart::TextBuffer* msg); |
69 | 69 |
70 private: | 70 private: |
71 void HandleUnknownMsg(); | 71 void HandleUnknownMsg(); |
72 void HandleMessages(); | 72 void HandleMessages(); |
73 | 73 |
74 void CloseDbgConnection(); | 74 void CloseDbgConnection(); |
75 | 75 |
76 // The socket that connects with the debugger client. | 76 // The socket that connects with the debugger client. |
77 // The descriptor is created and closed by the debugger connection thread. | 77 // The descriptor is created and closed by the debugger connection thread. |
78 int debug_fd_; | 78 intptr_t debug_fd_; |
79 | 79 |
80 // Buffer holding the messages received over the wire from the debugger | 80 // Buffer holding the messages received over the wire from the debugger |
81 // front end.. | 81 // front end.. |
82 MessageBuffer* msgbuf_; | 82 MessageBuffer* msgbuf_; |
83 | 83 |
84 // Accepts connection requests from debugger client and sets up a | 84 // Accepts connection requests from debugger client and sets up a |
85 // connection handler object to read and handle messages from the client. | 85 // connection handler object to read and handle messages from the client. |
86 static void AcceptDbgConnection(int debug_fd); | 86 static void AcceptDbgConnection(intptr_t debug_fd); |
87 | 87 |
88 // Handlers for generic debug command messages which are not specific to | 88 // Handlers for generic debug command messages which are not specific to |
89 // an isolate. | 89 // an isolate. |
90 static void HandleInterruptCmd(DbgMessage* msg); | 90 static void HandleInterruptCmd(DbgMessage* msg); |
91 static void HandleIsolatesListCmd(DbgMessage* msg); | 91 static void HandleIsolatesListCmd(DbgMessage* msg); |
92 | 92 |
93 // Helper methods to manage debugger client connections. | 93 // Helper methods to manage debugger client connections. |
94 static void AddNewDebuggerConnection(int debug_fd); | 94 static void AddNewDebuggerConnection(intptr_t debug_fd); |
95 static void RemoveDebuggerConnection(int debug_fd); | 95 static void RemoveDebuggerConnection(intptr_t debug_fd); |
96 static DebuggerConnectionHandler* GetDebuggerConnectionHandler(int debug_fd); | 96 static DebuggerConnectionHandler* GetDebuggerConnectionHandler( |
| 97 intptr_t debug_fd); |
97 static bool IsConnected(); | 98 static bool IsConnected(); |
98 | 99 |
99 // Helper method for sending messages back to a debugger client. | 100 // Helper method for sending messages back to a debugger client. |
100 static void SendMsgHelper(int debug_fd, dart::TextBuffer* msg); | 101 static void SendMsgHelper(intptr_t debug_fd, dart::TextBuffer* msg); |
101 | 102 |
102 // mutex/condition variable used by isolates when writing back to the | 103 // mutex/condition variable used by isolates when writing back to the |
103 // debugger. This is also used to ensure that the isolate waits for | 104 // debugger. This is also used to ensure that the isolate waits for |
104 // a debugger to be attached when that is requested on the command line. | 105 // a debugger to be attached when that is requested on the command line. |
105 static dart::Monitor* handler_lock_; | 106 static dart::Monitor* handler_lock_; |
106 | 107 |
107 static bool IsListening() { | 108 static bool IsListening() { |
108 return listener_fd_ != -1; | 109 return listener_fd_ != -1; |
109 } | 110 } |
110 | 111 |
111 // The socket that is listening for incoming debugger connections. | 112 // The socket that is listening for incoming debugger connections. |
112 // This descriptor is created and closed by a native thread. | 113 // This descriptor is created and closed by a native thread. |
113 static int listener_fd_; | 114 static intptr_t listener_fd_; |
114 | 115 |
115 friend class DebuggerConnectionImpl; | 116 friend class DebuggerConnectionImpl; |
116 | 117 |
117 DISALLOW_IMPLICIT_CONSTRUCTORS(DebuggerConnectionHandler); | 118 DISALLOW_IMPLICIT_CONSTRUCTORS(DebuggerConnectionHandler); |
118 }; | 119 }; |
119 | 120 |
120 } // namespace bin | 121 } // namespace bin |
121 } // namespace dart | 122 } // namespace dart |
122 | 123 |
123 #endif // BIN_DBG_CONNECTION_H_ | 124 #endif // BIN_DBG_CONNECTION_H_ |
OLD | NEW |