| Index: runtime/bin/socket_base_fuchsia.cc
|
| diff --git a/runtime/bin/socket_base_fuchsia.cc b/runtime/bin/socket_base_fuchsia.cc
|
| deleted file mode 100644
|
| index 63b358e4221bcd20f87278e9d54244374669af9c..0000000000000000000000000000000000000000
|
| --- a/runtime/bin/socket_base_fuchsia.cc
|
| +++ /dev/null
|
| @@ -1,370 +0,0 @@
|
| -// Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file
|
| -// for details. All rights reserved. Use of this source code is governed by a
|
| -// BSD-style license that can be found in the LICENSE file.
|
| -
|
| -#if !defined(DART_IO_DISABLED)
|
| -
|
| -#include "platform/globals.h"
|
| -#if defined(HOST_OS_FUCHSIA)
|
| -
|
| -#include "bin/socket_base.h"
|
| -
|
| -#include <errno.h> // NOLINT
|
| -#include <fcntl.h> // NOLINT
|
| -#include <ifaddrs.h> // NOLINT
|
| -#include <net/if.h> // NOLINT
|
| -#include <netinet/tcp.h> // NOLINT
|
| -#include <stdio.h> // NOLINT
|
| -#include <stdlib.h> // NOLINT
|
| -#include <string.h> // NOLINT
|
| -#include <sys/ioctl.h> // NOLINT
|
| -#include <sys/stat.h> // NOLINT
|
| -#include <unistd.h> // NOLINT
|
| -
|
| -#include "bin/fdutils.h"
|
| -#include "bin/file.h"
|
| -#include "bin/socket_base_fuchsia.h"
|
| -#include "platform/signal_blocker.h"
|
| -
|
| -// #define SOCKET_LOG_INFO 1
|
| -// #define SOCKET_LOG_ERROR 1
|
| -
|
| -// define SOCKET_LOG_ERROR to get log messages only for errors.
|
| -// define SOCKET_LOG_INFO to get log messages for both information and errors.
|
| -#if defined(SOCKET_LOG_INFO) || defined(SOCKET_LOG_ERROR)
|
| -#define LOG_ERR(msg, ...) \
|
| - { \
|
| - int err = errno; \
|
| - Log::PrintErr("Dart Socket ERROR: %s:%d: " msg, __FILE__, __LINE__, \
|
| - ##__VA_ARGS__); \
|
| - errno = err; \
|
| - }
|
| -#if defined(SOCKET_LOG_INFO)
|
| -#define LOG_INFO(msg, ...) \
|
| - Log::Print("Dart Socket INFO: %s:%d: " msg, __FILE__, __LINE__, ##__VA_ARGS__)
|
| -#else
|
| -#define LOG_INFO(msg, ...)
|
| -#endif // defined(SOCKET_LOG_INFO)
|
| -#else
|
| -#define LOG_ERR(msg, ...)
|
| -#define LOG_INFO(msg, ...)
|
| -#endif // defined(SOCKET_LOG_INFO) || defined(SOCKET_LOG_ERROR)
|
| -
|
| -namespace dart {
|
| -namespace bin {
|
| -
|
| -SocketAddress::SocketAddress(struct sockaddr* sa) {
|
| - ASSERT(INET6_ADDRSTRLEN >= INET_ADDRSTRLEN);
|
| - if (!SocketBase::FormatNumericAddress(*reinterpret_cast<RawAddr*>(sa),
|
| - as_string_, INET6_ADDRSTRLEN)) {
|
| - as_string_[0] = 0;
|
| - }
|
| - socklen_t salen = GetAddrLength(*reinterpret_cast<RawAddr*>(sa));
|
| - memmove(reinterpret_cast<void*>(&addr_), sa, salen);
|
| -}
|
| -
|
| -
|
| -bool SocketBase::FormatNumericAddress(const RawAddr& addr,
|
| - char* address,
|
| - int len) {
|
| - socklen_t salen = SocketAddress::GetAddrLength(addr);
|
| - LOG_INFO("SocketBase::FormatNumericAddress: calling getnameinfo\n");
|
| - return (NO_RETRY_EXPECTED(getnameinfo(&addr.addr, salen, address, len, NULL,
|
| - 0, NI_NUMERICHOST) == 0));
|
| -}
|
| -
|
| -
|
| -bool SocketBase::IsBindError(intptr_t error_number) {
|
| - return error_number == EADDRINUSE || error_number == EADDRNOTAVAIL ||
|
| - error_number == EINVAL;
|
| -}
|
| -
|
| -
|
| -intptr_t SocketBase::Available(intptr_t fd) {
|
| - intptr_t available = FDUtils::AvailableBytes(fd);
|
| - LOG_INFO("SocketBase::Available(%ld) = %ld\n", fd, available);
|
| - return available;
|
| -}
|
| -
|
| -
|
| -intptr_t SocketBase::Read(intptr_t fd, void* buffer, intptr_t num_bytes) {
|
| - ASSERT(fd >= 0);
|
| - LOG_INFO("SocketBase::Read: calling read(%ld, %p, %ld)\n", fd, buffer,
|
| - num_bytes);
|
| - ssize_t read_bytes = NO_RETRY_EXPECTED(read(fd, buffer, num_bytes));
|
| - ASSERT(EAGAIN == EWOULDBLOCK);
|
| - if ((read_bytes == -1) && (errno == EWOULDBLOCK)) {
|
| - // If the read would block we need to retry and therefore return 0
|
| - // as the number of bytes written.
|
| - read_bytes = 0;
|
| - } else if (read_bytes == -1) {
|
| - LOG_ERR("SocketBase::Read: read(%ld, %p, %ld) failed\n", fd, buffer,
|
| - num_bytes);
|
| - } else {
|
| - LOG_INFO("SocketBase::Read: read(%ld, %p, %ld) succeeded\n", fd, buffer,
|
| - num_bytes);
|
| - }
|
| - return read_bytes;
|
| -}
|
| -
|
| -
|
| -intptr_t SocketBase::RecvFrom(intptr_t fd,
|
| - void* buffer,
|
| - intptr_t num_bytes,
|
| - RawAddr* addr) {
|
| - LOG_ERR("SocketBase::RecvFrom is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return -1;
|
| -}
|
| -
|
| -
|
| -intptr_t SocketBase::Write(intptr_t fd,
|
| - const void* buffer,
|
| - intptr_t num_bytes) {
|
| - ASSERT(fd >= 0);
|
| - LOG_INFO("SocketBase::Write: calling write(%ld, %p, %ld)\n", fd, buffer,
|
| - num_bytes);
|
| - ssize_t written_bytes = NO_RETRY_EXPECTED(write(fd, buffer, num_bytes));
|
| - ASSERT(EAGAIN == EWOULDBLOCK);
|
| - if ((written_bytes == -1) && (errno == EWOULDBLOCK)) {
|
| - // If the would block we need to retry and therefore return 0 as
|
| - // the number of bytes written.
|
| - written_bytes = 0;
|
| - } else if (written_bytes == -1) {
|
| - LOG_ERR("SocketBase::Write: write(%ld, %p, %ld) failed\n", fd, buffer,
|
| - num_bytes);
|
| - } else {
|
| - LOG_INFO("SocketBase::Write: write(%ld, %p, %ld) succeeded\n", fd, buffer,
|
| - num_bytes);
|
| - }
|
| - return written_bytes;
|
| -}
|
| -
|
| -
|
| -intptr_t SocketBase::SendTo(intptr_t fd,
|
| - const void* buffer,
|
| - intptr_t num_bytes,
|
| - const RawAddr& addr) {
|
| - LOG_ERR("SocketBase::SendTo is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return -1;
|
| -}
|
| -
|
| -
|
| -intptr_t SocketBase::GetPort(intptr_t fd) {
|
| - ASSERT(fd >= 0);
|
| - RawAddr raw;
|
| - socklen_t size = sizeof(raw);
|
| - LOG_INFO("SocketBase::GetPort: calling getsockname(%ld)\n", fd);
|
| - if (NO_RETRY_EXPECTED(getsockname(fd, &raw.addr, &size))) {
|
| - return 0;
|
| - }
|
| - return SocketAddress::GetAddrPort(raw);
|
| -}
|
| -
|
| -
|
| -SocketAddress* SocketBase::GetRemotePeer(intptr_t fd, intptr_t* port) {
|
| - ASSERT(fd >= 0);
|
| - RawAddr raw;
|
| - socklen_t size = sizeof(raw);
|
| - if (NO_RETRY_EXPECTED(getpeername(fd, &raw.addr, &size))) {
|
| - return NULL;
|
| - }
|
| - *port = SocketAddress::GetAddrPort(raw);
|
| - return new SocketAddress(&raw.addr);
|
| -}
|
| -
|
| -
|
| -void SocketBase::GetError(intptr_t fd, OSError* os_error) {
|
| - LOG_ERR("SocketBase::GetError is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| -}
|
| -
|
| -
|
| -int SocketBase::GetType(intptr_t fd) {
|
| - LOG_ERR("SocketBase::GetType is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return File::kOther;
|
| -}
|
| -
|
| -
|
| -intptr_t SocketBase::GetStdioHandle(intptr_t num) {
|
| - LOG_ERR("SocketBase::GetStdioHandle is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return num;
|
| -}
|
| -
|
| -
|
| -AddressList<SocketAddress>* SocketBase::LookupAddress(const char* host,
|
| - int type,
|
| - OSError** os_error) {
|
| - // Perform a name lookup for a host name.
|
| - struct addrinfo hints;
|
| - memset(&hints, 0, sizeof(hints));
|
| - hints.ai_family = SocketAddress::FromType(type);
|
| - hints.ai_socktype = SOCK_STREAM;
|
| - hints.ai_flags = AI_ADDRCONFIG;
|
| - hints.ai_protocol = IPPROTO_TCP;
|
| - struct addrinfo* info = NULL;
|
| - LOG_INFO("SocketBase::LookupAddress: calling getaddrinfo\n");
|
| - int status = NO_RETRY_EXPECTED(getaddrinfo(host, 0, &hints, &info));
|
| - if (status != 0) {
|
| - // We failed, try without AI_ADDRCONFIG. This can happen when looking up
|
| - // e.g. '::1', when there are no global IPv6 addresses.
|
| - hints.ai_flags = 0;
|
| - LOG_INFO("SocketBase::LookupAddress: calling getaddrinfo again\n");
|
| - status = NO_RETRY_EXPECTED(getaddrinfo(host, 0, &hints, &info));
|
| - if (status != 0) {
|
| - ASSERT(*os_error == NULL);
|
| - *os_error =
|
| - new OSError(status, gai_strerror(status), OSError::kGetAddressInfo);
|
| - return NULL;
|
| - }
|
| - }
|
| - intptr_t count = 0;
|
| - for (struct addrinfo* c = info; c != NULL; c = c->ai_next) {
|
| - if ((c->ai_family == AF_INET) || (c->ai_family == AF_INET6)) {
|
| - count++;
|
| - }
|
| - }
|
| - intptr_t i = 0;
|
| - AddressList<SocketAddress>* addresses = new AddressList<SocketAddress>(count);
|
| - for (struct addrinfo* c = info; c != NULL; c = c->ai_next) {
|
| - if ((c->ai_family == AF_INET) || (c->ai_family == AF_INET6)) {
|
| - addresses->SetAt(i, new SocketAddress(c->ai_addr));
|
| - i++;
|
| - }
|
| - }
|
| - freeaddrinfo(info);
|
| - return addresses;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::ReverseLookup(const RawAddr& addr,
|
| - char* host,
|
| - intptr_t host_len,
|
| - OSError** os_error) {
|
| - LOG_ERR("SocketBase::ReverseLookup is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::ParseAddress(int type, const char* address, RawAddr* addr) {
|
| - int result;
|
| - if (type == SocketAddress::TYPE_IPV4) {
|
| - result = NO_RETRY_EXPECTED(inet_pton(AF_INET, address, &addr->in.sin_addr));
|
| - } else {
|
| - ASSERT(type == SocketAddress::TYPE_IPV6);
|
| - result =
|
| - NO_RETRY_EXPECTED(inet_pton(AF_INET6, address, &addr->in6.sin6_addr));
|
| - }
|
| - return (result == 1);
|
| -}
|
| -
|
| -
|
| -bool SocketBase::ListInterfacesSupported() {
|
| - return false;
|
| -}
|
| -
|
| -
|
| -AddressList<InterfaceSocketAddress>* SocketBase::ListInterfaces(
|
| - int type,
|
| - OSError** os_error) {
|
| - UNIMPLEMENTED();
|
| - return NULL;
|
| -}
|
| -
|
| -
|
| -void SocketBase::Close(intptr_t fd) {
|
| - ASSERT(fd >= 0);
|
| - NO_RETRY_EXPECTED(close(fd));
|
| -}
|
| -
|
| -
|
| -bool SocketBase::GetNoDelay(intptr_t fd, bool* enabled) {
|
| - LOG_ERR("SocketBase::GetNoDelay is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::SetNoDelay(intptr_t fd, bool enabled) {
|
| - int on = enabled ? 1 : 0;
|
| - return NO_RETRY_EXPECTED(setsockopt(fd, IPPROTO_TCP, TCP_NODELAY,
|
| - reinterpret_cast<char*>(&on),
|
| - sizeof(on))) == 0;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::GetMulticastLoop(intptr_t fd,
|
| - intptr_t protocol,
|
| - bool* enabled) {
|
| - LOG_ERR("SocketBase::GetMulticastLoop is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::SetMulticastLoop(intptr_t fd,
|
| - intptr_t protocol,
|
| - bool enabled) {
|
| - LOG_ERR("SocketBase::SetMulticastLoop is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::GetMulticastHops(intptr_t fd, intptr_t protocol, int* value) {
|
| - LOG_ERR("SocketBase::GetMulticastHops is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::SetMulticastHops(intptr_t fd, intptr_t protocol, int value) {
|
| - LOG_ERR("SocketBase::SetMulticastHops is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::GetBroadcast(intptr_t fd, bool* enabled) {
|
| - LOG_ERR("SocketBase::GetBroadcast is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::SetBroadcast(intptr_t fd, bool enabled) {
|
| - LOG_ERR("SocketBase::SetBroadcast is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::JoinMulticast(intptr_t fd,
|
| - const RawAddr& addr,
|
| - const RawAddr&,
|
| - int interfaceIndex) {
|
| - LOG_ERR("SocketBase::JoinMulticast is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -
|
| -bool SocketBase::LeaveMulticast(intptr_t fd,
|
| - const RawAddr& addr,
|
| - const RawAddr&,
|
| - int interfaceIndex) {
|
| - LOG_ERR("SocketBase::LeaveMulticast is unimplemented\n");
|
| - UNIMPLEMENTED();
|
| - return false;
|
| -}
|
| -
|
| -} // namespace bin
|
| -} // namespace dart
|
| -
|
| -#endif // defined(HOST_OS_FUCHSIA)
|
| -
|
| -#endif // !defined(DART_IO_DISABLED)
|
|
|