src/lib/player/accept.c File Reference

#include <config.h>
#include <errno.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <unistd.h>
#include "empio.h"
#include "empthread.h"
#include "file.h"
#include "misc.h"
#include "optlist.h"
#include "player.h"
#include "power.h"
#include "proto.h"
#include "prototypes.h"

Include dependency graph for accept.c:

Go to the source code of this file.

Functions
void	player_init (void)
player *	player_new (int s)
player *	player_delete (struct player *lp)
player *	player_next (struct player *lp)
player *	player_prev (struct player *lp)
player *	getplayer (natid cnum)
void	player_accept (void *unused)
Variables
static struct emp_qelem	Players
static int	player_socket
static size_t	player_addrlen

---

Function Documentation

struct player* getplayer

(

natid

cnum

)

[read]

Definition at line 140 of file accept.c.

References player::cnum, NULL, Players, PS_PLAYING, emp_qelem::q_forw, and player::state.

Referenced by coun_list(), kill_cmd(), play_cmd(), and typed_wu().

{
    struct emp_qelem *qp;
    struct player *pl;

    for (qp = Players.q_forw; qp != &Players; qp = qp->q_forw) {
        pl = (struct player *)qp;
        if (pl->cnum == cnum && pl->state == PS_PLAYING)
            return pl;
    }

    return NULL;
}

void player_accept

(

void *

unused

)

Definition at line 156 of file accept.c.

References accept, close, empth_create(), empth_select(), player::hostaddr, player::hostname, inet_ntop(), logerror(), MAX, MAXNOC, NULL, player_addrlen, player_login(), player_new(), player_socket, setsockopt, and WORLD_SZ.

Referenced by start_server().

{
    struct sockaddr *sap;
    void *inaddr;
    int s = player_socket;
    struct player *np;
    socklen_t len;
    int ns;
    int set = 1;
    int stacksize;
    char buf[128];
#ifdef RESOLVE_IPADDRESS
    struct hostent *hostp;
#endif

    /* auto sockaddr_storage would be simpler, but less portable */
    sap = malloc(player_addrlen);

    while (1) {
        empth_select(s, EMPTH_FD_READ);
        len = player_addrlen;
        ns = accept(s, sap, &len);
        /* FIXME accept() can block on some systems (RST after select() reports ready) */
        if (ns < 0) {
            logerror("new socket accept");
            continue;
        }
        /* FIXME SO_KEEPALIVE is useless, player_kill_idle() strikes long before */
        (void)setsockopt(ns, SOL_SOCKET, SO_KEEPALIVE, &set, sizeof(set));
        np = player_new(ns);
        if (!np) {
            logerror("can't create player for fd %d", ns);
            close(ns);
            continue;
        }
#ifdef HAVE_GETADDRINFO
        inaddr = sap->sa_family == AF_INET
            ? (void *)&((struct sockaddr_in *)sap)->sin_addr
            : (void *)&((struct sockaddr_in6 *)sap)->sin6_addr;
        /* Assumes that if you got getaddrinfo(), you got inet_ntop() too */
        if (!inet_ntop(sap->sa_family, inaddr,
                       np->hostaddr, sizeof(np->hostaddr))) {
            logerror("inet_ntop() failed: %s", strerror(errno));
            close(ns);
            continue;
        }
#else
        inaddr = &((struct sockaddr_in *)sap)->sin_addr;
        strcpy(np->hostaddr, inet_ntoa(*(struct in_addr *)inaddr));
#endif
#ifdef RESOLVE_IPADDRESS
        hostp = gethostbyaddr(inaddr, player_addrlen, sap->sa_family);
        if (NULL != hostp)
            strcpy(np->hostname, hostp->h_name);
#endif /* RESOLVE_IPADDRESS */
        /* FIXME ancient black magic; figure out true stack need */
        stacksize = 100000
/* budget */  + MAX(WORLD_SZ() * sizeof(int) * 7,
/* power */ MAXNOC * sizeof(struct powstr));
        sprintf(buf, "Player (fd #%d)", ns);
        empth_create(player_login, stacksize, 0, buf, np);
    }
}

Here is the call graph for this function:

struct player* player_delete

(

struct player *

lp

)

[read]

Definition at line 95 of file accept.c.

References emp_remque(), io_close(), player::iop, emp_qelem::q_back, and player::queue.

Referenced by player_login().

{
    struct player *back;

    back = (struct player *)lp->queue.q_back;
    if (back)
        emp_remque(&lp->queue);
    if (lp->iop) {
        /* it's a real player */
        io_close(lp->iop);
        lp->iop = 0;
    }
    free(lp);
    /* XXX may need to free bigmap here */
    return back;
}

Here is the call graph for this function:

void player_init

(

void

)

Definition at line 61 of file accept.c.

References emp_initque(), init_player_commands(), NULL, player_addrlen, player_socket, Players, and tcp_listen().

Referenced by init_server().

{
    emp_initque(&Players);
    init_player_commands();

    player_socket = tcp_listen(*listen_addr ? listen_addr : NULL,
                               loginport, &player_addrlen);
}

Here is the call graph for this function:

struct player* player_new

(

int

s

)

[read]

Definition at line 71 of file accept.c.

References player::cnum, player::curid, player::curup, emp_insque(), IO_BUFSIZE, IO_NBLOCK, io_open(), IO_READ, IO_WRITE, player::iop, NULL, Players, and player::queue.

Referenced by market_init(), player_accept(), and update_init().

{
    struct player *lp;

    lp = malloc(sizeof(struct player));
    if (!lp)
      return NULL;
    memset(lp, 0, sizeof(struct player));
    if (s >= 0) {
        /* real player, not dummy created by update and market update */
        lp->iop = io_open(s, IO_READ | IO_WRITE | IO_NBLOCK, IO_BUFSIZE);
        if (!lp->iop) {
            free(lp);
            return NULL;
        }
        emp_insque(&lp->queue, &Players);
        lp->cnum = 255;
        lp->curid = -1;
        time(&lp->curup);
    }
    return lp;
}

Here is the call graph for this function:

struct player* player_next

(

struct player *

lp

)

[read]

Definition at line 113 of file accept.c.

References Players, emp_qelem::q_forw, and player::queue.

Referenced by player_kill_idle(), pr_wall(), sendmessage(), shutdwn(), and update_run().

{
    if (lp == 0)
        lp = (struct player *)Players.q_forw;
    else
        lp = (struct player *)lp->queue.q_forw;
    if (&lp->queue == &Players)
        return 0;
    return lp;
}

struct player* player_prev

(

struct player *

lp

)

[read]

Definition at line 125 of file accept.c.

References Players, emp_qelem::q_back, and player::queue.

Referenced by play().

{
    if (lp == 0)
        lp = (struct player *)Players.q_back;
    else
        lp = (struct player *)lp->queue.q_back;
    if (&lp->queue == &Players)
        return 0;
    return lp;
}

---

Variable Documentation

size_t player_addrlen [static]

Definition at line 58 of file accept.c.

Referenced by player_accept(), and player_init().

int player_socket [static]

Definition at line 57 of file accept.c.

Referenced by player_accept(), and player_init().

struct emp_qelem Players [static]

Definition at line 56 of file accept.c.

Referenced by getplayer(), player_init(), player_new(), player_next(), and player_prev().

---