2020-01-18 08:38:21 +00:00
|
|
|
/*
|
|
|
|
* Copyright (c) 2018-2020, Andreas Kling <kling@serenityos.org>
|
|
|
|
* All rights reserved.
|
|
|
|
*
|
|
|
|
* Redistribution and use in source and binary forms, with or without
|
|
|
|
* modification, are permitted provided that the following conditions are met:
|
|
|
|
*
|
|
|
|
* 1. Redistributions of source code must retain the above copyright notice, this
|
|
|
|
* list of conditions and the following disclaimer.
|
|
|
|
*
|
|
|
|
* 2. Redistributions in binary form must reproduce the above copyright notice,
|
|
|
|
* this list of conditions and the following disclaimer in the documentation
|
|
|
|
* and/or other materials provided with the distribution.
|
|
|
|
*
|
|
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
|
|
|
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
|
|
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
|
|
|
* DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
|
|
|
|
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
|
|
|
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
|
|
|
|
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
|
|
|
|
* CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
|
|
|
|
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|
|
|
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
|
|
*/
|
|
|
|
|
2020-08-25 01:35:19 +00:00
|
|
|
#include <AK/Singleton.h>
|
2019-08-10 16:10:36 +00:00
|
|
|
#include <AK/StringBuilder.h>
|
2021-01-25 15:07:10 +00:00
|
|
|
#include <Kernel/Debug.h>
|
2019-06-07 09:43:58 +00:00
|
|
|
#include <Kernel/FileSystem/FileDescription.h>
|
|
|
|
#include <Kernel/Net/ARP.h>
|
|
|
|
#include <Kernel/Net/ICMP.h>
|
|
|
|
#include <Kernel/Net/IPv4.h>
|
2019-04-02 17:54:38 +00:00
|
|
|
#include <Kernel/Net/IPv4Socket.h>
|
|
|
|
#include <Kernel/Net/NetworkAdapter.h>
|
2019-06-07 09:43:58 +00:00
|
|
|
#include <Kernel/Net/Routing.h>
|
2019-04-02 17:54:38 +00:00
|
|
|
#include <Kernel/Net/TCP.h>
|
2019-06-07 09:43:58 +00:00
|
|
|
#include <Kernel/Net/TCPSocket.h>
|
2019-04-02 17:54:38 +00:00
|
|
|
#include <Kernel/Net/UDP.h>
|
2019-06-07 09:43:58 +00:00
|
|
|
#include <Kernel/Net/UDPSocket.h>
|
|
|
|
#include <Kernel/Process.h>
|
|
|
|
#include <Kernel/UnixTypes.h>
|
2019-03-12 14:51:42 +00:00
|
|
|
#include <LibC/errno_numbers.h>
|
2019-09-23 17:06:03 +00:00
|
|
|
#include <LibC/sys/ioctl_numbers.h>
|
2019-03-12 14:51:42 +00:00
|
|
|
|
2020-02-16 00:27:42 +00:00
|
|
|
namespace Kernel {
|
|
|
|
|
2020-08-25 01:35:19 +00:00
|
|
|
static AK::Singleton<Lockable<HashTable<IPv4Socket*>>> s_table;
|
|
|
|
|
2019-03-12 16:27:07 +00:00
|
|
|
Lockable<HashTable<IPv4Socket*>>& IPv4Socket::all_sockets()
|
|
|
|
{
|
|
|
|
return *s_table;
|
|
|
|
}
|
|
|
|
|
2020-01-23 17:11:14 +00:00
|
|
|
KResultOr<NonnullRefPtr<Socket>> IPv4Socket::create(int type, int protocol)
|
2019-03-12 14:51:42 +00:00
|
|
|
{
|
2019-03-14 11:20:38 +00:00
|
|
|
if (type == SOCK_STREAM)
|
|
|
|
return TCPSocket::create(protocol);
|
2019-03-14 11:43:18 +00:00
|
|
|
if (type == SOCK_DGRAM)
|
|
|
|
return UDPSocket::create(protocol);
|
2020-01-23 17:11:14 +00:00
|
|
|
if (type == SOCK_RAW)
|
|
|
|
return adopt(*new IPv4Socket(type, protocol));
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINVAL;
|
2019-03-12 14:51:42 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
IPv4Socket::IPv4Socket(int type, int protocol)
|
|
|
|
: Socket(AF_INET, type, protocol)
|
|
|
|
{
|
2021-02-07 12:03:24 +00:00
|
|
|
dbgln_if(IPV4_SOCKET_DEBUG, "IPv4Socket({}) created with type={}, protocol={}", this, type, protocol);
|
2019-12-14 08:43:31 +00:00
|
|
|
m_buffer_mode = type == SOCK_STREAM ? BufferMode::Bytes : BufferMode::Packets;
|
|
|
|
if (m_buffer_mode == BufferMode::Bytes) {
|
|
|
|
m_scratch_buffer = KBuffer::create_with_size(65536);
|
|
|
|
}
|
2019-03-12 16:27:07 +00:00
|
|
|
LOCKER(all_sockets().lock());
|
|
|
|
all_sockets().resource().set(this);
|
2019-03-12 14:51:42 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
IPv4Socket::~IPv4Socket()
|
|
|
|
{
|
2019-03-14 11:43:18 +00:00
|
|
|
LOCKER(all_sockets().lock());
|
|
|
|
all_sockets().resource().remove(this);
|
2019-03-12 14:51:42 +00:00
|
|
|
}
|
|
|
|
|
2020-02-07 22:42:28 +00:00
|
|
|
void IPv4Socket::get_local_address(sockaddr* address, socklen_t* address_size)
|
2019-03-12 14:51:42 +00:00
|
|
|
{
|
2020-02-07 22:42:28 +00:00
|
|
|
sockaddr_in local_address = { AF_INET, htons(m_local_port), { m_local_address.to_in_addr_t() }, { 0 } };
|
|
|
|
memcpy(address, &local_address, min(static_cast<size_t>(*address_size), sizeof(sockaddr_in)));
|
2019-05-20 18:33:03 +00:00
|
|
|
*address_size = sizeof(sockaddr_in);
|
|
|
|
}
|
|
|
|
|
2020-02-07 22:42:28 +00:00
|
|
|
void IPv4Socket::get_peer_address(sockaddr* address, socklen_t* address_size)
|
2019-05-20 18:33:03 +00:00
|
|
|
{
|
2020-02-07 22:42:28 +00:00
|
|
|
sockaddr_in peer_address = { AF_INET, htons(m_peer_port), { m_peer_address.to_in_addr_t() }, { 0 } };
|
|
|
|
memcpy(address, &peer_address, min(static_cast<size_t>(*address_size), sizeof(sockaddr_in)));
|
2019-03-12 14:51:42 +00:00
|
|
|
*address_size = sizeof(sockaddr_in);
|
|
|
|
}
|
|
|
|
|
2020-08-09 22:13:43 +00:00
|
|
|
KResult IPv4Socket::bind(Userspace<const sockaddr*> user_address, socklen_t address_size)
|
2019-03-12 14:51:42 +00:00
|
|
|
{
|
2021-02-23 19:42:32 +00:00
|
|
|
VERIFY(setup_state() == SetupState::Unstarted);
|
2019-03-12 14:51:42 +00:00
|
|
|
if (address_size != sizeof(sockaddr_in))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINVAL;
|
2019-03-12 14:51:42 +00:00
|
|
|
|
2020-01-11 11:07:45 +00:00
|
|
|
sockaddr_in address;
|
2020-09-12 03:11:07 +00:00
|
|
|
if (!copy_from_user(&address, user_address, sizeof(sockaddr_in)))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2020-01-11 11:07:45 +00:00
|
|
|
|
|
|
|
if (address.sin_family != AF_INET)
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINVAL;
|
2019-09-02 16:49:54 +00:00
|
|
|
|
2020-01-11 11:07:45 +00:00
|
|
|
auto requested_local_port = ntohs(address.sin_port);
|
2020-06-28 21:34:31 +00:00
|
|
|
if (!Process::current()->is_superuser()) {
|
2019-09-02 16:49:54 +00:00
|
|
|
if (requested_local_port < 1024) {
|
2021-01-10 14:17:54 +00:00
|
|
|
dbgln("UID {} attempted to bind {} to port {}", Process::current()->uid(), class_name(), requested_local_port);
|
2021-01-20 22:11:17 +00:00
|
|
|
return EACCES;
|
2019-09-02 16:49:54 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-01-11 11:07:45 +00:00
|
|
|
m_local_address = IPv4Address((const u8*)&address.sin_addr.s_addr);
|
2019-09-02 16:49:54 +00:00
|
|
|
m_local_port = requested_local_port;
|
2019-05-03 19:51:40 +00:00
|
|
|
|
2021-02-07 12:03:24 +00:00
|
|
|
dbgln_if(IPV4_SOCKET_DEBUG, "IPv4Socket::bind {}({}) to {}:{}", class_name(), this, m_local_address, m_local_port);
|
2019-05-03 19:51:40 +00:00
|
|
|
|
|
|
|
return protocol_bind();
|
2019-03-12 14:51:42 +00:00
|
|
|
}
|
|
|
|
|
2020-02-25 13:49:47 +00:00
|
|
|
KResult IPv4Socket::listen(size_t backlog)
|
2019-08-06 13:40:38 +00:00
|
|
|
{
|
2020-10-21 18:51:02 +00:00
|
|
|
LOCKER(lock());
|
2019-08-06 13:40:38 +00:00
|
|
|
int rc = allocate_local_port_if_needed();
|
|
|
|
if (rc < 0)
|
2021-01-20 22:11:17 +00:00
|
|
|
return EADDRINUSE;
|
2019-08-06 13:40:38 +00:00
|
|
|
|
|
|
|
set_backlog(backlog);
|
2019-09-08 07:03:03 +00:00
|
|
|
m_role = Role::Listener;
|
2020-11-29 23:05:27 +00:00
|
|
|
evaluate_block_conditions();
|
2019-08-06 13:40:38 +00:00
|
|
|
|
2021-02-07 12:03:24 +00:00
|
|
|
dbgln_if(IPV4_SOCKET_DEBUG, "IPv4Socket({}) listening with backlog={}", this, backlog);
|
2019-08-06 13:40:38 +00:00
|
|
|
|
|
|
|
return protocol_listen();
|
|
|
|
}
|
|
|
|
|
2020-09-12 03:11:07 +00:00
|
|
|
KResult IPv4Socket::connect(FileDescription& description, Userspace<const sockaddr*> address, socklen_t address_size, ShouldBlock should_block)
|
2019-03-12 14:51:42 +00:00
|
|
|
{
|
|
|
|
if (address_size != sizeof(sockaddr_in))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINVAL;
|
2020-09-12 03:11:07 +00:00
|
|
|
u16 sa_family_copy;
|
|
|
|
auto* user_address = reinterpret_cast<const sockaddr*>(address.unsafe_userspace_ptr());
|
|
|
|
if (!copy_from_user(&sa_family_copy, &user_address->sa_family, sizeof(u16)))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2020-09-12 03:11:07 +00:00
|
|
|
if (sa_family_copy != AF_INET)
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINVAL;
|
2019-08-11 13:38:20 +00:00
|
|
|
if (m_role == Role::Connected)
|
2021-01-20 22:11:17 +00:00
|
|
|
return EISCONN;
|
2019-03-12 14:51:42 +00:00
|
|
|
|
2020-09-12 03:11:07 +00:00
|
|
|
sockaddr_in safe_address;
|
|
|
|
if (!copy_from_user(&safe_address, (const sockaddr_in*)user_address, sizeof(sockaddr_in)))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2020-09-12 03:11:07 +00:00
|
|
|
|
|
|
|
m_peer_address = IPv4Address((const u8*)&safe_address.sin_addr.s_addr);
|
|
|
|
m_peer_port = ntohs(safe_address.sin_port);
|
2019-03-13 16:17:07 +00:00
|
|
|
|
2019-06-13 20:03:04 +00:00
|
|
|
return protocol_connect(description, should_block);
|
2019-03-12 14:51:42 +00:00
|
|
|
}
|
|
|
|
|
2020-04-10 09:44:42 +00:00
|
|
|
bool IPv4Socket::can_read(const FileDescription&, size_t) const
|
2019-03-12 14:51:42 +00:00
|
|
|
{
|
2019-08-11 13:38:20 +00:00
|
|
|
if (m_role == Role::Listener)
|
2019-05-03 19:51:40 +00:00
|
|
|
return can_accept();
|
2019-03-14 14:23:32 +00:00
|
|
|
if (protocol_is_disconnected())
|
|
|
|
return true;
|
2019-03-12 16:27:07 +00:00
|
|
|
return m_can_read;
|
2019-03-12 14:51:42 +00:00
|
|
|
}
|
|
|
|
|
2020-04-10 09:44:42 +00:00
|
|
|
bool IPv4Socket::can_write(const FileDescription&, size_t) const
|
2019-03-12 14:51:42 +00:00
|
|
|
{
|
2019-04-08 02:52:21 +00:00
|
|
|
return is_connected();
|
2019-03-12 14:51:42 +00:00
|
|
|
}
|
|
|
|
|
2019-05-04 14:40:34 +00:00
|
|
|
int IPv4Socket::allocate_local_port_if_needed()
|
2019-03-13 15:05:56 +00:00
|
|
|
{
|
2019-05-04 14:40:34 +00:00
|
|
|
if (m_local_port)
|
|
|
|
return m_local_port;
|
|
|
|
int port = protocol_allocate_local_port();
|
2019-03-18 03:03:44 +00:00
|
|
|
if (port < 0)
|
|
|
|
return port;
|
2019-07-03 19:17:35 +00:00
|
|
|
m_local_port = (u16)port;
|
2019-03-18 03:03:44 +00:00
|
|
|
return port;
|
2019-03-13 15:05:56 +00:00
|
|
|
}
|
|
|
|
|
2020-12-20 23:09:48 +00:00
|
|
|
KResultOr<size_t> IPv4Socket::sendto(FileDescription&, const UserOrKernelBuffer& data, size_t data_length, [[maybe_unused]] int flags, Userspace<const sockaddr*> addr, socklen_t addr_length)
|
2019-03-12 14:51:42 +00:00
|
|
|
{
|
2020-10-21 18:51:02 +00:00
|
|
|
LOCKER(lock());
|
|
|
|
|
2019-03-13 22:14:30 +00:00
|
|
|
if (addr && addr_length != sizeof(sockaddr_in))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINVAL;
|
2019-03-12 14:51:42 +00:00
|
|
|
|
2019-03-13 16:17:07 +00:00
|
|
|
if (addr) {
|
2020-08-18 06:49:35 +00:00
|
|
|
sockaddr_in ia;
|
2020-09-12 03:11:07 +00:00
|
|
|
if (!copy_from_user(&ia, Userspace<const sockaddr_in*>(addr.ptr())))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2020-08-18 06:49:35 +00:00
|
|
|
|
|
|
|
if (ia.sin_family != AF_INET) {
|
|
|
|
klog() << "sendto: Bad address family: " << ia.sin_family << " is not AF_INET!";
|
2021-01-20 22:11:17 +00:00
|
|
|
return EAFNOSUPPORT;
|
2019-03-13 22:14:30 +00:00
|
|
|
}
|
|
|
|
|
2019-07-03 19:17:35 +00:00
|
|
|
m_peer_address = IPv4Address((const u8*)&ia.sin_addr.s_addr);
|
2019-05-04 14:40:34 +00:00
|
|
|
m_peer_port = ntohs(ia.sin_port);
|
2019-03-13 16:17:07 +00:00
|
|
|
}
|
2019-03-13 14:40:30 +00:00
|
|
|
|
2020-04-04 20:46:45 +00:00
|
|
|
auto routing_decision = route_to(m_peer_address, m_local_address, bound_interface());
|
2019-08-29 01:18:38 +00:00
|
|
|
if (routing_decision.is_zero())
|
2021-01-20 22:11:17 +00:00
|
|
|
return EHOSTUNREACH;
|
2019-04-02 13:46:44 +00:00
|
|
|
|
2019-08-06 13:40:38 +00:00
|
|
|
if (m_local_address.to_u32() == 0)
|
2019-08-28 11:58:01 +00:00
|
|
|
m_local_address = routing_decision.adapter->ipv4_address();
|
2019-08-06 13:40:38 +00:00
|
|
|
|
2019-05-04 14:40:34 +00:00
|
|
|
int rc = allocate_local_port_if_needed();
|
2019-03-18 03:03:44 +00:00
|
|
|
if (rc < 0)
|
|
|
|
return rc;
|
2019-03-12 14:51:42 +00:00
|
|
|
|
2021-01-23 22:29:11 +00:00
|
|
|
#if IPV4_SOCKET_DEBUG
|
2020-03-01 19:45:39 +00:00
|
|
|
klog() << "sendto: destination=" << m_peer_address.to_string().characters() << ":" << m_peer_port;
|
2019-09-08 09:13:50 +00:00
|
|
|
#endif
|
2019-03-12 14:51:42 +00:00
|
|
|
|
2019-03-13 14:40:30 +00:00
|
|
|
if (type() == SOCK_RAW) {
|
2021-01-31 11:13:16 +00:00
|
|
|
auto result = routing_decision.adapter->send_ipv4(routing_decision.next_hop, m_peer_address, (IPv4Protocol)protocol(), data, data_length, m_ttl);
|
|
|
|
if (result.is_error())
|
|
|
|
return result;
|
2019-03-13 14:40:30 +00:00
|
|
|
return data_length;
|
|
|
|
}
|
|
|
|
|
2020-08-04 16:02:23 +00:00
|
|
|
auto nsent_or_error = protocol_send(data, data_length);
|
|
|
|
if (!nsent_or_error.is_error())
|
|
|
|
Thread::current()->did_ipv4_socket_write(nsent_or_error.value());
|
|
|
|
return nsent_or_error;
|
2019-03-12 14:51:42 +00:00
|
|
|
}
|
2019-03-12 16:27:07 +00:00
|
|
|
|
2020-09-12 03:11:07 +00:00
|
|
|
KResultOr<size_t> IPv4Socket::receive_byte_buffered(FileDescription& description, UserOrKernelBuffer& buffer, size_t buffer_length, int, Userspace<sockaddr*>, Userspace<socklen_t*>)
|
2019-03-12 16:27:07 +00:00
|
|
|
{
|
2020-03-07 10:26:17 +00:00
|
|
|
Locker locker(lock());
|
2020-02-08 12:09:37 +00:00
|
|
|
if (m_receive_buffer.is_empty()) {
|
|
|
|
if (protocol_is_disconnected())
|
|
|
|
return 0;
|
|
|
|
if (!description.is_blocking())
|
2021-01-20 22:11:17 +00:00
|
|
|
return EAGAIN;
|
2019-12-14 08:43:31 +00:00
|
|
|
|
2020-03-07 10:26:17 +00:00
|
|
|
locker.unlock();
|
2020-11-29 23:05:27 +00:00
|
|
|
auto unblocked_flags = Thread::FileDescriptionBlocker::BlockFlags::None;
|
2021-01-10 23:29:28 +00:00
|
|
|
auto res = Thread::current()->block<Thread::ReadBlocker>({}, description, unblocked_flags);
|
2020-03-07 10:26:17 +00:00
|
|
|
locker.lock();
|
2019-12-14 08:43:31 +00:00
|
|
|
|
2020-11-29 23:05:27 +00:00
|
|
|
if (!((u32)unblocked_flags & (u32)Thread::FileDescriptionBlocker::BlockFlags::Read)) {
|
2020-07-06 23:10:52 +00:00
|
|
|
if (res.was_interrupted())
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINTR;
|
2019-12-14 08:43:31 +00:00
|
|
|
|
2020-02-08 12:09:37 +00:00
|
|
|
// Unblocked due to timeout.
|
2021-01-20 22:11:17 +00:00
|
|
|
return EAGAIN;
|
2019-12-14 08:43:31 +00:00
|
|
|
}
|
2020-02-08 12:09:37 +00:00
|
|
|
}
|
2019-12-14 08:43:31 +00:00
|
|
|
|
2021-02-23 19:42:32 +00:00
|
|
|
VERIFY(!m_receive_buffer.is_empty());
|
2020-09-12 03:11:07 +00:00
|
|
|
int nreceived = m_receive_buffer.read(buffer, buffer_length);
|
2020-02-08 12:09:37 +00:00
|
|
|
if (nreceived > 0)
|
2020-06-28 21:34:31 +00:00
|
|
|
Thread::current()->did_ipv4_socket_read((size_t)nreceived);
|
2019-12-14 08:43:31 +00:00
|
|
|
|
2020-11-29 23:05:27 +00:00
|
|
|
set_can_read(!m_receive_buffer.is_empty());
|
2020-02-08 12:09:37 +00:00
|
|
|
return nreceived;
|
|
|
|
}
|
2019-12-14 08:43:31 +00:00
|
|
|
|
2021-02-28 01:48:45 +00:00
|
|
|
KResultOr<size_t> IPv4Socket::receive_packet_buffered(FileDescription& description, UserOrKernelBuffer& buffer, size_t buffer_length, int flags, Userspace<sockaddr*> addr, Userspace<socklen_t*> addr_length, Time& packet_timestamp)
|
2020-02-08 12:09:37 +00:00
|
|
|
{
|
2020-03-07 10:26:17 +00:00
|
|
|
Locker locker(lock());
|
2019-05-04 14:40:34 +00:00
|
|
|
ReceivedPacket packet;
|
2019-03-12 16:27:07 +00:00
|
|
|
{
|
2019-11-18 16:30:45 +00:00
|
|
|
if (m_receive_queue.is_empty()) {
|
|
|
|
// FIXME: Shouldn't this return -ENOTCONN instead of EOF?
|
|
|
|
// But if so, we still need to deliver at least one EOF read to userspace.. right?
|
|
|
|
if (protocol_is_disconnected())
|
|
|
|
return 0;
|
|
|
|
if (!description.is_blocking())
|
2021-01-20 22:11:17 +00:00
|
|
|
return EAGAIN;
|
2019-11-18 16:30:45 +00:00
|
|
|
}
|
2019-11-04 12:41:36 +00:00
|
|
|
|
2019-03-12 16:27:07 +00:00
|
|
|
if (!m_receive_queue.is_empty()) {
|
2019-05-04 14:40:34 +00:00
|
|
|
packet = m_receive_queue.take_first();
|
2020-11-29 23:05:27 +00:00
|
|
|
set_can_read(!m_receive_queue.is_empty());
|
2021-01-13 23:21:21 +00:00
|
|
|
|
2021-02-07 12:03:24 +00:00
|
|
|
dbgln_if(IPV4_SOCKET_DEBUG, "IPv4Socket({}): recvfrom without blocking {} bytes, packets in queue: {}",
|
2021-01-13 23:21:21 +00:00
|
|
|
this,
|
|
|
|
packet.data.value().size(),
|
|
|
|
m_receive_queue.size());
|
2019-03-12 16:27:07 +00:00
|
|
|
}
|
|
|
|
}
|
2019-08-05 09:06:21 +00:00
|
|
|
if (!packet.data.has_value()) {
|
2019-03-14 14:23:32 +00:00
|
|
|
if (protocol_is_disconnected()) {
|
2021-01-10 14:17:54 +00:00
|
|
|
dbgln("IPv4Socket({}) is protocol-disconnected, returning 0 in recvfrom!", this);
|
2019-03-14 14:23:32 +00:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2020-03-07 10:26:17 +00:00
|
|
|
locker.unlock();
|
2020-11-29 23:05:27 +00:00
|
|
|
auto unblocked_flags = Thread::FileDescriptionBlocker::BlockFlags::None;
|
2021-01-10 23:29:28 +00:00
|
|
|
auto res = Thread::current()->block<Thread::ReadBlocker>({}, description, unblocked_flags);
|
2020-03-07 10:26:17 +00:00
|
|
|
locker.lock();
|
2019-03-12 16:27:07 +00:00
|
|
|
|
2020-11-29 23:05:27 +00:00
|
|
|
if (!((u32)unblocked_flags & (u32)Thread::FileDescriptionBlocker::BlockFlags::Read)) {
|
2020-07-06 23:10:52 +00:00
|
|
|
if (res.was_interrupted())
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINTR;
|
2019-07-20 09:05:52 +00:00
|
|
|
|
2019-03-13 12:13:23 +00:00
|
|
|
// Unblocked due to timeout.
|
2021-01-20 22:11:17 +00:00
|
|
|
return EAGAIN;
|
2019-03-13 12:13:23 +00:00
|
|
|
}
|
2021-02-23 19:42:32 +00:00
|
|
|
VERIFY(m_can_read);
|
|
|
|
VERIFY(!m_receive_queue.is_empty());
|
2019-05-04 14:40:34 +00:00
|
|
|
packet = m_receive_queue.take_first();
|
2020-11-29 23:05:27 +00:00
|
|
|
set_can_read(!m_receive_queue.is_empty());
|
2021-01-13 23:21:21 +00:00
|
|
|
|
2021-02-07 12:03:24 +00:00
|
|
|
dbgln_if(IPV4_SOCKET_DEBUG, "IPv4Socket({}): recvfrom with blocking {} bytes, packets in queue: {}",
|
2021-01-13 23:21:21 +00:00
|
|
|
this,
|
|
|
|
packet.data.value().size(),
|
|
|
|
m_receive_queue.size());
|
2019-03-12 16:27:07 +00:00
|
|
|
}
|
2021-02-23 19:42:32 +00:00
|
|
|
VERIFY(packet.data.has_value());
|
2019-03-13 13:22:27 +00:00
|
|
|
|
2020-09-16 16:25:06 +00:00
|
|
|
packet_timestamp = packet.timestamp;
|
|
|
|
|
2019-03-13 22:14:30 +00:00
|
|
|
if (addr) {
|
2021-02-07 12:03:24 +00:00
|
|
|
dbgln_if(IPV4_SOCKET_DEBUG, "Incoming packet is from: {}:{}", packet.peer_address, packet.peer_port);
|
2020-08-18 07:25:23 +00:00
|
|
|
|
|
|
|
sockaddr_in out_addr {};
|
|
|
|
memcpy(&out_addr.sin_addr, &packet.peer_address, sizeof(IPv4Address));
|
|
|
|
out_addr.sin_port = htons(packet.peer_port);
|
|
|
|
out_addr.sin_family = AF_INET;
|
|
|
|
Userspace<sockaddr_in*> dest_addr = addr.ptr();
|
2020-09-12 03:11:07 +00:00
|
|
|
if (!copy_to_user(dest_addr, &out_addr))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2020-08-18 07:25:23 +00:00
|
|
|
|
|
|
|
socklen_t out_length = sizeof(sockaddr_in);
|
2021-02-23 19:42:32 +00:00
|
|
|
VERIFY(addr_length);
|
2020-09-12 03:11:07 +00:00
|
|
|
if (!copy_to_user(addr_length, &out_length))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2019-03-13 22:14:30 +00:00
|
|
|
}
|
2019-03-13 13:47:21 +00:00
|
|
|
|
2019-03-13 13:22:27 +00:00
|
|
|
if (type() == SOCK_RAW) {
|
2020-10-31 10:32:33 +00:00
|
|
|
size_t bytes_written = min(packet.data.value().size(), buffer_length);
|
|
|
|
if (!buffer.write(packet.data.value().data(), bytes_written))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2020-09-10 04:12:50 +00:00
|
|
|
return bytes_written;
|
2019-03-13 13:22:27 +00:00
|
|
|
}
|
|
|
|
|
2020-12-18 15:13:23 +00:00
|
|
|
return protocol_receive(ReadonlyBytes { packet.data.value().data(), packet.data.value().size() }, buffer, buffer_length, flags);
|
2020-02-08 12:09:37 +00:00
|
|
|
}
|
|
|
|
|
2021-02-28 01:48:45 +00:00
|
|
|
KResultOr<size_t> IPv4Socket::recvfrom(FileDescription& description, UserOrKernelBuffer& buffer, size_t buffer_length, int flags, Userspace<sockaddr*> user_addr, Userspace<socklen_t*> user_addr_length, Time& packet_timestamp)
|
2020-02-08 12:09:37 +00:00
|
|
|
{
|
2020-08-18 07:25:23 +00:00
|
|
|
if (user_addr_length) {
|
|
|
|
socklen_t addr_length;
|
2020-09-12 03:11:07 +00:00
|
|
|
if (!copy_from_user(&addr_length, user_addr_length.unsafe_userspace_ptr()))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2020-08-18 07:25:23 +00:00
|
|
|
if (addr_length < sizeof(sockaddr_in))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINVAL;
|
2020-08-18 07:25:23 +00:00
|
|
|
}
|
2020-02-08 12:09:37 +00:00
|
|
|
|
2021-01-23 22:29:11 +00:00
|
|
|
#if IPV4_SOCKET_DEBUG
|
2020-03-01 19:45:39 +00:00
|
|
|
klog() << "recvfrom: type=" << type() << ", local_port=" << local_port();
|
2020-02-08 12:09:37 +00:00
|
|
|
#endif
|
|
|
|
|
2020-08-04 16:02:23 +00:00
|
|
|
KResultOr<size_t> nreceived = 0;
|
2020-02-08 12:09:37 +00:00
|
|
|
if (buffer_mode() == BufferMode::Bytes)
|
2020-08-18 07:25:23 +00:00
|
|
|
nreceived = receive_byte_buffered(description, buffer, buffer_length, flags, user_addr, user_addr_length);
|
2020-02-08 12:09:37 +00:00
|
|
|
else
|
2020-09-16 16:25:06 +00:00
|
|
|
nreceived = receive_packet_buffered(description, buffer, buffer_length, flags, user_addr, user_addr_length, packet_timestamp);
|
2020-02-08 12:09:37 +00:00
|
|
|
|
2020-08-04 16:02:23 +00:00
|
|
|
if (!nreceived.is_error())
|
|
|
|
Thread::current()->did_ipv4_socket_read(nreceived.value());
|
2019-12-01 16:36:06 +00:00
|
|
|
return nreceived;
|
2019-03-12 16:27:07 +00:00
|
|
|
}
|
|
|
|
|
2021-02-28 01:48:45 +00:00
|
|
|
bool IPv4Socket::did_receive(const IPv4Address& source_address, u16 source_port, KBuffer&& packet, const Time& packet_timestamp)
|
2019-03-12 16:27:07 +00:00
|
|
|
{
|
2019-03-13 23:20:44 +00:00
|
|
|
LOCKER(lock());
|
2020-02-07 23:58:11 +00:00
|
|
|
|
|
|
|
if (is_shut_down_for_reading())
|
|
|
|
return false;
|
|
|
|
|
2019-08-05 09:06:21 +00:00
|
|
|
auto packet_size = packet.size();
|
2019-12-14 08:43:31 +00:00
|
|
|
|
|
|
|
if (buffer_mode() == BufferMode::Bytes) {
|
2020-01-20 15:08:49 +00:00
|
|
|
size_t space_in_receive_buffer = m_receive_buffer.space_for_writing();
|
2019-12-14 08:43:31 +00:00
|
|
|
if (packet_size > space_in_receive_buffer) {
|
2021-01-10 14:17:54 +00:00
|
|
|
dbgln("IPv4Socket({}): did_receive refusing packet since buffer is full.", this);
|
2021-02-23 19:42:32 +00:00
|
|
|
VERIFY(m_can_read);
|
2019-12-14 08:43:31 +00:00
|
|
|
return false;
|
|
|
|
}
|
2020-09-12 03:11:07 +00:00
|
|
|
auto scratch_buffer = UserOrKernelBuffer::for_kernel_buffer(m_scratch_buffer.value().data());
|
2020-12-18 15:13:23 +00:00
|
|
|
auto nreceived_or_error = protocol_receive(ReadonlyBytes { packet.data(), packet.size() }, scratch_buffer, m_scratch_buffer.value().size(), 0);
|
2020-08-04 16:02:23 +00:00
|
|
|
if (nreceived_or_error.is_error())
|
|
|
|
return false;
|
2020-09-12 03:11:07 +00:00
|
|
|
ssize_t nwritten = m_receive_buffer.write(scratch_buffer, nreceived_or_error.value());
|
|
|
|
if (nwritten < 0)
|
|
|
|
return false;
|
2020-11-29 23:05:27 +00:00
|
|
|
set_can_read(!m_receive_buffer.is_empty());
|
2019-12-14 08:43:31 +00:00
|
|
|
} else {
|
2020-08-05 04:35:30 +00:00
|
|
|
if (m_receive_queue.size() > 2000) {
|
2021-01-10 14:17:54 +00:00
|
|
|
dbgln("IPv4Socket({}): did_receive refusing packet since queue is full.", this);
|
2019-12-14 08:43:31 +00:00
|
|
|
return false;
|
|
|
|
}
|
2020-09-16 16:25:06 +00:00
|
|
|
m_receive_queue.append({ source_address, source_port, packet_timestamp, move(packet) });
|
2020-11-29 23:05:27 +00:00
|
|
|
set_can_read(true);
|
2019-12-14 08:43:31 +00:00
|
|
|
}
|
2019-03-14 14:28:23 +00:00
|
|
|
m_bytes_received += packet_size;
|
2021-01-13 23:21:21 +00:00
|
|
|
|
2021-01-23 22:59:27 +00:00
|
|
|
if constexpr (IPV4_SOCKET_DEBUG) {
|
2021-01-13 23:21:21 +00:00
|
|
|
if (buffer_mode() == BufferMode::Bytes)
|
|
|
|
dbgln("IPv4Socket({}): did_receive {} bytes, total_received={}", this, packet_size, m_bytes_received);
|
|
|
|
else
|
|
|
|
dbgln("IPv4Socket({}): did_receive {} bytes, total_received={}, packets in queue: {}",
|
|
|
|
this,
|
|
|
|
packet_size,
|
|
|
|
m_bytes_received,
|
|
|
|
m_receive_queue.size());
|
|
|
|
}
|
|
|
|
|
2019-11-04 13:03:14 +00:00
|
|
|
return true;
|
2019-03-12 16:27:07 +00:00
|
|
|
}
|
2019-08-10 16:10:36 +00:00
|
|
|
|
|
|
|
String IPv4Socket::absolute_path(const FileDescription&) const
|
|
|
|
{
|
|
|
|
if (m_role == Role::None)
|
|
|
|
return "socket";
|
|
|
|
|
|
|
|
StringBuilder builder;
|
|
|
|
builder.append("socket:");
|
|
|
|
|
2021-02-09 15:08:43 +00:00
|
|
|
builder.appendff("{}:{}", m_local_address.to_string(), m_local_port);
|
2019-08-10 16:10:36 +00:00
|
|
|
if (m_role == Role::Accepted || m_role == Role::Connected)
|
2021-02-09 15:08:43 +00:00
|
|
|
builder.appendff(" / {}:{}", m_peer_address.to_string(), m_peer_port);
|
2019-08-10 16:10:36 +00:00
|
|
|
|
|
|
|
switch (m_role) {
|
|
|
|
case Role::Listener:
|
|
|
|
builder.append(" (listening)");
|
|
|
|
break;
|
|
|
|
case Role::Accepted:
|
|
|
|
builder.append(" (accepted)");
|
|
|
|
break;
|
|
|
|
case Role::Connected:
|
|
|
|
builder.append(" (connected)");
|
|
|
|
break;
|
|
|
|
case Role::Connecting:
|
|
|
|
builder.append(" (connecting)");
|
|
|
|
break;
|
|
|
|
default:
|
2021-02-23 19:42:32 +00:00
|
|
|
VERIFY_NOT_REACHED();
|
2019-08-10 16:10:36 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return builder.to_string();
|
|
|
|
}
|
2019-09-19 19:40:06 +00:00
|
|
|
|
2020-08-07 07:18:20 +00:00
|
|
|
KResult IPv4Socket::setsockopt(int level, int option, Userspace<const void*> user_value, socklen_t user_value_size)
|
2019-09-19 19:40:06 +00:00
|
|
|
{
|
|
|
|
if (level != IPPROTO_IP)
|
2020-07-30 22:26:33 +00:00
|
|
|
return Socket::setsockopt(level, option, user_value, user_value_size);
|
2019-09-19 19:40:06 +00:00
|
|
|
|
|
|
|
switch (option) {
|
2020-07-30 22:26:33 +00:00
|
|
|
case IP_TTL: {
|
|
|
|
if (user_value_size < sizeof(int))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINVAL;
|
2020-07-30 22:26:33 +00:00
|
|
|
int value;
|
2020-09-12 03:11:07 +00:00
|
|
|
if (!copy_from_user(&value, static_ptr_cast<const int*>(user_value)))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2020-07-30 22:26:33 +00:00
|
|
|
if (value < 0 || value > 255)
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINVAL;
|
2020-07-30 22:26:33 +00:00
|
|
|
m_ttl = value;
|
2019-09-19 19:40:06 +00:00
|
|
|
return KSuccess;
|
2020-07-30 22:26:33 +00:00
|
|
|
}
|
2019-09-19 19:40:06 +00:00
|
|
|
default:
|
2021-01-20 22:11:17 +00:00
|
|
|
return ENOPROTOOPT;
|
2019-09-19 19:40:06 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-08-07 09:29:05 +00:00
|
|
|
KResult IPv4Socket::getsockopt(FileDescription& description, int level, int option, Userspace<void*> value, Userspace<socklen_t*> value_size)
|
2019-09-19 19:40:06 +00:00
|
|
|
{
|
|
|
|
if (level != IPPROTO_IP)
|
2019-12-06 17:38:36 +00:00
|
|
|
return Socket::getsockopt(description, level, option, value, value_size);
|
2019-09-19 19:40:06 +00:00
|
|
|
|
2020-08-07 09:29:05 +00:00
|
|
|
socklen_t size;
|
2020-09-12 03:11:07 +00:00
|
|
|
if (!copy_from_user(&size, value_size.unsafe_userspace_ptr()))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2020-08-07 09:29:05 +00:00
|
|
|
|
2019-09-19 19:40:06 +00:00
|
|
|
switch (option) {
|
|
|
|
case IP_TTL:
|
2020-08-07 09:29:05 +00:00
|
|
|
if (size < sizeof(int))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EINVAL;
|
2020-09-12 03:11:07 +00:00
|
|
|
if (!copy_to_user(static_ptr_cast<int*>(value), (int*)&m_ttl))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2020-08-07 09:29:05 +00:00
|
|
|
size = sizeof(int);
|
2020-09-12 03:11:07 +00:00
|
|
|
if (!copy_to_user(value_size, &size))
|
2021-01-20 22:11:17 +00:00
|
|
|
return EFAULT;
|
2019-09-19 19:40:06 +00:00
|
|
|
return KSuccess;
|
|
|
|
default:
|
2021-01-20 22:11:17 +00:00
|
|
|
return ENOPROTOOPT;
|
2019-09-19 19:40:06 +00:00
|
|
|
}
|
|
|
|
}
|
2019-09-23 17:06:03 +00:00
|
|
|
|
2020-05-23 11:17:58 +00:00
|
|
|
int IPv4Socket::ioctl(FileDescription&, unsigned request, FlatPtr arg)
|
2019-09-23 17:06:03 +00:00
|
|
|
{
|
2020-01-12 12:28:07 +00:00
|
|
|
REQUIRE_PROMISE(inet);
|
2019-09-23 17:06:03 +00:00
|
|
|
|
2020-03-14 19:00:49 +00:00
|
|
|
auto ioctl_route = [request, arg]() {
|
2020-09-12 03:11:07 +00:00
|
|
|
rtentry route;
|
|
|
|
if (!copy_from_user(&route, (rtentry*)arg))
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EFAULT;
|
2019-09-23 17:06:03 +00:00
|
|
|
|
2020-09-12 03:11:07 +00:00
|
|
|
auto copied_ifname = copy_string_from_user(route.rt_dev, IFNAMSIZ);
|
|
|
|
if (copied_ifname.is_null())
|
|
|
|
return -EFAULT;
|
2020-03-14 19:00:49 +00:00
|
|
|
|
2020-09-12 03:11:07 +00:00
|
|
|
auto adapter = NetworkAdapter::lookup_by_name(copied_ifname);
|
2020-03-14 19:00:49 +00:00
|
|
|
if (!adapter)
|
|
|
|
return -ENODEV;
|
|
|
|
|
|
|
|
switch (request) {
|
|
|
|
case SIOCADDRT:
|
2020-06-28 21:34:31 +00:00
|
|
|
if (!Process::current()->is_superuser())
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EPERM;
|
2020-09-12 03:11:07 +00:00
|
|
|
if (route.rt_gateway.sa_family != AF_INET)
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EAFNOSUPPORT;
|
2020-09-12 03:11:07 +00:00
|
|
|
if ((route.rt_flags & (RTF_UP | RTF_GATEWAY)) != (RTF_UP | RTF_GATEWAY))
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EINVAL; // FIXME: Find the correct value to return
|
2020-09-12 03:11:07 +00:00
|
|
|
adapter->set_ipv4_gateway(IPv4Address(((sockaddr_in&)route.rt_gateway).sin_addr.s_addr));
|
2020-03-14 19:00:49 +00:00
|
|
|
return 0;
|
2019-09-23 17:06:03 +00:00
|
|
|
|
2020-03-14 19:00:49 +00:00
|
|
|
case SIOCDELRT:
|
|
|
|
// FIXME: Support gateway deletion
|
|
|
|
return 0;
|
|
|
|
}
|
2020-03-11 20:30:41 +00:00
|
|
|
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EINVAL;
|
|
|
|
};
|
2019-10-02 16:20:11 +00:00
|
|
|
|
2020-03-14 19:00:49 +00:00
|
|
|
auto ioctl_interface = [request, arg]() {
|
2020-09-12 03:11:07 +00:00
|
|
|
ifreq* user_ifr = (ifreq*)arg;
|
|
|
|
ifreq ifr;
|
|
|
|
if (!copy_from_user(&ifr, user_ifr))
|
2019-10-02 16:20:11 +00:00
|
|
|
return -EFAULT;
|
2020-03-14 19:00:49 +00:00
|
|
|
|
|
|
|
char namebuf[IFNAMSIZ + 1];
|
2020-09-12 03:11:07 +00:00
|
|
|
memcpy(namebuf, ifr.ifr_name, IFNAMSIZ);
|
2020-03-14 19:00:49 +00:00
|
|
|
namebuf[sizeof(namebuf) - 1] = '\0';
|
|
|
|
|
|
|
|
auto adapter = NetworkAdapter::lookup_by_name(namebuf);
|
|
|
|
if (!adapter)
|
|
|
|
return -ENODEV;
|
|
|
|
|
|
|
|
switch (request) {
|
|
|
|
case SIOCSIFADDR:
|
2020-06-28 21:34:31 +00:00
|
|
|
if (!Process::current()->is_superuser())
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EPERM;
|
2020-09-12 03:11:07 +00:00
|
|
|
if (ifr.ifr_addr.sa_family != AF_INET)
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EAFNOSUPPORT;
|
2020-09-12 03:11:07 +00:00
|
|
|
adapter->set_ipv4_address(IPv4Address(((sockaddr_in&)ifr.ifr_addr).sin_addr.s_addr));
|
2020-03-14 19:00:49 +00:00
|
|
|
return 0;
|
|
|
|
|
|
|
|
case SIOCSIFNETMASK:
|
2020-06-28 21:34:31 +00:00
|
|
|
if (!Process::current()->is_superuser())
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EPERM;
|
2020-09-12 03:11:07 +00:00
|
|
|
if (ifr.ifr_addr.sa_family != AF_INET)
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EAFNOSUPPORT;
|
2020-09-12 03:11:07 +00:00
|
|
|
adapter->set_ipv4_netmask(IPv4Address(((sockaddr_in&)ifr.ifr_netmask).sin_addr.s_addr));
|
2020-03-14 19:00:49 +00:00
|
|
|
return 0;
|
|
|
|
|
2020-09-12 03:11:07 +00:00
|
|
|
case SIOCGIFADDR: {
|
|
|
|
u16 sa_family = AF_INET;
|
|
|
|
if (!copy_to_user(&user_ifr->ifr_addr.sa_family, &sa_family))
|
|
|
|
return -EFAULT;
|
|
|
|
auto ip4_addr = adapter->ipv4_address().to_u32();
|
|
|
|
if (!copy_to_user(&((sockaddr_in&)user_ifr->ifr_addr).sin_addr.s_addr, &ip4_addr, sizeof(ip4_addr)))
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EFAULT;
|
|
|
|
return 0;
|
2020-09-12 03:11:07 +00:00
|
|
|
}
|
2020-03-14 19:00:49 +00:00
|
|
|
|
2020-09-12 03:11:07 +00:00
|
|
|
case SIOCGIFHWADDR: {
|
|
|
|
u16 sa_family = AF_INET;
|
|
|
|
if (!copy_to_user(&user_ifr->ifr_hwaddr.sa_family, &sa_family))
|
|
|
|
return -EFAULT;
|
|
|
|
auto mac_address = adapter->mac_address();
|
|
|
|
if (!copy_to_user(ifr.ifr_hwaddr.sa_data, &mac_address, sizeof(MACAddress)))
|
2020-03-14 19:00:49 +00:00
|
|
|
return -EFAULT;
|
|
|
|
return 0;
|
2019-10-02 16:20:11 +00:00
|
|
|
}
|
2020-09-12 03:11:07 +00:00
|
|
|
}
|
2020-03-14 19:00:49 +00:00
|
|
|
|
|
|
|
return -EINVAL;
|
|
|
|
};
|
|
|
|
|
|
|
|
switch (request) {
|
|
|
|
case SIOCSIFADDR:
|
|
|
|
case SIOCSIFNETMASK:
|
|
|
|
case SIOCGIFADDR:
|
|
|
|
case SIOCGIFHWADDR:
|
|
|
|
return ioctl_interface();
|
|
|
|
|
|
|
|
case SIOCADDRT:
|
|
|
|
case SIOCDELRT:
|
|
|
|
return ioctl_route();
|
2019-09-23 17:06:03 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return -EINVAL;
|
|
|
|
}
|
2020-02-08 14:52:32 +00:00
|
|
|
|
2020-06-02 16:20:05 +00:00
|
|
|
KResult IPv4Socket::close()
|
2020-02-08 14:52:32 +00:00
|
|
|
{
|
2020-12-20 23:09:48 +00:00
|
|
|
[[maybe_unused]] auto rc = shutdown(SHUT_RDWR);
|
2020-06-02 16:20:05 +00:00
|
|
|
return KSuccess;
|
2020-02-08 14:52:32 +00:00
|
|
|
}
|
2020-02-08 14:59:21 +00:00
|
|
|
|
|
|
|
void IPv4Socket::shut_down_for_reading()
|
|
|
|
{
|
|
|
|
Socket::shut_down_for_reading();
|
2020-11-29 23:05:27 +00:00
|
|
|
set_can_read(true);
|
|
|
|
}
|
|
|
|
|
|
|
|
void IPv4Socket::set_can_read(bool value)
|
|
|
|
{
|
|
|
|
m_can_read = value;
|
|
|
|
if (value)
|
|
|
|
evaluate_block_conditions();
|
2020-02-08 14:59:21 +00:00
|
|
|
}
|
2020-02-16 00:27:42 +00:00
|
|
|
|
|
|
|
}
|