mirror of
https://github.com/dart-lang/sdk
synced 2024-10-03 10:18:31 +00:00
0b62bb66ed
We are using `epoll()` in edge-triggerred mode, which requires us to hit `EAGAIN` on `write()` before we are guaranteed to receive an `EPOLLOUT` event. `_SocketStreamConsumer` looks at `_NativeSocket.writeAvailable` after issuing a `write` to decide whether it should continue writing or pause and wait until event handler sends us `writeEvent`. However we did not previously set `writeAvailable` to `true` until the first `writeEvent` arrived, which lead to a hang on some Linux servers: we would write a small amount of bytes into a pipe and then wait for `writeEvent`, which would never come, as `epoll()` is only guaranteed to wake up with `EPOLLOUT` if we hit `EAGAIN` on `write()`. This CL also changes `_NativeSocket.nativeWrite` implementation to write bytes into the file descriptor until it gets EAGAIN. This reduces the number of roundtrips between Dart and native. Unfortunately this CL does not come with a regression test because it is relying on concrete `epoll()` behaviour and it this behaviour does not reproduce for me. TEST=Tested manually on the affected servers. FIXED=b/286346121 Fixed: 286346121 Change-Id: I37fef9aa12b1da724b035aa9577b414a8057217e Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/308101 Reviewed-by: Martin Kustermann <kustermann@google.com> Commit-Queue: Slava Egorov <vegorov@google.com>
512 lines
17 KiB
C++
512 lines
17 KiB
C++
// Copyright (c) 2021, 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.
|
|
|
|
#include "platform/globals.h"
|
|
#if defined(DART_HOST_OS_LINUX) || defined(DART_HOST_OS_MACOS)
|
|
#include "bin/socket_base.h"
|
|
|
|
#include <errno.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/stat.h> // NOLINT
|
|
#include <unistd.h> // NOLINT
|
|
|
|
#include "bin/fdutils.h"
|
|
#include "bin/file.h"
|
|
#include "bin/socket_base_macos.h"
|
|
#include "platform/signal_blocker.h"
|
|
|
|
namespace dart {
|
|
namespace bin {
|
|
|
|
SocketAddress::SocketAddress(struct sockaddr* sa, bool unnamed_unix_socket) {
|
|
if (unnamed_unix_socket) {
|
|
// This is an unnamed unix domain socket.
|
|
as_string_[0] = 0;
|
|
} else if (sa->sa_family == AF_UNIX) {
|
|
struct sockaddr_un* un = ((struct sockaddr_un*)sa);
|
|
memmove(as_string_, un->sun_path, sizeof(un->sun_path));
|
|
} else {
|
|
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), unnamed_unix_socket);
|
|
memmove(reinterpret_cast<void*>(&addr_), sa, salen);
|
|
}
|
|
|
|
bool SocketBase::Initialize() {
|
|
// Nothing to do on Posix.
|
|
return true;
|
|
}
|
|
|
|
bool SocketBase::FormatNumericAddress(const RawAddr& addr,
|
|
char* address,
|
|
int len) {
|
|
socklen_t salen = SocketAddress::GetAddrLength(addr);
|
|
return (NO_RETRY_EXPECTED(getnameinfo(&addr.addr, salen, address, len,
|
|
nullptr, 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) {
|
|
return FDUtils::AvailableBytes(fd);
|
|
}
|
|
|
|
intptr_t SocketBase::Read(intptr_t fd,
|
|
void* buffer,
|
|
intptr_t num_bytes,
|
|
SocketOpKind sync) {
|
|
ASSERT(fd >= 0);
|
|
ssize_t read_bytes = TEMP_FAILURE_RETRY(read(fd, buffer, num_bytes));
|
|
ASSERT(EAGAIN == EWOULDBLOCK);
|
|
if ((sync == kAsync) && (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;
|
|
}
|
|
return read_bytes;
|
|
}
|
|
|
|
intptr_t SocketBase::RecvFrom(intptr_t fd,
|
|
void* buffer,
|
|
intptr_t num_bytes,
|
|
RawAddr* addr,
|
|
SocketOpKind sync) {
|
|
ASSERT(fd >= 0);
|
|
socklen_t addr_len = sizeof(addr->ss);
|
|
ssize_t read_bytes = TEMP_FAILURE_RETRY(
|
|
recvfrom(fd, buffer, num_bytes, 0, &addr->addr, &addr_len));
|
|
if ((sync == kAsync) && (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;
|
|
}
|
|
return read_bytes;
|
|
}
|
|
|
|
bool SocketControlMessage::is_file_descriptors_control_message() {
|
|
return level_ == SOL_SOCKET && type_ == SCM_RIGHTS;
|
|
}
|
|
|
|
// The maximum size on macOS is not documented so use the same size as Linux.
|
|
// If the sender message size is larger than this then some
|
|
// SocketControlMessages may not be received.
|
|
// /proc/sys/net/core/optmem_max is corresponding kernel setting.
|
|
const size_t kMaxSocketMessageControlLength = 2048;
|
|
|
|
intptr_t SocketBase::ReceiveMessage(intptr_t fd,
|
|
void* buffer,
|
|
int64_t* p_buffer_num_bytes,
|
|
SocketControlMessage** p_messages,
|
|
SocketOpKind sync,
|
|
OSError* p_oserror) {
|
|
ASSERT(fd >= 0);
|
|
ASSERT(p_messages != nullptr);
|
|
ASSERT(p_buffer_num_bytes != nullptr);
|
|
|
|
struct iovec iov[1];
|
|
memset(iov, 0, sizeof(iov));
|
|
iov[0].iov_base = buffer;
|
|
iov[0].iov_len = *p_buffer_num_bytes;
|
|
|
|
struct msghdr msg;
|
|
memset(&msg, 0, sizeof(msg));
|
|
msg.msg_iov = iov;
|
|
msg.msg_iovlen = 1; // number of elements in iov
|
|
uint8_t control_buffer[kMaxSocketMessageControlLength];
|
|
msg.msg_control = control_buffer;
|
|
msg.msg_controllen = sizeof(control_buffer);
|
|
|
|
int flags = 0;
|
|
#ifdef MSG_CMSG_CLOEXEC
|
|
// MSG_CMSG_CLOEXEC is not supported on macOS.
|
|
flags &= MSG_CMSG_CLOEXEC;
|
|
#endif
|
|
ssize_t read_bytes = TEMP_FAILURE_RETRY(recvmsg(fd, &msg, flags));
|
|
if ((sync == kAsync) && (read_bytes == -1) && (errno == EWOULDBLOCK)) {
|
|
// If the read would block we need to retry and therefore return 0
|
|
// as the number of bytes read.
|
|
return 0;
|
|
}
|
|
if (read_bytes < 0) {
|
|
p_oserror->Reload();
|
|
return read_bytes;
|
|
}
|
|
*p_buffer_num_bytes = read_bytes;
|
|
|
|
struct cmsghdr* cmsg = CMSG_FIRSTHDR(&msg);
|
|
size_t num_messages = 0;
|
|
while (cmsg != nullptr) {
|
|
num_messages++;
|
|
cmsg = CMSG_NXTHDR(&msg, cmsg);
|
|
}
|
|
(*p_messages) = reinterpret_cast<SocketControlMessage*>(
|
|
Dart_ScopeAllocate(sizeof(SocketControlMessage) * num_messages));
|
|
SocketControlMessage* control_message = *p_messages;
|
|
for (cmsg = CMSG_FIRSTHDR(&msg); cmsg != nullptr;
|
|
cmsg = CMSG_NXTHDR(&msg, cmsg), control_message++) {
|
|
void* data = CMSG_DATA(cmsg);
|
|
size_t data_length = cmsg->cmsg_len - (reinterpret_cast<uint8_t*>(data) -
|
|
reinterpret_cast<uint8_t*>(cmsg));
|
|
void* copied_data = Dart_ScopeAllocate(data_length);
|
|
ASSERT(copied_data != nullptr);
|
|
memmove(copied_data, data, data_length);
|
|
ASSERT(cmsg->cmsg_level == SOL_SOCKET);
|
|
ASSERT(cmsg->cmsg_type == SCM_RIGHTS);
|
|
new (control_message) SocketControlMessage(
|
|
cmsg->cmsg_level, cmsg->cmsg_type, copied_data, data_length);
|
|
|
|
int fd;
|
|
memmove(&fd, CMSG_DATA(cmsg), sizeof(int));
|
|
|
|
#ifndef MSG_CMSG_CLOEXEC
|
|
// MSG_CMSG_CLOEXEC is not supported on macOS.
|
|
if (!FDUtils::SetCloseOnExec(fd)) {
|
|
FDUtils::SaveErrorAndClose(fd);
|
|
return -1;
|
|
}
|
|
#endif
|
|
}
|
|
return num_messages;
|
|
}
|
|
|
|
bool SocketBase::AvailableDatagram(intptr_t fd,
|
|
void* buffer,
|
|
intptr_t num_bytes) {
|
|
ASSERT(fd >= 0);
|
|
ssize_t read_bytes = TEMP_FAILURE_RETRY(
|
|
recvfrom(fd, buffer, num_bytes, MSG_PEEK, nullptr, nullptr));
|
|
return read_bytes >= 0;
|
|
}
|
|
|
|
intptr_t SocketBase::WriteImpl(intptr_t fd,
|
|
const void* buffer,
|
|
intptr_t num_bytes,
|
|
SocketOpKind sync) {
|
|
return TEMP_FAILURE_RETRY(write(fd, buffer, num_bytes));
|
|
}
|
|
|
|
intptr_t SocketBase::SendTo(intptr_t fd,
|
|
const void* buffer,
|
|
intptr_t num_bytes,
|
|
const RawAddr& addr,
|
|
SocketOpKind sync) {
|
|
ASSERT(fd >= 0);
|
|
ssize_t written_bytes =
|
|
TEMP_FAILURE_RETRY(sendto(fd, buffer, num_bytes, 0, &addr.addr,
|
|
SocketAddress::GetAddrLength(addr)));
|
|
ASSERT(EAGAIN == EWOULDBLOCK);
|
|
if ((sync == kAsync) && (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;
|
|
}
|
|
return written_bytes;
|
|
}
|
|
|
|
intptr_t SocketBase::SendMessage(intptr_t fd,
|
|
void* buffer,
|
|
size_t num_bytes,
|
|
SocketControlMessage* messages,
|
|
intptr_t num_messages,
|
|
SocketOpKind sync,
|
|
OSError* p_oserror) {
|
|
ASSERT(fd >= 0);
|
|
|
|
struct iovec iov = {
|
|
.iov_base = buffer,
|
|
.iov_len = num_bytes,
|
|
};
|
|
|
|
struct msghdr msg;
|
|
memset(&msg, 0, sizeof(msg));
|
|
msg.msg_iov = &iov;
|
|
msg.msg_iovlen = 1;
|
|
|
|
if (messages != nullptr && num_messages > 0) {
|
|
SocketControlMessage* message = messages;
|
|
size_t total_length = 0;
|
|
for (intptr_t i = 0; i < num_messages; i++, message++) {
|
|
total_length += CMSG_SPACE(message->data_length());
|
|
}
|
|
|
|
uint8_t* control_buffer =
|
|
reinterpret_cast<uint8_t*>(Dart_ScopeAllocate(total_length));
|
|
memset(control_buffer, 0, total_length);
|
|
msg.msg_control = control_buffer;
|
|
msg.msg_controllen = total_length;
|
|
|
|
struct cmsghdr* cmsg = CMSG_FIRSTHDR(&msg);
|
|
message = messages;
|
|
for (intptr_t i = 0; i < num_messages;
|
|
i++, message++, cmsg = CMSG_NXTHDR(&msg, cmsg)) {
|
|
ASSERT(message->is_file_descriptors_control_message());
|
|
cmsg->cmsg_level = SOL_SOCKET;
|
|
cmsg->cmsg_type = SCM_RIGHTS;
|
|
|
|
intptr_t data_length = message->data_length();
|
|
cmsg->cmsg_len = CMSG_LEN(data_length);
|
|
memmove(CMSG_DATA(cmsg), message->data(), data_length);
|
|
}
|
|
msg.msg_controllen = total_length;
|
|
}
|
|
|
|
ssize_t written_bytes = TEMP_FAILURE_RETRY(sendmsg(fd, &msg, 0));
|
|
ASSERT(EAGAIN == EWOULDBLOCK);
|
|
if ((sync == kAsync) && (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;
|
|
}
|
|
if (written_bytes < 0) {
|
|
p_oserror->Reload();
|
|
}
|
|
|
|
return written_bytes;
|
|
}
|
|
|
|
bool SocketBase::GetSocketName(intptr_t fd, SocketAddress* p_sa) {
|
|
ASSERT(fd >= 0);
|
|
ASSERT(p_sa != nullptr);
|
|
RawAddr raw;
|
|
socklen_t size = sizeof(raw);
|
|
if (NO_RETRY_EXPECTED(getsockname(fd, &raw.addr, &size))) {
|
|
return false;
|
|
}
|
|
|
|
// sockaddr_un contains sa_family_t sun_family and char[] sun_path.
|
|
// If size is the size of sa_family_t, this is an unnamed socket and
|
|
// sun_path contains garbage.
|
|
new (p_sa) SocketAddress(&raw.addr,
|
|
/*unnamed_unix_socket=*/size == sizeof(sa_family_t));
|
|
return true;
|
|
}
|
|
|
|
intptr_t SocketBase::GetPort(intptr_t fd) {
|
|
ASSERT(fd >= 0);
|
|
RawAddr raw;
|
|
socklen_t size = sizeof(raw);
|
|
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 nullptr;
|
|
}
|
|
// sockaddr_un contains sa_family_t sun_family and char[] sun_path.
|
|
// If size is the size of sa_family_t, this is an unnamed socket and
|
|
// sun_path contains garbage.
|
|
if (size == sizeof(sa_family_t)) {
|
|
*port = 0;
|
|
return new SocketAddress(&raw.addr, /*unnamed_unix_socket=*/true);
|
|
}
|
|
*port = SocketAddress::GetAddrPort(raw);
|
|
return new SocketAddress(&raw.addr);
|
|
}
|
|
|
|
intptr_t SocketBase::GetStdioHandle(intptr_t num) {
|
|
return num;
|
|
}
|
|
|
|
bool SocketBase::ReverseLookup(const RawAddr& addr,
|
|
char* host,
|
|
intptr_t host_len,
|
|
OSError** os_error) {
|
|
ASSERT(host_len >= NI_MAXHOST);
|
|
int status = NO_RETRY_EXPECTED(
|
|
getnameinfo(&addr.addr, SocketAddress::GetAddrLength(addr), host,
|
|
host_len, nullptr, 0, NI_NAMEREQD));
|
|
if (status != 0) {
|
|
ASSERT(*os_error == nullptr);
|
|
*os_error =
|
|
new OSError(status, gai_strerror(status), OSError::kGetAddressInfo);
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
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);
|
|
}
|
|
|
|
static bool ShouldIncludeIfaAddrs(struct ifaddrs* ifa, int lookup_family) {
|
|
if (ifa->ifa_addr == nullptr) {
|
|
// OpenVPN's virtual device tun0.
|
|
return false;
|
|
}
|
|
int family = ifa->ifa_addr->sa_family;
|
|
return ((lookup_family == family) ||
|
|
((lookup_family == AF_UNSPEC) &&
|
|
((family == AF_INET) || (family == AF_INET6))));
|
|
}
|
|
|
|
AddressList<InterfaceSocketAddress>* SocketBase::ListInterfaces(
|
|
int type,
|
|
OSError** os_error) {
|
|
struct ifaddrs* ifaddr;
|
|
|
|
int status = NO_RETRY_EXPECTED(getifaddrs(&ifaddr));
|
|
if (status != 0) {
|
|
ASSERT(*os_error == nullptr);
|
|
*os_error =
|
|
new OSError(status, gai_strerror(status), OSError::kGetAddressInfo);
|
|
return nullptr;
|
|
}
|
|
|
|
int lookup_family = SocketAddress::FromType(type);
|
|
|
|
intptr_t count = 0;
|
|
for (struct ifaddrs* ifa = ifaddr; ifa != nullptr; ifa = ifa->ifa_next) {
|
|
if (ShouldIncludeIfaAddrs(ifa, lookup_family)) {
|
|
count++;
|
|
}
|
|
}
|
|
|
|
AddressList<InterfaceSocketAddress>* addresses =
|
|
new AddressList<InterfaceSocketAddress>(count);
|
|
int i = 0;
|
|
for (struct ifaddrs* ifa = ifaddr; ifa != nullptr; ifa = ifa->ifa_next) {
|
|
if (ShouldIncludeIfaAddrs(ifa, lookup_family)) {
|
|
char* ifa_name = DartUtils::ScopedCopyCString(ifa->ifa_name);
|
|
addresses->SetAt(
|
|
i, new InterfaceSocketAddress(ifa->ifa_addr, ifa_name,
|
|
if_nametoindex(ifa->ifa_name)));
|
|
i++;
|
|
}
|
|
}
|
|
freeifaddrs(ifaddr);
|
|
return addresses;
|
|
}
|
|
|
|
void SocketBase::Close(intptr_t fd) {
|
|
ASSERT(fd >= 0);
|
|
close(fd);
|
|
}
|
|
|
|
bool SocketBase::RawAddrToString(RawAddr* addr, char* str) {
|
|
if (addr->addr.sa_family == AF_INET) {
|
|
return inet_ntop(AF_INET, &addr->in.sin_addr, str, INET_ADDRSTRLEN) !=
|
|
nullptr;
|
|
} else {
|
|
ASSERT(addr->addr.sa_family == AF_INET6);
|
|
return inet_ntop(AF_INET6, &addr->in6.sin6_addr, str, INET6_ADDRSTRLEN) !=
|
|
nullptr;
|
|
}
|
|
}
|
|
|
|
bool SocketBase::GetNoDelay(intptr_t fd, bool* enabled) {
|
|
int on;
|
|
socklen_t len = sizeof(on);
|
|
int err = NO_RETRY_EXPECTED(getsockopt(fd, IPPROTO_TCP, TCP_NODELAY,
|
|
reinterpret_cast<void*>(&on), &len));
|
|
if (err == 0) {
|
|
*enabled = (on == 1);
|
|
}
|
|
return (err == 0);
|
|
}
|
|
|
|
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) {
|
|
uint8_t on;
|
|
socklen_t len = sizeof(on);
|
|
int level = protocol == SocketAddress::TYPE_IPV4 ? IPPROTO_IP : IPPROTO_IPV6;
|
|
int optname = protocol == SocketAddress::TYPE_IPV4 ? IP_MULTICAST_LOOP
|
|
: IPV6_MULTICAST_LOOP;
|
|
if (NO_RETRY_EXPECTED(getsockopt(fd, level, optname,
|
|
reinterpret_cast<char*>(&on), &len)) == 0) {
|
|
*enabled = (on == 1);
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
bool SocketBase::GetMulticastHops(intptr_t fd, intptr_t protocol, int* value) {
|
|
uint8_t v;
|
|
socklen_t len = sizeof(v);
|
|
int level = protocol == SocketAddress::TYPE_IPV4 ? IPPROTO_IP : IPPROTO_IPV6;
|
|
int optname = protocol == SocketAddress::TYPE_IPV4 ? IP_MULTICAST_TTL
|
|
: IPV6_MULTICAST_HOPS;
|
|
if (NO_RETRY_EXPECTED(getsockopt(fd, level, optname,
|
|
reinterpret_cast<char*>(&v), &len)) == 0) {
|
|
*value = v;
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
bool SocketBase::SetMulticastHops(intptr_t fd, intptr_t protocol, int value) {
|
|
int v = value;
|
|
int level = protocol == SocketAddress::TYPE_IPV4 ? IPPROTO_IP : IPPROTO_IPV6;
|
|
int optname = protocol == SocketAddress::TYPE_IPV4 ? IP_MULTICAST_TTL
|
|
: IPV6_MULTICAST_HOPS;
|
|
return NO_RETRY_EXPECTED(setsockopt(
|
|
fd, level, optname, reinterpret_cast<char*>(&v), sizeof(v))) == 0;
|
|
}
|
|
|
|
bool SocketBase::GetBroadcast(intptr_t fd, bool* enabled) {
|
|
int on;
|
|
socklen_t len = sizeof(on);
|
|
int err = NO_RETRY_EXPECTED(getsockopt(fd, SOL_SOCKET, SO_BROADCAST,
|
|
reinterpret_cast<char*>(&on), &len));
|
|
if (err == 0) {
|
|
*enabled = (on == 1);
|
|
}
|
|
return (err == 0);
|
|
}
|
|
|
|
bool SocketBase::SetBroadcast(intptr_t fd, bool enabled) {
|
|
int on = enabled ? 1 : 0;
|
|
return NO_RETRY_EXPECTED(setsockopt(fd, SOL_SOCKET, SO_BROADCAST,
|
|
reinterpret_cast<char*>(&on),
|
|
sizeof(on))) == 0;
|
|
}
|
|
|
|
bool SocketBase::SetOption(intptr_t fd,
|
|
int level,
|
|
int option,
|
|
const char* data,
|
|
int length) {
|
|
return NO_RETRY_EXPECTED(setsockopt(fd, level, option, data, length)) == 0;
|
|
}
|
|
|
|
} // namespace bin
|
|
} // namespace dart
|
|
|
|
#endif // defined(DART_HOST_OS_ANDROID) || defined(DART_HOST_OS_LINUX) || \
|
|
// defined(DART_HOST_OS_MACOS)
|