OLD | NEW |
1 // Copyright (c) 2017, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2017, 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 #if !defined(DART_IO_DISABLED) | 5 #if !defined(DART_IO_DISABLED) |
6 | 6 |
7 #include "platform/globals.h" | 7 #include "platform/globals.h" |
8 #if defined(HOST_OS_MACOS) | 8 #if defined(HOST_OS_MACOS) |
9 | 9 |
10 #include "bin/sync_socket.h" | 10 #include "bin/sync_socket.h" |
11 | 11 |
12 #include <errno.h> // NOLINT | 12 #include <errno.h> // NOLINT |
13 | 13 |
14 #include "bin/fdutils.h" | 14 #include "bin/fdutils.h" |
15 #include "bin/socket_base.h" | 15 #include "bin/socket_base.h" |
16 #include "platform/signal_blocker.h" | 16 #include "platform/signal_blocker.h" |
17 | 17 |
18 namespace dart { | 18 namespace dart { |
19 namespace bin { | 19 namespace bin { |
20 | 20 |
21 bool SynchronousSocket::Initialize() { | 21 bool SynchronousSocket::Initialize() { |
22 // Nothing to do on Linux. | 22 // Nothing to do on Linux. |
23 return true; | 23 return true; |
24 } | 24 } |
25 | 25 |
26 | |
27 static intptr_t Create(const RawAddr& addr) { | 26 static intptr_t Create(const RawAddr& addr) { |
28 intptr_t fd; | 27 intptr_t fd; |
29 fd = NO_RETRY_EXPECTED(socket(addr.ss.ss_family, SOCK_STREAM, 0)); | 28 fd = NO_RETRY_EXPECTED(socket(addr.ss.ss_family, SOCK_STREAM, 0)); |
30 if (fd < 0) { | 29 if (fd < 0) { |
31 return -1; | 30 return -1; |
32 } | 31 } |
33 if (!FDUtils::SetCloseOnExec(fd)) { | 32 if (!FDUtils::SetCloseOnExec(fd)) { |
34 FDUtils::SaveErrorAndClose(fd); | 33 FDUtils::SaveErrorAndClose(fd); |
35 return -1; | 34 return -1; |
36 } | 35 } |
37 return fd; | 36 return fd; |
38 } | 37 } |
39 | 38 |
40 | |
41 static intptr_t Connect(intptr_t fd, const RawAddr& addr) { | 39 static intptr_t Connect(intptr_t fd, const RawAddr& addr) { |
42 intptr_t result = TEMP_FAILURE_RETRY( | 40 intptr_t result = TEMP_FAILURE_RETRY( |
43 connect(fd, &addr.addr, SocketAddress::GetAddrLength(addr))); | 41 connect(fd, &addr.addr, SocketAddress::GetAddrLength(addr))); |
44 if (result == 0) { | 42 if (result == 0) { |
45 return fd; | 43 return fd; |
46 } | 44 } |
47 ASSERT(errno != EINPROGRESS); | 45 ASSERT(errno != EINPROGRESS); |
48 FDUtils::FDUtils::SaveErrorAndClose(fd); | 46 FDUtils::FDUtils::SaveErrorAndClose(fd); |
49 return -1; | 47 return -1; |
50 } | 48 } |
51 | 49 |
52 | |
53 intptr_t SynchronousSocket::CreateConnect(const RawAddr& addr) { | 50 intptr_t SynchronousSocket::CreateConnect(const RawAddr& addr) { |
54 intptr_t fd = Create(addr); | 51 intptr_t fd = Create(addr); |
55 if (fd < 0) { | 52 if (fd < 0) { |
56 return fd; | 53 return fd; |
57 } | 54 } |
58 return Connect(fd, addr); | 55 return Connect(fd, addr); |
59 } | 56 } |
60 | 57 |
61 | |
62 intptr_t SynchronousSocket::Available(intptr_t fd) { | 58 intptr_t SynchronousSocket::Available(intptr_t fd) { |
63 return SocketBase::Available(fd); | 59 return SocketBase::Available(fd); |
64 } | 60 } |
65 | 61 |
66 | |
67 intptr_t SynchronousSocket::GetPort(intptr_t fd) { | 62 intptr_t SynchronousSocket::GetPort(intptr_t fd) { |
68 return SocketBase::GetPort(fd); | 63 return SocketBase::GetPort(fd); |
69 } | 64 } |
70 | 65 |
71 | |
72 SocketAddress* SynchronousSocket::GetRemotePeer(intptr_t fd, intptr_t* port) { | 66 SocketAddress* SynchronousSocket::GetRemotePeer(intptr_t fd, intptr_t* port) { |
73 return SocketBase::GetRemotePeer(fd, port); | 67 return SocketBase::GetRemotePeer(fd, port); |
74 } | 68 } |
75 | 69 |
76 | |
77 intptr_t SynchronousSocket::Read(intptr_t fd, | 70 intptr_t SynchronousSocket::Read(intptr_t fd, |
78 void* buffer, | 71 void* buffer, |
79 intptr_t num_bytes) { | 72 intptr_t num_bytes) { |
80 return SocketBase::Read(fd, buffer, num_bytes, SocketBase::kSync); | 73 return SocketBase::Read(fd, buffer, num_bytes, SocketBase::kSync); |
81 } | 74 } |
82 | 75 |
83 | |
84 intptr_t SynchronousSocket::Write(intptr_t fd, | 76 intptr_t SynchronousSocket::Write(intptr_t fd, |
85 const void* buffer, | 77 const void* buffer, |
86 intptr_t num_bytes) { | 78 intptr_t num_bytes) { |
87 return SocketBase::Write(fd, buffer, num_bytes, SocketBase::kSync); | 79 return SocketBase::Write(fd, buffer, num_bytes, SocketBase::kSync); |
88 } | 80 } |
89 | 81 |
90 | |
91 void SynchronousSocket::ShutdownRead(intptr_t fd) { | 82 void SynchronousSocket::ShutdownRead(intptr_t fd) { |
92 VOID_NO_RETRY_EXPECTED(shutdown(fd, SHUT_RD)); | 83 VOID_NO_RETRY_EXPECTED(shutdown(fd, SHUT_RD)); |
93 } | 84 } |
94 | 85 |
95 | |
96 void SynchronousSocket::ShutdownWrite(intptr_t fd) { | 86 void SynchronousSocket::ShutdownWrite(intptr_t fd) { |
97 VOID_NO_RETRY_EXPECTED(shutdown(fd, SHUT_WR)); | 87 VOID_NO_RETRY_EXPECTED(shutdown(fd, SHUT_WR)); |
98 } | 88 } |
99 | 89 |
100 | |
101 void SynchronousSocket::Close(intptr_t fd) { | 90 void SynchronousSocket::Close(intptr_t fd) { |
102 return SocketBase::Close(fd); | 91 return SocketBase::Close(fd); |
103 } | 92 } |
104 | 93 |
105 } // namespace bin | 94 } // namespace bin |
106 } // namespace dart | 95 } // namespace dart |
107 | 96 |
108 #endif // defined(HOST_OS_MACOS) | 97 #endif // defined(HOST_OS_MACOS) |
109 | 98 |
110 #endif // !defined(DART_IO_DISABLED) | 99 #endif // !defined(DART_IO_DISABLED) |
OLD | NEW |