aboutsummaryrefslogtreecommitdiff
path: root/works/life/computer-network-experiment/server.cpp
diff options
context:
space:
mode:
authorcrupest <crupest@outlook.com>2021-06-07 14:05:51 +0800
committercrupest <crupest@outlook.com>2021-06-07 14:05:51 +0800
commitda6c0e6194578538ce0bcd1b9815696b96153f6b (patch)
treebb4121f622161fad8810890e0e16aac8c1826605 /works/life/computer-network-experiment/server.cpp
parent2de4663d385ab54c5d8b8adc68611ad67636f56f (diff)
downloadcrupest-da6c0e6194578538ce0bcd1b9815696b96153f6b.tar.gz
crupest-da6c0e6194578538ce0bcd1b9815696b96153f6b.tar.bz2
crupest-da6c0e6194578538ce0bcd1b9815696b96153f6b.zip
import(life): ...
Diffstat (limited to 'works/life/computer-network-experiment/server.cpp')
-rw-r--r--works/life/computer-network-experiment/server.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/works/life/computer-network-experiment/server.cpp b/works/life/computer-network-experiment/server.cpp
index a5a7a9b..14987f3 100644
--- a/works/life/computer-network-experiment/server.cpp
+++ b/works/life/computer-network-experiment/server.cpp
@@ -42,22 +42,20 @@ void ResponseThreadProc(int socket, sockaddr_in address) {
// send failed
if (byte_actually_sent == -1) {
SendOutput(OutputType::Error, CRUT("Failed to send!\n"));
- Close(socket);
+ CloseSocket(socket);
break;
}
byte_count_sent += byte_actually_sent;
}
- SendOutput(CRUT("Succeeded to send message to {} !\n"),
+ SendOutput(CRUT("Succeeded to send message to {}!\n"),
ConvertCharString(address_string));
- Close(socket);
+ CloseSocket(socket);
}
int Main() {
- std::thread output_thread(OutputThread);
-
int server_socket;
if ((server_socket = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
@@ -81,6 +79,8 @@ int Main() {
}
while (true) {
+ SendOutput(CRUT("Now start to accept incoming connection.\n"));
+
sockaddr_in client_address;
int client_socket;
unsigned sin_size = sizeof(sockaddr_in);
@@ -92,7 +92,7 @@ int Main() {
(&sin_size));
if (client_socket == -1) {
- PrintErrorMessageAndExit(CRUT("Failed to accecpt"));
+ PrintErrorMessageAndExit(CRUT("Failed to accecpt."));
}
std::thread response_thread(ResponseThreadProc, client_socket,