OLD | NEW |
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 #include "bin/process.h" | 5 #include "bin/process.h" |
6 | 6 |
7 #include "bin/dartutils.h" | 7 #include "bin/dartutils.h" |
8 #include "bin/io_buffer.h" | 8 #include "bin/io_buffer.h" |
9 #include "bin/log.h" | 9 #include "bin/log.h" |
| 10 #include "bin/namespace.h" |
10 #include "bin/platform.h" | 11 #include "bin/platform.h" |
11 #include "bin/socket.h" | 12 #include "bin/socket.h" |
12 #include "bin/utils.h" | 13 #include "bin/utils.h" |
13 | 14 |
14 #include "include/dart_api.h" | 15 #include "include/dart_api.h" |
15 | 16 |
16 namespace dart { | 17 namespace dart { |
17 namespace bin { | 18 namespace bin { |
18 | 19 |
19 static const int kProcessIdNativeField = 0; | 20 static const int kProcessIdNativeField = 0; |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
75 ClearSignalHandler(i, ILLEGAL_PORT); | 76 ClearSignalHandler(i, ILLEGAL_PORT); |
76 } | 77 } |
77 } | 78 } |
78 | 79 |
79 void FUNCTION_NAME(Process_Start)(Dart_NativeArguments args) { | 80 void FUNCTION_NAME(Process_Start)(Dart_NativeArguments args) { |
80 Dart_Handle process = Dart_GetNativeArgument(args, 0); | 81 Dart_Handle process = Dart_GetNativeArgument(args, 0); |
81 intptr_t process_stdin; | 82 intptr_t process_stdin; |
82 intptr_t process_stdout; | 83 intptr_t process_stdout; |
83 intptr_t process_stderr; | 84 intptr_t process_stderr; |
84 intptr_t exit_event; | 85 intptr_t exit_event; |
85 Dart_Handle result; | 86 Namespace* namespc = Namespace::GetNamespace(args, 1); |
86 Dart_Handle status_handle = Dart_GetNativeArgument(args, 10); | 87 Dart_Handle status_handle = Dart_GetNativeArgument(args, 11); |
87 Dart_Handle path_handle = Dart_GetNativeArgument(args, 1); | 88 Dart_Handle path_handle = Dart_GetNativeArgument(args, 2); |
88 // The Dart code verifies that the path implements the String | 89 // The Dart code verifies that the path implements the String |
89 // interface. However, only builtin Strings are handled by | 90 // interface. However, only builtin Strings are handled by |
90 // GetStringValue. | 91 // GetStringValue. |
| 92 Dart_Handle result; |
91 if (!Dart_IsString(path_handle)) { | 93 if (!Dart_IsString(path_handle)) { |
92 result = DartUtils::SetIntegerField(status_handle, "_errorCode", 0); | 94 result = DartUtils::SetIntegerField(status_handle, "_errorCode", 0); |
93 if (Dart_IsError(result)) { | 95 if (Dart_IsError(result)) { |
94 Dart_PropagateError(result); | 96 Dart_PropagateError(result); |
95 } | 97 } |
96 result = DartUtils::SetStringField(status_handle, "_errorMessage", | 98 result = DartUtils::SetStringField(status_handle, "_errorMessage", |
97 "Path must be a builtin string"); | 99 "Path must be a builtin string"); |
98 if (Dart_IsError(result)) { | 100 if (Dart_IsError(result)) { |
99 Dart_PropagateError(result); | 101 Dart_PropagateError(result); |
100 } | 102 } |
101 Dart_SetReturnValue(args, Dart_NewBoolean(false)); | 103 Dart_SetBooleanReturnValue(args, false); |
102 return; | 104 return; |
103 } | 105 } |
104 const char* path = DartUtils::GetStringValue(path_handle); | 106 const char* path = DartUtils::GetStringValue(path_handle); |
105 Dart_Handle arguments = Dart_GetNativeArgument(args, 2); | 107 Dart_Handle arguments = Dart_GetNativeArgument(args, 3); |
106 intptr_t args_length = 0; | 108 intptr_t args_length = 0; |
107 char** string_args = | 109 char** string_args = |
108 ExtractCStringList(arguments, status_handle, | 110 ExtractCStringList(arguments, status_handle, |
109 "Arguments must be builtin strings", &args_length); | 111 "Arguments must be builtin strings", &args_length); |
110 if (string_args == NULL) { | 112 if (string_args == NULL) { |
111 Dart_SetReturnValue(args, Dart_NewBoolean(false)); | 113 Dart_SetBooleanReturnValue(args, false); |
112 return; | 114 return; |
113 } | 115 } |
114 Dart_Handle working_directory_handle = Dart_GetNativeArgument(args, 3); | 116 Dart_Handle working_directory_handle = Dart_GetNativeArgument(args, 4); |
115 // Defaults to the current working directoy. | 117 // Defaults to the current working directoy. |
116 const char* working_directory = NULL; | 118 const char* working_directory = NULL; |
117 if (Dart_IsString(working_directory_handle)) { | 119 if (Dart_IsString(working_directory_handle)) { |
118 working_directory = DartUtils::GetStringValue(working_directory_handle); | 120 working_directory = DartUtils::GetStringValue(working_directory_handle); |
119 } else if (!Dart_IsNull(working_directory_handle)) { | 121 } else if (!Dart_IsNull(working_directory_handle)) { |
120 result = DartUtils::SetIntegerField(status_handle, "_errorCode", 0); | 122 result = DartUtils::SetIntegerField(status_handle, "_errorCode", 0); |
121 if (Dart_IsError(result)) { | 123 if (Dart_IsError(result)) { |
122 Dart_PropagateError(result); | 124 Dart_PropagateError(result); |
123 } | 125 } |
124 result = | 126 result = |
125 DartUtils::SetStringField(status_handle, "_errorMessage", | 127 DartUtils::SetStringField(status_handle, "_errorMessage", |
126 "WorkingDirectory must be a builtin string"); | 128 "WorkingDirectory must be a builtin string"); |
127 if (Dart_IsError(result)) { | 129 if (Dart_IsError(result)) { |
128 Dart_PropagateError(result); | 130 Dart_PropagateError(result); |
129 } | 131 } |
130 Dart_SetReturnValue(args, Dart_NewBoolean(false)); | 132 Dart_SetBooleanReturnValue(args, false); |
131 return; | 133 return; |
132 } | 134 } |
133 Dart_Handle environment = Dart_GetNativeArgument(args, 4); | 135 Dart_Handle environment = Dart_GetNativeArgument(args, 5); |
134 intptr_t environment_length = 0; | 136 intptr_t environment_length = 0; |
135 char** string_environment = NULL; | 137 char** string_environment = NULL; |
136 if (!Dart_IsNull(environment)) { | 138 if (!Dart_IsNull(environment)) { |
137 string_environment = ExtractCStringList( | 139 string_environment = ExtractCStringList( |
138 environment, status_handle, | 140 environment, status_handle, |
139 "Environment values must be builtin strings", &environment_length); | 141 "Environment values must be builtin strings", &environment_length); |
140 if (string_environment == NULL) { | 142 if (string_environment == NULL) { |
141 Dart_SetReturnValue(args, Dart_NewBoolean(false)); | 143 Dart_SetReturnValue(args, Dart_NewBoolean(false)); |
142 return; | 144 return; |
143 } | 145 } |
144 } | 146 } |
145 int64_t mode = | 147 int64_t mode = |
146 DartUtils::GetInt64ValueCheckRange(Dart_GetNativeArgument(args, 5), 0, 2); | 148 DartUtils::GetInt64ValueCheckRange(Dart_GetNativeArgument(args, 6), 0, 2); |
147 Dart_Handle stdin_handle = Dart_GetNativeArgument(args, 6); | 149 Dart_Handle stdin_handle = Dart_GetNativeArgument(args, 7); |
148 Dart_Handle stdout_handle = Dart_GetNativeArgument(args, 7); | 150 Dart_Handle stdout_handle = Dart_GetNativeArgument(args, 8); |
149 Dart_Handle stderr_handle = Dart_GetNativeArgument(args, 8); | 151 Dart_Handle stderr_handle = Dart_GetNativeArgument(args, 9); |
150 Dart_Handle exit_handle = Dart_GetNativeArgument(args, 9); | 152 Dart_Handle exit_handle = Dart_GetNativeArgument(args, 10); |
151 intptr_t pid = -1; | 153 intptr_t pid = -1; |
152 char* os_error_message = NULL; // Scope allocated by Process::Start. | 154 char* os_error_message = NULL; // Scope allocated by Process::Start. |
153 | 155 |
154 int error_code = Process::Start( | 156 int error_code = Process::Start(namespc, |
155 path, string_args, args_length, working_directory, string_environment, | 157 path, string_args, args_length, working_directory, string_environment, |
156 environment_length, static_cast<ProcessStartMode>(mode), &process_stdout, | 158 environment_length, static_cast<ProcessStartMode>(mode), &process_stdout, |
157 &process_stdin, &process_stderr, &pid, &exit_event, &os_error_message); | 159 &process_stdin, &process_stderr, &pid, &exit_event, &os_error_message); |
158 if (error_code == 0) { | 160 if (error_code == 0) { |
159 if (mode != kDetached) { | 161 if (mode != kDetached) { |
160 Socket::SetSocketIdNativeField(stdin_handle, process_stdin, | 162 Socket::SetSocketIdNativeField(stdin_handle, process_stdin, |
161 Socket::kFinalizerNormal); | 163 Socket::kFinalizerNormal); |
162 Socket::SetSocketIdNativeField(stdout_handle, process_stdout, | 164 Socket::SetSocketIdNativeField(stdout_handle, process_stdout, |
163 Socket::kFinalizerNormal); | 165 Socket::kFinalizerNormal); |
164 Socket::SetSocketIdNativeField(stderr_handle, process_stderr, | 166 Socket::SetSocketIdNativeField(stderr_handle, process_stderr, |
(...skipping 11 matching lines...) Expand all Loading... |
176 Dart_PropagateError(result); | 178 Dart_PropagateError(result); |
177 } | 179 } |
178 result = DartUtils::SetStringField(status_handle, "_errorMessage", | 180 result = DartUtils::SetStringField(status_handle, "_errorMessage", |
179 os_error_message != NULL | 181 os_error_message != NULL |
180 ? os_error_message | 182 ? os_error_message |
181 : "Cannot get error message"); | 183 : "Cannot get error message"); |
182 if (Dart_IsError(result)) { | 184 if (Dart_IsError(result)) { |
183 Dart_PropagateError(result); | 185 Dart_PropagateError(result); |
184 } | 186 } |
185 } | 187 } |
186 Dart_SetReturnValue(args, Dart_NewBoolean(error_code == 0)); | 188 Dart_SetBooleanReturnValue(args, error_code == 0); |
187 } | 189 } |
188 | 190 |
189 void FUNCTION_NAME(Process_Wait)(Dart_NativeArguments args) { | 191 void FUNCTION_NAME(Process_Wait)(Dart_NativeArguments args) { |
190 Dart_Handle process = Dart_GetNativeArgument(args, 0); | 192 Dart_Handle process = Dart_GetNativeArgument(args, 0); |
191 Socket* process_stdin = | 193 Socket* process_stdin = |
192 Socket::GetSocketIdNativeField(Dart_GetNativeArgument(args, 1)); | 194 Socket::GetSocketIdNativeField(Dart_GetNativeArgument(args, 1)); |
193 Socket* process_stdout = | 195 Socket* process_stdout = |
194 Socket::GetSocketIdNativeField(Dart_GetNativeArgument(args, 2)); | 196 Socket::GetSocketIdNativeField(Dart_GetNativeArgument(args, 2)); |
195 Socket* process_stderr = | 197 Socket* process_stderr = |
196 Socket::GetSocketIdNativeField(Dart_GetNativeArgument(args, 3)); | 198 Socket::GetSocketIdNativeField(Dart_GetNativeArgument(args, 3)); |
(...skipping 29 matching lines...) Expand all Loading... |
226 Dart_Handle error = DartUtils::NewDartOSError(); | 228 Dart_Handle error = DartUtils::NewDartOSError(); |
227 Process::Kill(pid, 9); | 229 Process::Kill(pid, 9); |
228 Dart_ThrowException(error); | 230 Dart_ThrowException(error); |
229 } | 231 } |
230 } | 232 } |
231 | 233 |
232 void FUNCTION_NAME(Process_KillPid)(Dart_NativeArguments args) { | 234 void FUNCTION_NAME(Process_KillPid)(Dart_NativeArguments args) { |
233 intptr_t pid = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 0)); | 235 intptr_t pid = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 0)); |
234 intptr_t signal = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 1)); | 236 intptr_t signal = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 1)); |
235 bool success = Process::Kill(pid, signal); | 237 bool success = Process::Kill(pid, signal); |
236 Dart_SetReturnValue(args, Dart_NewBoolean(success)); | 238 Dart_SetBooleanReturnValue(args, success); |
237 } | 239 } |
238 | 240 |
239 void FUNCTION_NAME(Process_Exit)(Dart_NativeArguments args) { | 241 void FUNCTION_NAME(Process_Exit)(Dart_NativeArguments args) { |
240 int64_t status = 0; | 242 int64_t status = 0; |
241 // Ignore result if passing invalid argument and just exit 0. | 243 // Ignore result if passing invalid argument and just exit 0. |
242 DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 0), &status); | 244 DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 0), &status); |
243 Process::RunExitHook(status); | 245 Process::RunExitHook(status); |
244 Dart_ExitIsolate(); | 246 Dart_ExitIsolate(); |
245 Platform::Exit(static_cast<int>(status)); | 247 Platform::Exit(static_cast<int>(status)); |
246 } | 248 } |
247 | 249 |
248 void FUNCTION_NAME(Process_SetExitCode)(Dart_NativeArguments args) { | 250 void FUNCTION_NAME(Process_SetExitCode)(Dart_NativeArguments args) { |
249 int64_t status = 0; | 251 int64_t status = 0; |
250 // Ignore result if passing invalid argument and just set exit code to 0. | 252 // Ignore result if passing invalid argument and just set exit code to 0. |
251 DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 0), &status); | 253 DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 0), &status); |
252 Process::SetGlobalExitCode(status); | 254 Process::SetGlobalExitCode(status); |
253 } | 255 } |
254 | 256 |
255 void FUNCTION_NAME(Process_GetExitCode)(Dart_NativeArguments args) { | 257 void FUNCTION_NAME(Process_GetExitCode)(Dart_NativeArguments args) { |
256 Dart_SetReturnValue(args, Dart_NewInteger(Process::GlobalExitCode())); | 258 Dart_SetIntegerReturnValue(args, Process::GlobalExitCode()); |
257 } | 259 } |
258 | 260 |
259 void FUNCTION_NAME(Process_Sleep)(Dart_NativeArguments args) { | 261 void FUNCTION_NAME(Process_Sleep)(Dart_NativeArguments args) { |
260 ScopedBlockingCall blocker; | 262 ScopedBlockingCall blocker; |
261 int64_t milliseconds = 0; | 263 int64_t milliseconds = 0; |
262 // Ignore result if passing invalid argument and just set exit code to 0. | 264 // Ignore result if passing invalid argument and just set exit code to 0. |
263 DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 0), &milliseconds); | 265 DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 0), &milliseconds); |
264 TimerUtils::Sleep(milliseconds); | 266 TimerUtils::Sleep(milliseconds); |
265 } | 267 } |
266 | 268 |
267 void FUNCTION_NAME(Process_Pid)(Dart_NativeArguments args) { | 269 void FUNCTION_NAME(Process_Pid)(Dart_NativeArguments args) { |
268 // Ignore result if passing invalid argument and just set exit code to 0. | 270 // Ignore result if passing invalid argument and just set exit code to 0. |
269 intptr_t pid = -1; | 271 intptr_t pid = -1; |
270 Dart_Handle process = Dart_GetNativeArgument(args, 0); | 272 Dart_Handle process = Dart_GetNativeArgument(args, 0); |
271 if (Dart_IsNull(process)) { | 273 if (Dart_IsNull(process)) { |
272 pid = Process::CurrentProcessId(); | 274 pid = Process::CurrentProcessId(); |
273 } else { | 275 } else { |
274 Process::GetProcessIdNativeField(process, &pid); | 276 Process::GetProcessIdNativeField(process, &pid); |
275 } | 277 } |
276 Dart_SetReturnValue(args, Dart_NewInteger(pid)); | 278 Dart_SetIntegerReturnValue(args, pid); |
277 } | 279 } |
278 | 280 |
279 void FUNCTION_NAME(Process_SetSignalHandler)(Dart_NativeArguments args) { | 281 void FUNCTION_NAME(Process_SetSignalHandler)(Dart_NativeArguments args) { |
280 intptr_t signal = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 0)); | 282 intptr_t signal = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 0)); |
281 intptr_t id = Process::SetSignalHandler(signal); | 283 intptr_t id = Process::SetSignalHandler(signal); |
282 if (id == -1) { | 284 if (id == -1) { |
283 Dart_SetReturnValue(args, DartUtils::NewDartOSError()); | 285 Dart_SetReturnValue(args, DartUtils::NewDartOSError()); |
284 } else { | 286 } else { |
285 Dart_SetReturnValue(args, Dart_NewInteger(id)); | 287 Dart_SetIntegerReturnValue(args, id); |
286 } | 288 } |
287 } | 289 } |
288 | 290 |
289 void FUNCTION_NAME(Process_ClearSignalHandler)(Dart_NativeArguments args) { | 291 void FUNCTION_NAME(Process_ClearSignalHandler)(Dart_NativeArguments args) { |
290 intptr_t signal = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 0)); | 292 intptr_t signal = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 0)); |
291 Process::ClearSignalHandler(signal, Dart_GetMainPortId()); | 293 Process::ClearSignalHandler(signal, Dart_GetMainPortId()); |
292 } | 294 } |
293 | 295 |
294 Dart_Handle Process::GetProcessIdNativeField(Dart_Handle process, | 296 Dart_Handle Process::GetProcessIdNativeField(Dart_Handle process, |
295 intptr_t* pid) { | 297 intptr_t* pid) { |
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
369 | 371 |
370 void Process::GetRSSInformation(int64_t* max_rss, int64_t* current_rss) { | 372 void Process::GetRSSInformation(int64_t* max_rss, int64_t* current_rss) { |
371 ASSERT(max_rss != NULL); | 373 ASSERT(max_rss != NULL); |
372 ASSERT(current_rss != NULL); | 374 ASSERT(current_rss != NULL); |
373 *max_rss = Process::MaxRSS(); | 375 *max_rss = Process::MaxRSS(); |
374 *current_rss = Process::CurrentRSS(); | 376 *current_rss = Process::CurrentRSS(); |
375 } | 377 } |
376 | 378 |
377 } // namespace bin | 379 } // namespace bin |
378 } // namespace dart | 380 } // namespace dart |
OLD | NEW |