OLD | NEW |
| (Empty) |
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 | |
3 // BSD-style license that can be found in the LICENSE file. | |
4 | |
5 #include "platform/globals.h" | |
6 #if defined(TARGET_OS_WINDOWS) | |
7 | |
8 #include "bin/dbg_connection.h" | |
9 | |
10 #include "bin/eventhandler.h" | |
11 #include "bin/lockers.h" | |
12 #include "bin/log.h" | |
13 #include "bin/thread.h" | |
14 | |
15 namespace dart { | |
16 namespace bin { | |
17 | |
18 Monitor* DebuggerConnectionImpl::handler_monitor_ = new Monitor(); | |
19 ThreadId DebuggerConnectionImpl::handler_thread_id_ = Thread::kInvalidThreadId; | |
20 bool DebuggerConnectionImpl::handler_thread_running_ = false; | |
21 | |
22 | |
23 void DebuggerConnectionImpl::NotifyThreadStarted() { | |
24 MonitorLocker ml(handler_monitor_); | |
25 ASSERT(!handler_thread_running_); | |
26 ASSERT(handler_thread_id_ == Thread::kInvalidThreadId); | |
27 handler_thread_running_ = true; | |
28 handler_thread_id_ = Thread::GetCurrentThreadId(); | |
29 ml.Notify(); | |
30 } | |
31 | |
32 | |
33 void DebuggerConnectionImpl::WaitForThreadStarted() { | |
34 MonitorLocker ml(handler_monitor_); | |
35 while (!handler_thread_running_) { | |
36 ml.Wait(); | |
37 } | |
38 ASSERT(handler_thread_id_ != Thread::kInvalidThreadId); | |
39 } | |
40 | |
41 | |
42 void DebuggerConnectionImpl::NotifyThreadFinished() { | |
43 MonitorLocker ml(handler_monitor_); | |
44 ASSERT(handler_thread_running_); | |
45 ASSERT(handler_thread_id_ != Thread::kInvalidThreadId); | |
46 handler_thread_running_ = false; | |
47 ml.Notify(); | |
48 } | |
49 | |
50 | |
51 void DebuggerConnectionImpl::WaitForThreadFinished() { | |
52 MonitorLocker ml(handler_monitor_); | |
53 while (handler_thread_running_) { | |
54 ml.Wait(); | |
55 } | |
56 ASSERT(handler_thread_id_ != Thread::kInvalidThreadId); | |
57 Thread::Join(handler_thread_id_); | |
58 handler_thread_id_ = Thread::kInvalidThreadId; | |
59 } | |
60 | |
61 | |
62 void DebuggerConnectionImpl::ThreadEntry(uword args) { | |
63 NotifyThreadStarted(); | |
64 ListenSocket* listen_socket = | |
65 reinterpret_cast<ListenSocket*>(DebuggerConnectionHandler::listener_fd_); | |
66 SOCKET client_socket = accept(listen_socket->socket(), NULL, NULL); | |
67 if (client_socket == INVALID_SOCKET) { | |
68 FATAL("Accepting new debugger connection failed.\n"); | |
69 } | |
70 ClientSocket* socket = new ClientSocket(client_socket); | |
71 DebuggerConnectionHandler::AcceptDbgConnection( | |
72 reinterpret_cast<intptr_t>(socket)); | |
73 NotifyThreadFinished(); | |
74 } | |
75 | |
76 | |
77 void DebuggerConnectionImpl::StartHandler(int port_number) { | |
78 ASSERT(DebuggerConnectionHandler::listener_fd_ != -1); | |
79 int result = Thread::Start(&DebuggerConnectionImpl::ThreadEntry, 0); | |
80 if (result != 0) { | |
81 FATAL1("Failed to start debugger connection handler thread: %d\n", result); | |
82 } | |
83 WaitForThreadStarted(); | |
84 } | |
85 | |
86 | |
87 void DebuggerConnectionImpl::StopHandler(intptr_t debug_fd) { | |
88 Send(debug_fd, NULL, 0); | |
89 WaitForThreadFinished(); | |
90 } | |
91 | |
92 | |
93 intptr_t DebuggerConnectionImpl::Send(intptr_t socket, | |
94 const char* buf, | |
95 int len) { | |
96 ClientSocket* client_socket = reinterpret_cast<ClientSocket*>(socket); | |
97 return send(client_socket->socket(), buf, len, 0); | |
98 } | |
99 | |
100 | |
101 intptr_t DebuggerConnectionImpl::Receive(intptr_t socket, char* buf, int len) { | |
102 ClientSocket* client_socket = reinterpret_cast<ClientSocket*>(socket); | |
103 return recv(client_socket->socket(), buf, len, 0); | |
104 } | |
105 | |
106 } // namespace bin | |
107 } // namespace dart | |
108 | |
109 #endif // defined(TARGET_OS_WINDOWS) | |
OLD | NEW |