serenity/Kernel/Net/LocalSocket.h

#pragma once

#include <Kernel/Net/Socket.h>
#include <Kernel/DoubleBuffer.h>

class FileDescriptor;

class LocalSocket final : public Socket {
public:
    static Retained<LocalSocket> create(int type);
    virtual ~LocalSocket() override;

    virtual KResult bind(const sockaddr*, socklen_t) override;
    virtual KResult connect(FileDescriptor&, const sockaddr*, socklen_t, ShouldBlock = ShouldBlock::Yes) override;
    virtual bool get_local_address(sockaddr*, socklen_t*) override;
    virtual bool get_peer_address(sockaddr*, socklen_t*) override;
    virtual void attach(FileDescriptor&) override;
    virtual void detach(FileDescriptor&) override;
    virtual bool can_read(FileDescriptor&) const override;
    virtual ssize_t read(FileDescriptor&, byte*, ssize_t) override;
    virtual ssize_t write(FileDescriptor&, const byte*, ssize_t) override;
    virtual bool can_write(FileDescriptor&) const override;
    virtual ssize_t sendto(FileDescriptor&, const void*, size_t, int, const sockaddr*, socklen_t) override;
    virtual ssize_t recvfrom(FileDescriptor&, void*, size_t, int flags, sockaddr*, socklen_t*) override;

private:
    explicit LocalSocket(int type);
    virtual bool is_local() const override { return true; }
    bool has_attached_peer(const FileDescriptor&) const;

    RetainPtr<FileDescriptor> m_file;

    bool m_bound { false };
    int m_accepted_fds_open { 0 };
    int m_connected_fds_open { 0 };
    int m_connecting_fds_open { 0 };
    sockaddr_un m_address;

    DoubleBuffer m_for_client;
    DoubleBuffer m_for_server;
};
Kernel: Begin implementing UNIX domain sockets. 2019-02-14 14:17:38 +01:00			`#pragma once`

Kernel: Move FIFO into FileSystem/ and Socket+LocalSocket into Net/. 2019-04-06 20:29:48 +02:00			`#include <Kernel/Net/Socket.h>`
Kernel: Begin implementing UNIX domain sockets. 2019-02-14 14:17:38 +01:00			`#include <Kernel/DoubleBuffer.h>`

Kernel: More sockets work. Fleshing out accept(). 2019-02-14 15:17:30 +01:00			`class FileDescriptor;`

Kernel: Begin implementing UNIX domain sockets. 2019-02-14 14:17:38 +01:00			`class LocalSocket final : public Socket {`
			`public:`
AK: Add Retained<T>, like RetainPtr, but never null. Also use some Clang attribute wizardry to get a warning for use-after-move. 2019-02-25 12:43:52 +01:00			`static Retained<LocalSocket> create(int type);`
Kernel: Begin implementing UNIX domain sockets. 2019-02-14 14:17:38 +01:00			`virtual ~LocalSocket() override;`

Kernel: Port more code to KResult and KResultOr<T>. 2019-03-06 22:14:31 +01:00			`virtual KResult bind(const sockaddr*, socklen_t) override;`
Kernel: Prepare Socket for becoming a File. Make the Socket functions take a FileDescriptor& rather than a socket role throughout the code. Also change threads to block on a FileDescriptor, rather than either an fd index or a Socket. 2019-05-03 20:15:54 +02:00			`virtual KResult connect(FileDescriptor&, const sockaddr*, socklen_t, ShouldBlock = ShouldBlock::Yes) override;`
Kernel: Add getpeername() syscall, and fix getsockname() behavior. We were copying the raw IPv4 addresses into the wrong part of sockaddr_in, and we didn't set sa_family or sa_port. 2019-05-20 20:33:03 +02:00			`virtual bool get_local_address(sockaddr, socklen_t) override;`
			`virtual bool get_peer_address(sockaddr, socklen_t) override;`
Kernel: Prepare Socket for becoming a File. Make the Socket functions take a FileDescriptor& rather than a socket role throughout the code. Also change threads to block on a FileDescriptor, rather than either an fd index or a Socket. 2019-05-03 20:15:54 +02:00			`virtual void attach(FileDescriptor&) override;`
			`virtual void detach(FileDescriptor&) override;`
			`virtual bool can_read(FileDescriptor&) const override;`
			`virtual ssize_t read(FileDescriptor&, byte*, ssize_t) override;`
			`virtual ssize_t write(FileDescriptor&, const byte*, ssize_t) override;`
			`virtual bool can_write(FileDescriptor&) const override;`
			`virtual ssize_t sendto(FileDescriptor&, const void, size_t, int, const sockaddr, socklen_t) override;`
			`virtual ssize_t recvfrom(FileDescriptor&, void, size_t, int flags, sockaddr, socklen_t*) override;`
Kernel: Actually send things between the socket endpoints. 2019-02-14 16:01:08 +01:00
Kernel: Begin implementing UNIX domain sockets. 2019-02-14 14:17:38 +01:00			`private:`
			`explicit LocalSocket(int type);`
Kernel: More work on sockets. Fleshing out connect(). 2019-02-14 15:55:19 +01:00			`virtual bool is_local() const override { return true; }`
LocalSocket: Fix mismatch between can_write() and write() logic. can_write() was saying yes in situations where write() would overflow the internal buffer. This patch adds a has_attached_peer() helper to make it easier to understand what's going on in these functions. 2019-05-20 02:54:52 +02:00			`bool has_attached_peer(const FileDescriptor&) const;`
Kernel: Begin implementing UNIX domain sockets. 2019-02-14 14:17:38 +01:00
Kernel: More sockets work. Fleshing out accept(). 2019-02-14 15:17:30 +01:00			`RetainPtr<FileDescriptor> m_file;`

			`bool m_bound { false };`
Kernel: Give each FileDescriptor a chance to co-open sockets. Track how many fds are open for a socket's Accepted and Connected roles. This allows fork() to clone a socket fd without a subsequent close() walking all over the parent process's fd. 2019-02-17 11:00:35 +01:00			`int m_accepted_fds_open { 0 };`
			`int m_connected_fds_open { 0 };`
Kernel: Fix race between accept() and connect(). We had a bug where an accepted socket would appear to be EOF/disconnected on the accepting side until the connecting side had called attach_fd(). Fix this by adding a new SocketRole::Connecting state. 2019-03-20 02:33:51 +01:00			`int m_connecting_fds_open { 0 };`
Kernel: More sockets work. Fleshing out accept(). 2019-02-14 15:17:30 +01:00			`sockaddr_un m_address;`

Kernel: Begin implementing UNIX domain sockets. 2019-02-14 14:17:38 +01:00			`DoubleBuffer m_for_client;`
			`DoubleBuffer m_for_server;`
			`};`