You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
124 lines
2.5 KiB
124 lines
2.5 KiB
|
|
#include <string.h>
|
|
#include <unistd.h>
|
|
|
|
#include "UDPTCPNetwork.h"
|
|
|
|
#define DEFAULT_PORT 12345
|
|
|
|
|
|
void server () {
|
|
TCP tcpserver;
|
|
TCP *connection;
|
|
int i, timeout;
|
|
pid_t pid;
|
|
char buffer[NET_BUFFERSIZE];
|
|
|
|
//
|
|
// start the server
|
|
if (tcpserver.Listen(DEFAULT_PORT) != 1) {
|
|
printf ("cloud not start the tcp server\n");
|
|
exit (1);
|
|
}
|
|
|
|
//
|
|
// check for connections
|
|
for (timeout = 5; timeout > 0; timeout--) {
|
|
connection = tcpserver.Accept();
|
|
if (connection != NULL) {
|
|
//
|
|
// someone connected - create new process
|
|
// take care of parallel processing (parent is always the server)
|
|
//
|
|
printf (" server: got a connection forking new process\n");
|
|
pid = fork();
|
|
if (pid == 0) {
|
|
//
|
|
// child process - always close server since it will handeled
|
|
// by the parent process. Make sure the client exits and never
|
|
// returns.
|
|
tcpserver.Close();
|
|
i = connection->ReadTimeout(buffer, NET_BUFFERSIZE, 1000);
|
|
if (i > 0) {
|
|
int c;
|
|
|
|
printf (" server: (child) got: '%s'\n", buffer);
|
|
for (c = 0; c < i; c++) buffer[c] = toupper(buffer[c]);
|
|
connection->Write(buffer, i);
|
|
}
|
|
//
|
|
// just delete the class object, it will close the client connection
|
|
delete (connection);
|
|
|
|
//
|
|
// exit child process
|
|
exit (1);
|
|
}
|
|
else {
|
|
//
|
|
// parent process - just close the client connection
|
|
// it will be handeled by the child process.
|
|
delete (connection);
|
|
}
|
|
}
|
|
sleep (1);
|
|
}
|
|
};
|
|
|
|
|
|
void client () {
|
|
TCP tcpclient;
|
|
char buffer[NET_BUFFERSIZE];
|
|
int i;
|
|
|
|
sleep (1); // wait one second to start the server
|
|
|
|
//
|
|
// connect to the server
|
|
if (tcpclient.Connect ("localhost", DEFAULT_PORT) != 1) {
|
|
printf ("cloud not connect to server\n");
|
|
exit (1);
|
|
}
|
|
|
|
//
|
|
// send some data
|
|
snprintf (buffer, NET_BUFFERSIZE, "nur ein kleiner Test.");
|
|
printf ("client:send '%s' to the server.\n", buffer);
|
|
if (tcpclient.Write(buffer, strlen (buffer)) != strlen (buffer)) {
|
|
printf ("could not send all data.\n");
|
|
exit (1);
|
|
}
|
|
|
|
//
|
|
// read some data (wait maximum 10x1000ms)
|
|
for (i = 10; i > 0; i--)
|
|
if (tcpclient.ReadTimeout(buffer, NET_BUFFERSIZE, 1000) > 0) {
|
|
printf ("client:got '%s' from server.\n", buffer);
|
|
break;
|
|
}
|
|
|
|
//
|
|
// close connection
|
|
tcpclient.Close();
|
|
};
|
|
|
|
|
|
|
|
int main (int argc, char **argv) {
|
|
pid_t pid;
|
|
|
|
pid = fork();
|
|
if (pid == 0) { // child process
|
|
client();
|
|
client();
|
|
client();
|
|
client();
|
|
}
|
|
else { // parent process
|
|
server();
|
|
}
|
|
|
|
return 0;
|
|
};
|
|
|