diff options
author | Haavard <havardpe@yahoo-inc.com> | 2017-04-21 14:33:12 +0000 |
---|---|---|
committer | Haavard <havardpe@yahoo-inc.com> | 2017-04-21 21:04:33 +0000 |
commit | bbf11af22fff91b6f8f757a252ee4255bd018166 (patch) | |
tree | 7f8306230bfc0d37a7baa91589705c0cdd571a0c /vespalib/src/tests/net/socket/socket_server.cpp | |
parent | 33390132c1249768e445d8272bbfe421c6d2a5fc (diff) |
let socket handle handle more socket stuff
very simple Socket/SimpleSocket
stop using fastos sockets in websocket experimental code
stop using fastos sockets in vbench
Diffstat (limited to 'vespalib/src/tests/net/socket/socket_server.cpp')
-rw-r--r-- | vespalib/src/tests/net/socket/socket_server.cpp | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/vespalib/src/tests/net/socket/socket_server.cpp b/vespalib/src/tests/net/socket/socket_server.cpp index ff8d77f317d..c14c69caa70 100644 --- a/vespalib/src/tests/net/socket/socket_server.cpp +++ b/vespalib/src/tests/net/socket/socket_server.cpp @@ -12,7 +12,7 @@ using namespace vespalib; -vespalib::string read_msg(Socket &socket) { +vespalib::string read_msg(SocketHandle &socket) { vespalib::string msg; for (;;) { char c; @@ -28,7 +28,7 @@ vespalib::string read_msg(Socket &socket) { } } -void write_msg(Socket &socket, const vespalib::string &msg) { +void write_msg(SocketHandle &socket, const vespalib::string &msg) { for (size_t i = 0; i < msg.size(); ++i) { ssize_t ret = socket.write(&msg[i], 1); if (ret != 1) { @@ -39,8 +39,8 @@ void write_msg(Socket &socket, const vespalib::string &msg) { } int main(int, char **) { - ServerSocket::UP server = ServerSocket::listen(SocketSpec::from_port(0)); - if (!server->valid()) { + ServerSocket server(0); + if (!server.valid()) { fprintf(stderr, "listen failed, exiting\n"); return 1; } @@ -52,18 +52,19 @@ int main(int, char **) { fprintf(stderr, " %s\n", addr.spec().c_str()); } } - fprintf(stderr, "listening to %s\n", server->address().spec().c_str()); + fprintf(stderr, "listening to %s\n", server.address().spec().c_str()); fprintf(stderr, "client command: ./vespalib_socket_client_app %s %d\n", - HostName::get().c_str(), server->address().port()); + HostName::get().c_str(), server.address().port()); fprintf(stderr, "use ^C (SIGINT) to exit\n"); SignalHandler::INT.hook(); while (!SignalHandler::INT.check()) { - Socket::UP socket = server->accept(); - if (socket->valid()) { + SocketHandle socket = server.accept(); + if (socket.valid()) { fprintf(stderr, "got connection from: %s (local address: %s)\n", - socket->peer_address().spec().c_str(), socket->address().spec().c_str()); - fprintf(stderr, "message from client: '%s'\n", read_msg(*socket).c_str()); - write_msg(*socket, "hello from server\n"); + SocketAddress::peer_address(socket.get()).spec().c_str(), + SocketAddress::address_of(socket.get()).spec().c_str()); + fprintf(stderr, "message from client: '%s'\n", read_msg(socket).c_str()); + write_msg(socket, "hello from server\n"); } else { fprintf(stderr, "(got invalid socket from accept)\n"); } |