RGBCube/serenity
1
Fork 0
mirror of https://github.com/RGBCube/serenity synced 2025-05-14 08:54:58 +00:00
Code Issues Activity Actions

nc: Convert to Core::Stream::UDPSocket

Browse source
This commit is contained in:
sin-ack 2022-02-06 17:14:48 +00:00 • committed by Andreas Kling
parent 4ca0669d1e
commit 11a2e31306
1 changed files with 5 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

14
Userland/Utilities/nc.cpp
View file

@ -7,8 +7,8 @@
#include <AK/ByteBuffer.h>
#include <LibCore/ArgsParser.h>
#include <LibCore/EventLoop.h>
#include <LibCore/Stream.h>
#include <LibCore/System.h>
#include <LibCore/UDPSocket.h>
#include <LibMain/Main.h>
#include <arpa/inet.h>
#include <errno.h>
@ -54,14 +54,10 @@ ErrorOr<int> serenity_main(Main::Arguments arguments)
}
Core::EventLoop loop;
auto socket = TRY(Core::UDPSocket::try_create());
auto socket = TRY(Core::Stream::UDPSocket::connect(target, port));
socket->on_connected = [&]() {
if (verbose)
warnln("connected to {}:{}", target, port);
};
socket->connect(target, port);
if (verbose)
warnln("connected to {}:{}", target, port);
Array<u8, 1024> buffer;
for (;;) {
@ -69,7 +65,7 @@ ErrorOr<int> serenity_main(Main::Arguments arguments)
auto nread = TRY(Core::System::read(STDIN_FILENO, buffer_span));
buffer_span = buffer_span.trim(nread);
socket->send({ buffer_span.data(), static_cast<size_t>(nread) });
TRY(socket->write({ buffer_span.data(), static_cast<size_t>(nread) }));
}
}