LadybirdBrowser/ladybird
1
1
Fork 0
mirror of https://github.com/LadybirdBrowser/ladybird.git synced 2025-01-08 04:15:23 +03:00
Code Issues Packages Projects Releases Wiki Activity

Kernel: Add TCPSocket::try_for_each() for fallible iteration

Browse Source 
This API will allow users to short circuit iteration and properly
propagate errors.
This commit is contained in:
Idan Horowitz 2022-02-24 20:05:24 +02:00 committed by Andreas Kling
parent 24be52b3f5
commit aabc8d348b
Notes: sideshowbarker 2024-07-17 18:10:05 +09:00 
Author: https://github.com/IdanHo
Commit: https://github.com/SerenityOS/serenity/commit/aabc8d348b
Pull-request: https://github.com/SerenityOS/serenity/pull/12754
Reviewed-by: https://github.com/bgianfo ✅
Reviewed-by: https://github.com/elcuco
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
Kernel/Net/TCPSocket.cpp
View File

@ -29,6 +29,15 @@ void TCPSocket::for_each(Function<void(const TCPSocket&)> callback)
}); });
} }
ErrorOr<void> TCPSocket::try_for_each(Function<ErrorOr<void>(const TCPSocket&)> callback)
{
return sockets_by_tuple().with_shared([&](const auto& sockets) -> ErrorOr<void> {
for (auto& it : sockets)
TRY(callback(*it.value));
return {};
});
}
bool TCPSocket::unref() const bool TCPSocket::unref() const
{ {
bool did_hit_zero = sockets_by_tuple().with_exclusive([&](auto& table) { bool did_hit_zero = sockets_by_tuple().with_exclusive([&](auto& table) {

1
Kernel/Net/TCPSocket.h
View File

@ -19,6 +19,7 @@ namespace Kernel {
class TCPSocket final : public IPv4Socket { class TCPSocket final : public IPv4Socket {
public: public:
static void for_each(Function<void(const TCPSocket&)>); static void for_each(Function<void(const TCPSocket&)>);
static ErrorOr<void> try_for_each(Function<ErrorOr<void>(const TCPSocket&)>);
static ErrorOr<NonnullRefPtr<TCPSocket>> try_create(int protocol, NonnullOwnPtr<DoubleBuffer> receive_buffer); static ErrorOr<NonnullRefPtr<TCPSocket>> try_create(int protocol, NonnullOwnPtr<DoubleBuffer> receive_buffer);
virtual ~TCPSocket() override; virtual ~TCPSocket() override;