| 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 "bin/socket_base.h" | 7 #include "bin/socket_base.h" |
| 8 | 8 |
| 9 #include "bin/dartutils.h" | 9 #include "bin/dartutils.h" |
| 10 #include "bin/io_buffer.h" | 10 #include "bin/io_buffer.h" |
| (...skipping 10 matching lines...) Expand all Loading... |
| 21 namespace dart { | 21 namespace dart { |
| 22 namespace bin { | 22 namespace bin { |
| 23 | 23 |
| 24 int SocketAddress::GetType() { | 24 int SocketAddress::GetType() { |
| 25 if (addr_.ss.ss_family == AF_INET6) { | 25 if (addr_.ss.ss_family == AF_INET6) { |
| 26 return TYPE_IPV6; | 26 return TYPE_IPV6; |
| 27 } | 27 } |
| 28 return TYPE_IPV4; | 28 return TYPE_IPV4; |
| 29 } | 29 } |
| 30 | 30 |
| 31 | |
| 32 intptr_t SocketAddress::GetAddrLength(const RawAddr& addr) { | 31 intptr_t SocketAddress::GetAddrLength(const RawAddr& addr) { |
| 33 ASSERT((addr.ss.ss_family == AF_INET) || (addr.ss.ss_family == AF_INET6)); | 32 ASSERT((addr.ss.ss_family == AF_INET) || (addr.ss.ss_family == AF_INET6)); |
| 34 return (addr.ss.ss_family == AF_INET6) ? sizeof(struct sockaddr_in6) | 33 return (addr.ss.ss_family == AF_INET6) ? sizeof(struct sockaddr_in6) |
| 35 : sizeof(struct sockaddr_in); | 34 : sizeof(struct sockaddr_in); |
| 36 } | 35 } |
| 37 | 36 |
| 38 | |
| 39 intptr_t SocketAddress::GetInAddrLength(const RawAddr& addr) { | 37 intptr_t SocketAddress::GetInAddrLength(const RawAddr& addr) { |
| 40 ASSERT((addr.ss.ss_family == AF_INET) || (addr.ss.ss_family == AF_INET6)); | 38 ASSERT((addr.ss.ss_family == AF_INET) || (addr.ss.ss_family == AF_INET6)); |
| 41 return (addr.ss.ss_family == AF_INET6) ? sizeof(struct in6_addr) | 39 return (addr.ss.ss_family == AF_INET6) ? sizeof(struct in6_addr) |
| 42 : sizeof(struct in_addr); | 40 : sizeof(struct in_addr); |
| 43 } | 41 } |
| 44 | 42 |
| 45 | |
| 46 bool SocketAddress::AreAddressesEqual(const RawAddr& a, const RawAddr& b) { | 43 bool SocketAddress::AreAddressesEqual(const RawAddr& a, const RawAddr& b) { |
| 47 if (a.ss.ss_family == AF_INET) { | 44 if (a.ss.ss_family == AF_INET) { |
| 48 if (b.ss.ss_family != AF_INET) { | 45 if (b.ss.ss_family != AF_INET) { |
| 49 return false; | 46 return false; |
| 50 } | 47 } |
| 51 return memcmp(&a.in.sin_addr, &b.in.sin_addr, sizeof(a.in.sin_addr)) == 0; | 48 return memcmp(&a.in.sin_addr, &b.in.sin_addr, sizeof(a.in.sin_addr)) == 0; |
| 52 } else if (a.ss.ss_family == AF_INET6) { | 49 } else if (a.ss.ss_family == AF_INET6) { |
| 53 if (b.ss.ss_family != AF_INET6) { | 50 if (b.ss.ss_family != AF_INET6) { |
| 54 return false; | 51 return false; |
| 55 } | 52 } |
| 56 return memcmp(&a.in6.sin6_addr, &b.in6.sin6_addr, | 53 return memcmp(&a.in6.sin6_addr, &b.in6.sin6_addr, |
| 57 sizeof(a.in6.sin6_addr)) == 0; | 54 sizeof(a.in6.sin6_addr)) == 0; |
| 58 } else { | 55 } else { |
| 59 UNREACHABLE(); | 56 UNREACHABLE(); |
| 60 return false; | 57 return false; |
| 61 } | 58 } |
| 62 } | 59 } |
| 63 | 60 |
| 64 | |
| 65 void SocketAddress::GetSockAddr(Dart_Handle obj, RawAddr* addr) { | 61 void SocketAddress::GetSockAddr(Dart_Handle obj, RawAddr* addr) { |
| 66 Dart_TypedData_Type data_type; | 62 Dart_TypedData_Type data_type; |
| 67 uint8_t* data = NULL; | 63 uint8_t* data = NULL; |
| 68 intptr_t len; | 64 intptr_t len; |
| 69 Dart_Handle result = Dart_TypedDataAcquireData( | 65 Dart_Handle result = Dart_TypedDataAcquireData( |
| 70 obj, &data_type, reinterpret_cast<void**>(&data), &len); | 66 obj, &data_type, reinterpret_cast<void**>(&data), &len); |
| 71 if (Dart_IsError(result)) { | 67 if (Dart_IsError(result)) { |
| 72 Dart_PropagateError(result); | 68 Dart_PropagateError(result); |
| 73 } | 69 } |
| 74 if ((data_type != Dart_TypedData_kUint8) || | 70 if ((data_type != Dart_TypedData_kUint8) || |
| 75 ((len != sizeof(in_addr)) && (len != sizeof(in6_addr)))) { | 71 ((len != sizeof(in_addr)) && (len != sizeof(in6_addr)))) { |
| 76 Dart_PropagateError(Dart_NewApiError("Unexpected type for socket address")); | 72 Dart_PropagateError(Dart_NewApiError("Unexpected type for socket address")); |
| 77 } | 73 } |
| 78 memset(reinterpret_cast<void*>(addr), 0, sizeof(RawAddr)); | 74 memset(reinterpret_cast<void*>(addr), 0, sizeof(RawAddr)); |
| 79 if (len == sizeof(in_addr)) { | 75 if (len == sizeof(in_addr)) { |
| 80 addr->in.sin_family = AF_INET; | 76 addr->in.sin_family = AF_INET; |
| 81 memmove(reinterpret_cast<void*>(&addr->in.sin_addr), data, len); | 77 memmove(reinterpret_cast<void*>(&addr->in.sin_addr), data, len); |
| 82 } else { | 78 } else { |
| 83 ASSERT(len == sizeof(in6_addr)); | 79 ASSERT(len == sizeof(in6_addr)); |
| 84 addr->in6.sin6_family = AF_INET6; | 80 addr->in6.sin6_family = AF_INET6; |
| 85 memmove(reinterpret_cast<void*>(&addr->in6.sin6_addr), data, len); | 81 memmove(reinterpret_cast<void*>(&addr->in6.sin6_addr), data, len); |
| 86 } | 82 } |
| 87 Dart_TypedDataReleaseData(obj); | 83 Dart_TypedDataReleaseData(obj); |
| 88 } | 84 } |
| 89 | 85 |
| 90 | |
| 91 int16_t SocketAddress::FromType(int type) { | 86 int16_t SocketAddress::FromType(int type) { |
| 92 if (type == TYPE_ANY) { | 87 if (type == TYPE_ANY) { |
| 93 return AF_UNSPEC; | 88 return AF_UNSPEC; |
| 94 } | 89 } |
| 95 if (type == TYPE_IPV4) { | 90 if (type == TYPE_IPV4) { |
| 96 return AF_INET; | 91 return AF_INET; |
| 97 } | 92 } |
| 98 ASSERT((type == TYPE_IPV6) && "Invalid type"); | 93 ASSERT((type == TYPE_IPV6) && "Invalid type"); |
| 99 return AF_INET6; | 94 return AF_INET6; |
| 100 } | 95 } |
| 101 | 96 |
| 102 | |
| 103 void SocketAddress::SetAddrPort(RawAddr* addr, intptr_t port) { | 97 void SocketAddress::SetAddrPort(RawAddr* addr, intptr_t port) { |
| 104 if (addr->ss.ss_family == AF_INET) { | 98 if (addr->ss.ss_family == AF_INET) { |
| 105 addr->in.sin_port = htons(port); | 99 addr->in.sin_port = htons(port); |
| 106 } else { | 100 } else { |
| 107 addr->in6.sin6_port = htons(port); | 101 addr->in6.sin6_port = htons(port); |
| 108 } | 102 } |
| 109 } | 103 } |
| 110 | 104 |
| 111 | |
| 112 intptr_t SocketAddress::GetAddrPort(const RawAddr& addr) { | 105 intptr_t SocketAddress::GetAddrPort(const RawAddr& addr) { |
| 113 if (addr.ss.ss_family == AF_INET) { | 106 if (addr.ss.ss_family == AF_INET) { |
| 114 return ntohs(addr.in.sin_port); | 107 return ntohs(addr.in.sin_port); |
| 115 } else { | 108 } else { |
| 116 return ntohs(addr.in6.sin6_port); | 109 return ntohs(addr.in6.sin6_port); |
| 117 } | 110 } |
| 118 } | 111 } |
| 119 | 112 |
| 120 | |
| 121 Dart_Handle SocketAddress::ToTypedData(const RawAddr& addr) { | 113 Dart_Handle SocketAddress::ToTypedData(const RawAddr& addr) { |
| 122 int len = GetInAddrLength(addr); | 114 int len = GetInAddrLength(addr); |
| 123 Dart_Handle result = Dart_NewTypedData(Dart_TypedData_kUint8, len); | 115 Dart_Handle result = Dart_NewTypedData(Dart_TypedData_kUint8, len); |
| 124 if (Dart_IsError(result)) { | 116 if (Dart_IsError(result)) { |
| 125 Dart_PropagateError(result); | 117 Dart_PropagateError(result); |
| 126 } | 118 } |
| 127 Dart_Handle err; | 119 Dart_Handle err; |
| 128 if (addr.addr.sa_family == AF_INET6) { | 120 if (addr.addr.sa_family == AF_INET6) { |
| 129 err = Dart_ListSetAsBytes( | 121 err = Dart_ListSetAsBytes( |
| 130 result, 0, reinterpret_cast<const uint8_t*>(&addr.in6.sin6_addr), len); | 122 result, 0, reinterpret_cast<const uint8_t*>(&addr.in6.sin6_addr), len); |
| 131 } else { | 123 } else { |
| 132 err = Dart_ListSetAsBytes( | 124 err = Dart_ListSetAsBytes( |
| 133 result, 0, reinterpret_cast<const uint8_t*>(&addr.in.sin_addr), len); | 125 result, 0, reinterpret_cast<const uint8_t*>(&addr.in.sin_addr), len); |
| 134 } | 126 } |
| 135 if (Dart_IsError(err)) { | 127 if (Dart_IsError(err)) { |
| 136 Dart_PropagateError(err); | 128 Dart_PropagateError(err); |
| 137 } | 129 } |
| 138 return result; | 130 return result; |
| 139 } | 131 } |
| 140 | 132 |
| 141 | |
| 142 CObjectUint8Array* SocketAddress::ToCObject(const RawAddr& addr) { | 133 CObjectUint8Array* SocketAddress::ToCObject(const RawAddr& addr) { |
| 143 int in_addr_len = SocketAddress::GetInAddrLength(addr); | 134 int in_addr_len = SocketAddress::GetInAddrLength(addr); |
| 144 const void* in_addr; | 135 const void* in_addr; |
| 145 CObjectUint8Array* data = | 136 CObjectUint8Array* data = |
| 146 new CObjectUint8Array(CObject::NewUint8Array(in_addr_len)); | 137 new CObjectUint8Array(CObject::NewUint8Array(in_addr_len)); |
| 147 if (addr.addr.sa_family == AF_INET6) { | 138 if (addr.addr.sa_family == AF_INET6) { |
| 148 in_addr = reinterpret_cast<const void*>(&addr.in6.sin6_addr); | 139 in_addr = reinterpret_cast<const void*>(&addr.in6.sin6_addr); |
| 149 } else { | 140 } else { |
| 150 in_addr = reinterpret_cast<const void*>(&addr.in.sin_addr); | 141 in_addr = reinterpret_cast<const void*>(&addr.in.sin_addr); |
| 151 } | 142 } |
| 152 memmove(data->Buffer(), in_addr, in_addr_len); | 143 memmove(data->Buffer(), in_addr, in_addr_len); |
| 153 return data; | 144 return data; |
| 154 } | 145 } |
| 155 | 146 |
| 156 | |
| 157 void FUNCTION_NAME(InternetAddress_Parse)(Dart_NativeArguments args) { | 147 void FUNCTION_NAME(InternetAddress_Parse)(Dart_NativeArguments args) { |
| 158 const char* address = | 148 const char* address = |
| 159 DartUtils::GetStringValue(Dart_GetNativeArgument(args, 0)); | 149 DartUtils::GetStringValue(Dart_GetNativeArgument(args, 0)); |
| 160 ASSERT(address != NULL); | 150 ASSERT(address != NULL); |
| 161 RawAddr raw; | 151 RawAddr raw; |
| 162 memset(&raw, 0, sizeof(raw)); | 152 memset(&raw, 0, sizeof(raw)); |
| 163 int type = strchr(address, ':') == NULL ? SocketAddress::TYPE_IPV4 | 153 int type = strchr(address, ':') == NULL ? SocketAddress::TYPE_IPV4 |
| 164 : SocketAddress::TYPE_IPV6; | 154 : SocketAddress::TYPE_IPV6; |
| 165 if (type == SocketAddress::TYPE_IPV4) { | 155 if (type == SocketAddress::TYPE_IPV4) { |
| 166 raw.addr.sa_family = AF_INET; | 156 raw.addr.sa_family = AF_INET; |
| 167 } else { | 157 } else { |
| 168 raw.addr.sa_family = AF_INET6; | 158 raw.addr.sa_family = AF_INET6; |
| 169 } | 159 } |
| 170 bool ok = SocketBase::ParseAddress(type, address, &raw); | 160 bool ok = SocketBase::ParseAddress(type, address, &raw); |
| 171 if (!ok) { | 161 if (!ok) { |
| 172 Dart_SetReturnValue(args, Dart_Null()); | 162 Dart_SetReturnValue(args, Dart_Null()); |
| 173 } else { | 163 } else { |
| 174 Dart_SetReturnValue(args, SocketAddress::ToTypedData(raw)); | 164 Dart_SetReturnValue(args, SocketAddress::ToTypedData(raw)); |
| 175 } | 165 } |
| 176 } | 166 } |
| 177 | 167 |
| 178 | |
| 179 void FUNCTION_NAME(NetworkInterface_ListSupported)(Dart_NativeArguments args) { | 168 void FUNCTION_NAME(NetworkInterface_ListSupported)(Dart_NativeArguments args) { |
| 180 Dart_SetReturnValue(args, | 169 Dart_SetReturnValue(args, |
| 181 Dart_NewBoolean(SocketBase::ListInterfacesSupported())); | 170 Dart_NewBoolean(SocketBase::ListInterfacesSupported())); |
| 182 } | 171 } |
| 183 | 172 |
| 184 | |
| 185 void FUNCTION_NAME(SocketBase_IsBindError)(Dart_NativeArguments args) { | 173 void FUNCTION_NAME(SocketBase_IsBindError)(Dart_NativeArguments args) { |
| 186 intptr_t error_number = | 174 intptr_t error_number = |
| 187 DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 1)); | 175 DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 1)); |
| 188 bool is_bind_error = SocketBase::IsBindError(error_number); | 176 bool is_bind_error = SocketBase::IsBindError(error_number); |
| 189 Dart_SetReturnValue(args, is_bind_error ? Dart_True() : Dart_False()); | 177 Dart_SetReturnValue(args, is_bind_error ? Dart_True() : Dart_False()); |
| 190 } | 178 } |
| 191 | 179 |
| 192 } // namespace bin | 180 } // namespace bin |
| 193 } // namespace dart | 181 } // namespace dart |
| 194 | 182 |
| 195 #endif // !defined(DART_IO_DISABLED) | 183 #endif // !defined(DART_IO_DISABLED) |
| OLD | NEW |