2 * Empire - A multi-player, client/server Internet based war game.
3 * Copyright (C) 1986-2006, Dave Pare, Jeff Bailey, Thomas Ruschak,
4 * Ken Stevens, Steve McClure
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
22 * See files README, COPYING and CREDITS in the root of the source
23 * tree for related information and legal notices. It is expected
24 * that future projects/authors will amend these files as needed.
28 * accept.c: Keep track of people logged in
30 * Known contributors to this file:
32 * Markus Armbruster, 2005
43 #include "prototypes.h"
46 #include "empthread.h"
55 #include <arpa/inet.h>
56 #include <sys/socket.h>
59 #include <netinet/in.h>
60 #include <sys/ioctl.h>
69 static struct emp_qelem Players;
70 static int player_socket;
71 static int player_addrlen;
76 emp_initque(&Players);
77 init_player_commands();
79 player_socket = tcp_listen(*listen_addr ? listen_addr : NULL,
80 loginport, &player_addrlen);
88 lp = malloc(sizeof(struct player));
91 memset(lp, 0, sizeof(struct player));
93 /* real player, not dummy created by update and market update */
94 lp->iop = io_open(s, IO_READ | IO_WRITE | IO_NBLOCK, IO_BUFSIZE);
99 emp_insque(&lp->queue, &Players);
108 player_delete(struct player *lp)
112 back = (struct player *)lp->queue.q_back;
114 emp_remque(&lp->queue);
116 /* it's a real player */
121 /* XXX may need to free bigmap here */
126 player_next(struct player *lp)
129 lp = (struct player *)Players.q_forw;
131 lp = (struct player *)lp->queue.q_forw;
132 if (&lp->queue == &Players)
138 player_prev(struct player *lp)
141 lp = (struct player *)Players.q_back;
143 lp = (struct player *)lp->queue.q_back;
144 if (&lp->queue == &Players)
150 * Return player in state PS_PLAYING for CNUM.
153 getplayer(natid cnum)
155 struct emp_qelem *qp;
158 for (qp = Players.q_forw; qp != &Players; qp = qp->q_forw) {
159 pl = (struct player *)qp;
160 if (pl->cnum == cnum && pl->state == PS_PLAYING)
168 player_wakeup_all(natid cnum)
170 register struct player *lp;
172 if (NULL != (lp = getplayer(cnum)))
177 player_wakeup(struct player *pl)
180 empth_wakeup(pl->proc);
185 player_accept(void *unused)
187 struct sockaddr *sap;
189 int s = player_socket;
196 #ifdef RESOLVE_IPADDRESS
197 struct hostent *hostp;
200 /* auto sockaddr_storage would be simpler, but less portable */
201 sap = malloc(player_addrlen);
204 empth_select(s, EMPTH_FD_READ);
205 len = player_addrlen;
206 ns = accept(s, sap, &len);
207 /* FIXME accept() can block on some systems (RST after select() reported s ready) */
209 logerror("new socket accept");
212 /* FIXME SO_KEEPALIVE is useless, player_kill_idle() strikes long before */
213 (void)setsockopt(ns, SOL_SOCKET, SO_KEEPALIVE, &set, sizeof(set));
216 logerror("can't create player for fd %d", ns);
220 #ifdef HAVE_GETADDRINFO
221 inaddr = sap->sa_family == AF_INET
222 ? (void *)&((struct sockaddr_in *)sap)->sin_addr
223 : (void *)&((struct sockaddr_in6 *)sap)->sin6_addr;
224 /* Assumes that if you got getaddrinfo(), you got inet_ntop() too */
225 if (!inet_ntop(sap->sa_family, inaddr,
226 np->hostaddr, sizeof(np->hostaddr))) {
227 logerror("inet_ntop() failed: %s", strerror(errno));
232 inaddr = &((struct sockaddr_in *)sap)->sin_addr;
233 strcpy(np->hostaddr, inet_ntoa(*(struct in_addr *)inaddr));
235 #ifdef RESOLVE_IPADDRESS
236 hostp = gethostbyaddr(inaddr, player_addrlen, sap->sa_family);
238 strcpy(np->hostname, hostp->h_name);
239 #endif /* RESOLVE_IPADDRESS */
240 /* XXX may not be big enough */
242 /* budget */ + MAX(WORLD_X * WORLD_Y / 2 * sizeof(int) * 7,
243 /* power */ MAXNOC * sizeof(struct powstr));
244 sprintf(buf, "Player (fd #%d)", ns);
245 empth_create(PP_PLAYER, player_login, stacksize,
246 0, buf, "Empire player", np);