aboutsummaryrefslogtreecommitdiffstats
path: root/vespalib/src/tests/net/socket/socket_server.cpp
diff options
context:
space:
mode:
authorHaavard <havardpe@yahoo-inc.com>2017-04-21 14:33:12 +0000
committerHaavard <havardpe@yahoo-inc.com>2017-04-21 21:04:33 +0000
commitbbf11af22fff91b6f8f757a252ee4255bd018166 (patch)
tree7f8306230bfc0d37a7baa91589705c0cdd571a0c /vespalib/src/tests/net/socket/socket_server.cpp
parent33390132c1249768e445d8272bbfe421c6d2a5fc (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.cpp23
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");
}