21 char buf[INET_ADDRSTRLEN];
22 if (inet_ntop(AF_INET, &addr->
sin_addr, buf,
sizeof(buf)) !=
nullptr)
23 return std::string{buf};
28 char buf[INET6_ADDRSTRLEN];
31 addr->
sin6_addr.un.u32_addr[2] == htonl(0xFFFF) &&
32 inet_ntop(AF_INET, &addr->
sin6_addr.un.u32_addr[3], buf,
sizeof(buf)) !=
nullptr) {
33 return std::string{buf};
35 if (inet_ntop(AF_INET6, &addr->
sin6_addr, buf,
sizeof(buf)) !=
nullptr)
36 return std::string{buf};
42class BSDSocketImpl :
public Socket {
44 BSDSocketImpl(
int fd,
bool monitor_loop =
false) : fd_(fd) {
45#ifdef USE_SOCKET_SELECT_SUPPORT
47 if (monitor_loop && fd_ >= 0) {
58 ~BSDSocketImpl()
override {
63 int connect(
const struct sockaddr *addr,
socklen_t addrlen)
override { return ::connect(fd_, addr, addrlen); }
64 std::unique_ptr<Socket> accept(
struct sockaddr *addr,
socklen_t *addrlen)
override {
65 return accept_impl_(addr, addrlen,
false);
67 std::unique_ptr<Socket> accept_loop_monitored(
struct sockaddr *addr,
socklen_t *addrlen)
override {
68 return accept_impl_(addr, addrlen,
true);
72 std::unique_ptr<Socket> accept_impl_(
struct sockaddr *addr,
socklen_t *addrlen,
bool loop_monitored) {
73 int fd = ::accept(fd_, addr, addrlen);
80 int bind(
const struct sockaddr *addr,
socklen_t addrlen)
override { return ::bind(fd_, addr, addrlen); }
81 int close()
override {
83#ifdef USE_SOCKET_SELECT_SUPPORT
89 int ret = ::close(fd_);
95 int shutdown(
int how)
override { return ::shutdown(fd_, how); }
97 int getpeername(
struct sockaddr *addr,
socklen_t *addrlen)
override { return ::getpeername(fd_, addr, addrlen); }
98 std::string getpeername()
override {
101 int err = this->getpeername((
struct sockaddr *) &storage, &
len);
106 int getsockname(
struct sockaddr *addr,
socklen_t *addrlen)
override { return ::getsockname(fd_, addr, addrlen); }
107 std::string getsockname()
override {
110 int err = this->getsockname((
struct sockaddr *) &storage, &
len);
115 int getsockopt(
int level,
int optname,
void *optval,
socklen_t *optlen)
override {
116 return ::getsockopt(fd_, level, optname, optval, optlen);
118 int setsockopt(
int level,
int optname,
const void *optval,
socklen_t optlen)
override {
119 return ::setsockopt(fd_, level, optname, optval, optlen);
121 int listen(
int backlog)
override { return ::listen(fd_, backlog); }
122 ssize_t read(
void *buf,
size_t len)
override { return ::read(fd_, buf,
len); }
124#if defined(USE_ESP32) || defined(USE_HOST)
125 return ::recvfrom(this->fd_, buf,
len, 0, addr, addr_len);
127 return ::lwip_recvfrom(this->fd_, buf,
len, 0, addr, addr_len);
130 ssize_t readv(
const struct iovec *iov,
int iovcnt)
override {
131#if defined(USE_ESP32)
132 return ::lwip_readv(fd_, iov, iovcnt);
134 return ::readv(fd_, iov, iovcnt);
137 ssize_t write(
const void *buf,
size_t len)
override { return ::write(fd_, buf,
len); }
138 ssize_t send(
void *buf,
size_t len,
int flags) { return ::send(fd_, buf,
len, flags); }
139 ssize_t writev(
const struct iovec *iov,
int iovcnt)
override {
140#if defined(USE_ESP32)
141 return ::lwip_writev(fd_, iov, iovcnt);
143 return ::writev(fd_, iov, iovcnt);
148 return ::sendto(fd_, buf,
len, flags, to, tolen);
151 int setblocking(
bool blocking)
override {
152 int fl = ::fcntl(fd_, F_GETFL, 0);
158 ::fcntl(fd_, F_SETFL, fl);
162 int get_fd()
const override {
return fd_; }
166 bool closed_ =
false;
170static std::unique_ptr<Socket> create_socket(
int domain,
int type,
int protocol,
bool loop_monitored =
false) {
171 int ret = ::socket(domain,
type, protocol);
174 return std::unique_ptr<Socket>{
new BSDSocketImpl(ret, loop_monitored)};
177std::unique_ptr<Socket>
socket(
int domain,
int type,
int protocol) {
178 return create_socket(domain,
type, protocol,
false);
182 return create_socket(domain,
type, protocol,
true);