/* * Handling communication with clients. */ #include "moxerver.h" /* Closes client connection. */ int client_close(struct client_t *client) { /* force closing in case of error */ if (close(client->socket) == -1) { close(client->socket); } client->socket = -1; fprintf(stderr,"[%s] socket closed for client %s\n", __func__, client->ip_string); return 0; } /* Reads data from client into client data buffer. Returns number of read bytes. */ int client_read(struct client_t *client) { int len; /* read client data */ len = recv(client->socket, client->data, sizeof(client->data)-1, 0); if (len == -1) { fprintf(stderr, "[%s:%d] error %d: %s\n", __func__, __LINE__, errno, strerror(errno)); return -errno; } /* a disconnected client socket is ready for reading but read returns 0 */ if (len == 0) { fprintf(stderr, "[%s:%d] no data available from client\n", __func__, __LINE__); return -ENODATA; } //TODO let's print received bytes during development phase... { int i; for(i = 0; i < len; i++) { fprintf(stderr, "client %s <- %u '%c'\n", client->ip_string, (unsigned char) client->data[i], (unsigned char) client->data[i]); } } /* handle special telnet characters coming from client */ telnet_handle_client_read(client->data, &len); return len; } /* Sends data from a buffer to client. Returns number of sent bytes. */ int client_write(struct client_t *client, char *databuf, int datalen) { int len; /* handle special telnet characters to display them correctly on client */ //telnet_handle_client_write(databuf, &datalen); //TODO let's print received bytes during development phase... { int i; for(i = 0; i < datalen; i++) { fprintf(stderr, "client %s -> %u '%c'\n", client->ip_string, (unsigned char) databuf[i], (unsigned char) databuf[i]); } } /* send data to client */ len = send(client->socket, databuf, datalen, 0); if (len == -1) { fprintf(stderr, "[%s:%d] error %d: %s\n", __func__, __LINE__, errno, strerror(errno)); return -errno; } return len; }