Чат TCP

#include <iostream>
#include <map>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <cstring>
#include <sys/types.h>
#include <sys/wait.h>
#include <arpa/inet.h>
#include <fcntl.h>
 
 
#define PORT 5050
#define LISTENER_LIMIT 5
#define BUFFER_SIZE 2048
 
void send_message_to_client(int client_socket, const std::string& message) {
    send(client_socket, message.c_str(), message.length(), 0);
}
 
 
void handle_client(int client_socket) {
    char buffer[BUFFER_SIZE];
    int bytes_received;
    pid_t pid = getpid();
    
    printf("СЕРВЕР: Процесс %d обрабатывает клиента на сокете %d.\n", pid, client_socket);
    while ((bytes_received = recv(client_socket, buffer, BUFFER_SIZE, 0)) > 0) {
        buffer[bytes_received];
        std::cout << "Received message from client: " << buffer << std::endl;
 
        send_message_to_client(client_socket, std::string(buffer));
 
    }
 
    if (bytes_received == 0) {
        std::cout << "Client disconnected" << std::endl;
    } else {
        std::cerr << "Error in receiving message from client" << std::endl;
    }
 
    close(client_socket);
}
 
int main() {
    int server_socket, client_socket;
    struct sockaddr_in server_addr, client_addr;
    socklen_t client_len = sizeof(client_addr);
 
    if ((server_socket = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
        std::cerr << "Error in creating socket" << std::endl;
        return -1;
    }
 
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = INADDR_ANY;
    server_addr.sin_port = htons(PORT);
 
    if (bind(server_socket, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
        std::cerr << "Error in binding socket" << std::endl;
        close(server_socket);
        return -1;
    }
 
    if (listen(server_socket, LISTENER_LIMIT) == -1) {
        std::cerr << "Error in listening for connections" << std::endl;
        close(server_socket);
        return -1;
    }
 
    std::cout << "Server listening on port " << PORT << std::endl;
 
 
    while (1) {
        if ((client_socket = accept(server_socket, (struct sockaddr *)&client_addr, &client_len)) == -1) {
            std::cerr << "Error in accepting connection" << std::endl;
            continue;
        }
        std::cout << "Client connected from " << inet_ntoa(client_addr.sin_addr) << ":" << ntohs(client_addr.sin_port) << std::endl;
 
        pid_t pid = fork();
        if (pid == 0) {
            close(server_socket);
            handle_client(client_socket);
            close(client_socket);
            exit(0);
        } else if (pid > 0) { 
            close(client_socket); 
            exit(1)
        } else {
            std::cerr << "Error in forking process" << std::endl;
        }
    }
 
    close(server_socket);
    return 0;
}