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 |
3 | // BSD-style license that can be found in the LICENSE file. |
4 | |
5 | #if defined(DART_IO_SECURE_SOCKET_DISABLED) |
6 | |
7 | #include "bin/io_service_no_ssl.h" |
8 | |
9 | #include "bin/dartutils.h" |
10 | #include "bin/directory.h" |
11 | #include "bin/file.h" |
12 | #include "bin/io_buffer.h" |
13 | #include "bin/socket.h" |
14 | #include "bin/utils.h" |
15 | |
16 | #include "include/dart_api.h" |
17 | |
18 | #include "platform/globals.h" |
19 | #include "platform/utils.h" |
20 | |
21 | namespace dart { |
22 | namespace bin { |
23 | |
24 | #define CASE_REQUEST(type, method, id) \ |
25 | case IOService::k##type##method##Request: \ |
26 | response = type::method##Request(data); \ |
27 | break; |
28 | |
29 | void IOServiceCallback(Dart_Port dest_port_id, Dart_CObject* message) { |
30 | Dart_Port reply_port_id = ILLEGAL_PORT; |
31 | CObject* response = CObject::IllegalArgumentError(); |
32 | CObjectArray request(message); |
33 | if ((message->type == Dart_CObject_kArray) && (request.Length() == 4) && |
34 | request[0]->IsInt32() && request[1]->IsSendPort() && |
35 | request[2]->IsInt32() && request[3]->IsArray()) { |
36 | CObjectInt32 message_id(request[0]); |
37 | CObjectSendPort reply_port(request[1]); |
38 | CObjectInt32 request_id(request[2]); |
39 | CObjectArray data(request[3]); |
40 | reply_port_id = reply_port.Value(); |
41 | switch (request_id.Value()) { |
42 | IO_SERVICE_REQUEST_LIST(CASE_REQUEST); |
43 | default: |
44 | UNREACHABLE(); |
45 | } |
46 | } |
47 | |
48 | CObjectArray result(CObject::NewArray(2)); |
49 | result.SetAt(0, request[0]); |
50 | result.SetAt(1, response); |
51 | ASSERT(reply_port_id != ILLEGAL_PORT); |
52 | Dart_PostCObject(reply_port_id, result.AsApiCObject()); |
53 | } |
54 | |
55 | Dart_Port IOService::GetServicePort() { |
56 | return Dart_NewNativePort("IOService" , IOServiceCallback, true); |
57 | } |
58 | |
59 | void FUNCTION_NAME(IOService_NewServicePort)(Dart_NativeArguments args) { |
60 | Dart_SetReturnValue(args, Dart_Null()); |
61 | Dart_Port service_port = IOService::GetServicePort(); |
62 | if (service_port != ILLEGAL_PORT) { |
63 | // Return a send port for the service port. |
64 | Dart_Handle send_port = Dart_NewSendPort(service_port); |
65 | Dart_SetReturnValue(args, send_port); |
66 | } |
67 | } |
68 | |
69 | } // namespace bin |
70 | } // namespace dart |
71 | |
72 | #endif // defined(DART_IO_SECURE_SOCKET_DISABLED) |
73 | |