Come Trovare un Tecnico Termoidraulico Specializzato in Caldaie a Biomassa.

Scopri come trovare un tecnico termoidraulico specializzato in caldaie a biomassa per garantire un'installazione sicura ed efficiente. Questo articolo offre suggerimenti pratici e risorse utili per scegliere il professionista giusto, ottimizzando il tuo sistema di riscaldamento eco-sostenibile.

#include #include #include #include #include #include #include #include #include #include #include "connection_mgr.h" #include "buffer.h" #include "packet.h" #include "packet_mgr.h" #include "thread_mgr.h" #include "log.h" #include "config.h" #include "connection.h" int connection_socket; struct connection_list { struct connection *conn; struct connection_list *next; }; struct connection_list *head; struct connection_list *tail; pthread_mutex_t connection_list_lock; void init_connection_mgr() { head = NULL; tail = NULL; pthread_mutex_init(&connection_list_lock, NULL); connection_socket = socket(AF_INET, SOCK_STREAM, 0); if (connection_socket < 0) { log_error("Failed to start connection manager: %s\n", strerror(errno)); exit(EXIT_FAILURE); } int optval = 1; setsockopt(connection_socket, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval)); struct sockaddr_in server_addr; memset(&server_addr, 0, sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_addr.s_addr = htonl(INADDR_ANY); server_addr.sin_port = htons(config.port); if (bind(connection_socket, (struct sockaddr *) &server_addr, sizeof(server_addr)) < 0) { log_error("Failed to start connection manager: %s\n", strerror(errno)); exit(EXIT_FAILURE); } if (listen(connection_socket, 5) < 0) { log_error("Failed to start connection manager: %s\n", strerror(errno)); exit(EXIT_FAILURE); } } void add_connection(struct connection *conn) { pthread_mutex_lock(&connection_list_lock); struct connection_list *node = malloc(sizeof(struct connection_list)); node->conn = conn; node->next = NULL; if (head == NULL) { head = node; tail = node; } else { tail->next = node; tail = node; } pthread_mutex_unlock(&connection_list_lock); } void remove_connection(struct connection *conn) { pthread_mutex_lock(&connection_list_lock); struct connection_list *node = head; if (head == NULL) { pthread_mutex_unlock(&connection_list_lock); return; } if (head->conn == conn) { head = head->next; free(node); pthread_mutex_unlock(&connection_list_lock); return; } while (node->next != NULL) { if (node->next->conn == conn) { struct connection_list *next = node->next->next; free(node->next); node->next = next; if (tail == node->next) { tail = node; } pthread_mutex_unlock(&connection_list_lock); return; } node = node->next; } pthread_mutex_unlock(&connection_list_lock); } void broadcast_packet(struct packet *packet) { pthread_mutex_lock(&connection_list_lock); struct connection_list *node = head; while (node != NULL) { connection_send_packet(node->conn, packet); node = node->next; } pthread_mutex_unlock(&connection_list_lock); } void connection_mgr_thread() { log_info("Connection manager started\n"); while (1) { struct sockaddr_in client_addr; socklen_t addr_len = sizeof(client_addr); int client_socket = accept(connection_socket, (struct sockaddr *) &client_addr, &addr_len); if (client_socket < 0) { log_error("Accepting client failed: %s\n", strerror(errno)); continue; } struct connection *conn = malloc(sizeof(struct connection)); conn->socket = client_socket; conn->recv_buffer = create_buffer(1024); conn->send_buffer = create_buffer(1024); conn->packet_buffer = malloc(sizeof(struct packet_buffer)); conn->packet_buffer->head = NULL; conn->packet_buffer->tail = NULL; conn->addr_len = addr_len; memcpy(&conn->client_addr, &client_addr, addr_len); add_connection(conn); log_info("Accepted client %s\n", inet_ntoa(client_addr.sin_addr)); add_thread(connection_thread, conn); } log_info("Connection manager stopped\n"); }