X-Git-Url: https://git.cworth.org/git?a=blobdiff_plain;ds=sidebyside;f=src%2Fttt-server.c;h=813042044873fa20b03d9ff571dfb3ab0a7f3b9f;hb=47ff725ff3b109b94a23ea7c8c07c8b1417e31ef;hp=b42db7a95064811b95fff78b4f0070236b4fe69c;hpb=80c3009d01077a141a0803267a1f0aff217ed61c;p=ttt diff --git a/src/ttt-server.c b/src/ttt-server.c index b42db7a..8130420 100644 --- a/src/ttt-server.c +++ b/src/ttt-server.c @@ -1,4 +1,4 @@ -/* ttt.c - client-server tic-tac-toe game +/* ttt-server.c - tic-tac-toe game server * * Copyright © 2005 Carl Worth * @@ -19,17 +19,232 @@ * Author: Carl Worth */ -#include "ttt.h" +#include "ttt-server.h" + +#include "ttt-args.h" +#include "ttt-client.h" +#include "ttt-error.h" +#include "ttt-socket.h" + +struct _ttt_server { + pthread_mutex_t mutex; + + const char *host; + const char *port; + + ttt_client_t **clients; + int clients_size; + int num_clients; +}; + +static void +ttt_server_init (ttt_server_t *server, const char *host, const char *port) +{ + pthread_mutex_init (&server->mutex, NULL); + + server->host = host; + server->port = port; + + server->clients = NULL; + server->clients_size = 0; + server->num_clients = 0; +} + +/* Exported: See ttt-server.h for documentation. */ +ttt_error_t +ttt_server_register_client (ttt_server_t *server, ttt_client_t *client) +{ + int i; + ttt_error_t error = TTT_ERROR_NONE; + const char *username; + + pthread_mutex_lock (&server->mutex); + + username = ttt_client_get_username (client); + + assert (username != NULL); + + if (username[0] == '\0') + return TTT_ERROR_INVALID_NAME; + + for (i = 0; i < server->num_clients; i++) { + if (strcmp (ttt_client_get_username (server->clients[i]), username) == 0) { + error = TTT_ERROR_INVALID_NAME; + goto CLEANUP_LOCK; + } + } + + printf ("Client %s has joined.\r\n", username); + + server->num_clients++; + + if (server->num_clients > server->clients_size) { + if (server->clients_size == 0) + server->clients_size = 1; + else + server->clients_size *= 2; + + server->clients = xrealloc (server->clients, + server->clients_size * sizeof (ttt_client_t *)); + } + + server->clients [server->num_clients - 1] = client; + + CLEANUP_LOCK: + pthread_mutex_unlock (&server->mutex); + + return error; +} + +/* Exported: See ttt-server.h for documentation. */ +void +ttt_server_unregister_client (ttt_server_t *server, ttt_client_t *client) +{ + int i; + + pthread_mutex_lock (&server->mutex); + + for (i = 0; i < server->num_clients; i++) + if (server->clients[i] == client) + break; + + assert (i < server->num_clients); + + printf ("Client %s has left.\r\n", ttt_client_get_username (client)); + + memmove (&server->clients[i], &server->clients[i+1], + (server->num_clients - i - 1) * sizeof (ttt_client_t *)); + + server->num_clients--; + + pthread_mutex_unlock (&server->mutex); +} + +/* Exported: See ttt-server.h for documentation. */ +void +ttt_server_broadcast (ttt_server_t *server, const char *message) +{ + int i; + + pthread_mutex_lock (&server->mutex); + + for (i = 0; i < server->num_clients; i++) + ttt_client_send (server->clients[i], message); + + pthread_mutex_unlock (&server->mutex); +} + +/* Exported: See ttt-server.h for documentation. */ +const char* +ttt_server_who (ttt_server_t *server) +{ + int i; + char *response; + + pthread_mutex_lock (&server->mutex); + + xasprintf (&response, "WHO"); + + for (i = 0; i < server->num_clients; i++) + xasprintf (&response, "%s %s", + response, + ttt_client_get_username (server->clients[i])); + + xasprintf (&response, "%s\r\n", response); + + pthread_mutex_unlock (&server->mutex); + + return response; +} + +/* Exported: See ttt-server.h for documentation. */ +ttt_error_t +ttt_server_statistics (ttt_server_t *server, const char *username, char **response) +{ + ttt_bool_t usernamefound = FALSE; + char *client_username; + int client_num_wins; + int i; + + pthread_mutex_lock (&server->mutex); + + for (i = 0; i < server->num_clients; i++) { + client_username = ttt_client_get_username (server->clients[i]); + if (strcasecmp (username, client_username) == 0) { + usernamefound = TRUE; + client_num_wins = ttt_client_get_num_wins (server->clients[i]); + xasprintf (response, "STATISTICS %s \"\r\n" + "TICTACTOE WINS %d\r\n\"\r\n", + client_username, + client_num_wins); + } + } + + pthread_mutex_unlock (&server->mutex); + + if (!usernamefound) + return TTT_ERROR_NO_USER; + + return TTT_ERROR_NONE; +} + +/* Exported: See ttt-server.h for documentation. */ +const char* +ttt_server_get_host (ttt_server_t *server) +{ + return server->host; +} + +/* Exported: See ttt-server.h for documentation. */ +const char* +ttt_server_get_port (ttt_server_t *server) +{ + return server->port; +} + +static const char *WELCOME_MESSAGE = +"Welcome to ttt-server. The server is currently listening on:\r\n" +"\r\n" +" %s:%s\r\n" +"\r\n" +"To test this, simply connect one or more clients to that host and port.\r\n" +"For example:\r\n" +"\r\n" +" telnet %s %s\r\n" +"\r\n" +"The TTTP (tic-tac-toe protocol) has been partially implemented.\r\n" +"The following commands should work: HELO, HELP, MESSAGE, VERSION, QUIT, WHO.\r\n" +"\r\n"; + +static void +_ttt_server_accept (void *closure, int client_socket) +{ + ttt_server_t *server = closure; + + ttt_client_new (server, client_socket); +} int main (int argc, char **argv) { ttt_args_t args; - int args_first; + ttt_server_t server; + int socket; + + ttt_args_parse (&args, argc, argv); + + if (args.log_file) + xfreopen (args.log_file, "a", stderr); + + socket = ttt_socket_create_server (args.host, args.port); + + printf (WELCOME_MESSAGE, args.host, args.port, args.host, args.port); - ttt_args_parse (&args, argc, argv, &args_first); + ttt_server_init (&server, args.host, args.port); - /* XXX: insert code here */ + while (1) + ttt_socket_accept (socket, _ttt_server_accept, &server); - return 0; + /* We only reach here if something bad happened. */ + return 1; }