mux/src/bsd.cpp File Reference

#include "copyright.h"
#include "autoconf.h"
#include "config.h"
#include "externs.h"
#include <sys/file.h>
#include <sys/ioctl.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <signal.h>
#include "attrs.h"
#include "command.h"
#include "file_c.h"
#include "slave.h"

Include dependency graph for bsd.cpp:

Go to the source code of this file.

Data Structures
struct	SIGNALTYPE
struct	MUX_SIGNAMES
Defines
#define	CheckInput(x)   FD_ISSET(x, &input_set)
#define	CheckOutput(x)   FD_ISSET(x, &output_set)
#define	CAST_SIGNAL_FUNC
Typedefs
typedef struct SIGNALTYPE *	PSIGNALTYPE
Functions
static void	TelnetSetup (DESC *d)
	Begin initial telnet negotiations on a socket.
static void	SiteMonSend (int, const char *, DESC *, const char *)
static DESC *	initializesock (SOCKET, struct sockaddr_in *)
static DESC *	new_connection (PortInfo *Port, int *piError)
static bool	process_input (DESC *)
static int	make_nonblocking (SOCKET s)
void	CleanUpSlaveSocket (void)
void	CleanUpSlaveProcess (void)
void	boot_slave (dbref executor, dbref caller, dbref enactor, int)
	Lauch reverse-DNS slave process.
static int	get_slave_result (void)
static void	make_socket (PortInfo *Port)
void	SetupPorts (int *pnPorts, PortInfo aPorts[], IntArray *pia)
bool	ValidSocket (SOCKET s)
void	shovechars (int nPorts, PortInfo aPorts[])
void	shutdownsock (DESC *d, int reason)
static void	make_nolinger (SOCKET s)
static void	config_socket (SOCKET s)
void	process_output (void *dvoid, int bHandleShutdown)
int	HimState (DESC *d, unsigned char chOption)
	Return the other side's negotiation state.
int	UsState (DESC *d, unsigned char chOption)
	Return our side's negotiation state.
static void	SetHimState (DESC *d, unsigned char chOption, int iHimState)
	Change the other side's negotiation state.
static void	SetUsState (DESC *d, unsigned char chOption, int iUsState)
	Change our side's negotiation state.
static void	SendWill (DESC *d, unsigned char chOption)
	Transmit a Telnet WILL sequence for the given option.
static void	SendDont (DESC *d, unsigned char chOption)
	Transmit a Telnet DONT sequence for the given option.
static void	SendDo (DESC *d, unsigned char chOption)
	Transmit a Telnet DO sequence for the given option.
static void	SendWont (DESC *d, unsigned char chOption)
	Transmit a Telnet WONT sequence for the given option.
static bool	DesiredHimOption (DESC *d, unsigned char chOption)
	Determine whether we want a particular option on his side of the link to be enabled.
static bool	DesiredUsOption (DESC *d, unsigned char chOption)
	Determine whether we want a particular option on our side of the link to be enabled.
void	EnableHim (DESC *d, unsigned char chOption)
	Start the process of negotiating the enablement of an option on his side.
void	DisableHim (DESC *d, unsigned char chOption)
	Start the process of negotiating the disablement of an option on his side.
void	EnableUs (DESC *d, unsigned char chOption)
	Start the process of negotiating the enablement of an option on our side.
void	DisableUs (DESC *d, unsigned char chOption)
	Start the process of negotiating the disablement of an option on our side.
static void	process_input_helper (DESC *d, char *pBytes, int nBytes)
	Parse raw data from network connection into command lines and Telnet indications.
void	close_sockets (bool emergency, char *message)
void	emergency_shutdown (void)
static void	check_panicking (int sig)
static void	unset_signals (void)
void	BuildSignalNamesTable (void)
static char *	SignalDesc (int iSignal)
static void	log_signal (int iSignal)
static void	log_signal_ignore (int iSignal)
void	LogStatBuf (int stat_buf, const char *Name)
static RETSIGTYPE DCL_CDECL	sighandler (int sig)
void	set_signals (void)
void	list_system_resources (dbref player)
Variables
PortInfo	aMainGamePorts [MAX_LISTEN_PORTS]
int	nMainGamePorts = 0
unsigned int	ndescriptors = 0
DESC *	descriptor_list = NULL
int	maxd = 0
pid_t	slave_pid = 0
int	slave_socket = INVALID_SOCKET
pid_t	game_pid
static const char *	disc_reasons []
static const char *	disc_messages []
static const unsigned char	nvt_input_xlat_table [256]
	Table to quickly classify characters recieved from the wire with their Telnet meaning.
static const int	nvt_input_action_table [8][14]
	Table to map current telnet parsing state state and input to specific actions and state changes.
const SIGNALTYPE	aSigTypes []
static MUX_SIGNAMES	signames [NSIG]
NAMETAB	sigactions_nametab []

---

Detailed Description

File for most TCP socket-related code. Some socket-related code also exists in netcommon.cpp, but most of it is here.

Id

bsd.cpp,v 1.81 2006/11/26 05:05:21 sdennis Exp

Definition in file bsd.cpp.

---

Define Documentation

#define CAST_SIGNAL_FUNC

Definition at line 3413 of file bsd.cpp.

Referenced by alarm_signal(), child_signal(), main(), set_signals(), and sighandler().

#define CheckInput

(

x

)

FD_ISSET(x, &input_set)

Referenced by shovechars().

#define CheckOutput

(

x

)

FD_ISSET(x, &output_set)

Referenced by shovechars().

---

Typedef Documentation

typedef struct SIGNALTYPE * PSIGNALTYPE

---

Function Documentation

void boot_slave	(	dbref	executor,
		dbref	caller,
		dbref	enactor,
		int
	)

Lauch reverse-DNS slave process.

This spawns the reverse-DNS slave process and creates a socket-oriented, bi-directional communiocation path between that process and this process. Any existing slave process is killed.

Parameters:

	executor	dbref of Executor.
	caller	dbref of Caller.
	enactor	dbref of Enactor.

Returns:

None.

Definition at line 649 of file bsd.cpp.

References CleanUpSlaveProcess(), CleanUpSlaveSocket(), CMuxAlarm::Clear(), DebugTotalSockets, ENDLOG, LOG_ALWAYS, log_number(), log_text(), make_nonblocking(), maxd, MuxAlarm, slave_pid, slave_socket, and STARTLOG.

Referenced by main(), and shovechars().

{
    char *pFailedFunc = 0;
    int sv[2];
    int i;
    int maxfds;

#ifdef HAVE_GETDTABLESIZE
    maxfds = getdtablesize();
#else // HAVE_GETDTABLESIZE
    maxfds = sysconf(_SC_OPEN_MAX);
#endif // HAVE_GETDTABLESIZE

    CleanUpSlaveSocket();
    CleanUpSlaveProcess();

    if (socketpair(AF_UNIX, SOCK_DGRAM, 0, sv) < 0)
    {
        pFailedFunc = "socketpair() error: ";
        goto failure;
    }

    // Set to nonblocking.
    //
    if (make_nonblocking(sv[0]) < 0)
    {
        pFailedFunc = "make_nonblocking() error: ";
        close(sv[0]);
        close(sv[1]);
        goto failure;
    }
    slave_pid = fork();
    switch (slave_pid)
    {
    case -1:

        pFailedFunc = "fork() error: ";
        close(sv[0]);
        close(sv[1]);
        goto failure;

    case 0:

        // If we don't clear this alarm, the child will eventually receive a
        // SIG_PROF.
        //
        MuxAlarm.Clear();

        // Child.  The following calls to dup2() assume only the minimal
        // dup2() functionality.  That is, the destination descriptor is
        // always available for it, and sv[1] is never that descriptor.
        // It is likely that the standard defined behavior of dup2()
        // would handle the job by itself more directly, but a little
        // extra code is low-cost insurance.
        //
        close(sv[0]);
        if (sv[1] != 0)
        {
            close(0);
            if (dup2(sv[1], 0) == -1)
            {
                _exit(1);
            }
        }
        if (sv[1] != 1)
        {
            close(1);
            if (dup2(sv[1], 1) == -1)
            {
                _exit(1);
            }
        }
        for (i = 3; i < maxfds; i++)
        {
            close(i);
        }
        execlp("bin/slave", "slave", NULL);
        _exit(1);
    }
    close(sv[1]);

    slave_socket = sv[0];
    DebugTotalSockets++;
    if (make_nonblocking(slave_socket) < 0)
    {
        pFailedFunc = "make_nonblocking() error: ";
        CleanUpSlaveSocket();
        goto failure;
    }
    if (maxd <= slave_socket)
    {
        maxd = slave_socket + 1;
    }

    STARTLOG(LOG_ALWAYS, "NET", "SLAVE");
    log_text("DNS lookup slave started on fd ");
    log_number(slave_socket);
    ENDLOG;
    return;

failure:

    CleanUpSlaveProcess();
    STARTLOG(LOG_ALWAYS, "NET", "SLAVE");
    log_text(pFailedFunc);
    log_number(errno);
    ENDLOG;
}

void BuildSignalNamesTable

(

void

)

Definition at line 3632 of file bsd.cpp.

References aSigTypes, SIGNALTYPE::iSignal, MUX_SIGNAMES::pLongName, MUX_SIGNAMES::pShortName, signames, and SIGNALTYPE::szSignal.

Referenced by main().

{
    int i;
    for (i = 0; i < NSIG; i++)
    {
        signames[i].pShortName = NULL;
        signames[i].pLongName  = NULL;
    }

    const SIGNALTYPE *pst = aSigTypes;
    while (pst->szSignal)
    {
        int sig = pst->iSignal;
        if (  0 <= sig
           && sig < NSIG)
        {
            MUX_SIGNAMES *tsn = &signames[sig];
            if (tsn->pShortName == NULL)
            {
                tsn->pShortName = pst->szSignal;
#ifndef WIN32
                if (sig == SIGUSR1)
                {
                    tsn->pLongName = "Restart server";
                }
                else if (sig == SIGUSR2)
                {
                    tsn->pLongName = "Drop flatfile";
                }
#endif // WIN32
#ifdef SysSigNames
                if (  tsn->pLongName == NULL
                   && SysSigNames[sig]
                   && strcmp(tsn->pShortName, SysSigNames[sig]) != 0)
                {
                    tsn->pLongName = SysSigNames[sig];
                }
#endif // SysSigNames
            }
        }
        pst++;
    }
    for (i = 0; i < NSIG; i++)
    {
        MUX_SIGNAMES *tsn = &signames[i];
        if (tsn->pShortName == NULL)
        {
#ifdef SysSigNames
            if (SysSigNames[i])
            {
                tsn->pLongName = SysSigNames[i];
            }
#endif // SysSigNames

            // This is the only non-const memory case.
            //
            tsn->pShortName = StringClone(tprintf("SIG%03d", i));
        }
    }
}

static void check_panicking

(

int

sig

)

[static]

Definition at line 3380 of file bsd.cpp.

References game_pid, mudstate, statedata::panicking, and UNUSED_PARAMETER.

Referenced by sighandler().

{
    // If we are panicking, turn off signal catching and resignal.
    //
    if (mudstate.panicking)
    {
        for (int i = 0; i < NSIG; i++)
        {
            signal(i, SIG_DFL);
        }
#ifdef WIN32
        UNUSED_PARAMETER(sig);
        abort();
#else // WIN32
        kill(game_pid, sig);
#endif // WIN32
    }
    mudstate.panicking = true;
}

void CleanUpSlaveProcess

(

void

)

Definition at line 478 of file bsd.cpp.

References slave_pid.

Referenced by boot_slave(), do_restart(), get_slave_result(), main(), new_connection(), and sighandler().

{
    if (slave_pid > 0)
    {
        kill(slave_pid, SIGKILL);
        waitpid(slave_pid, NULL, 0);
    }
    slave_pid = 0;
}

void CleanUpSlaveSocket

(

void

)

Definition at line 465 of file bsd.cpp.

References DebugTotalSockets, INVALID_SOCKET, IS_INVALID_SOCKET, SD_BOTH, and slave_socket.

Referenced by boot_slave(), do_restart(), get_slave_result(), main(), new_connection(), and sighandler().

{
    if (!IS_INVALID_SOCKET(slave_socket))
    {
        shutdown(slave_socket, SD_BOTH);
        if (close(slave_socket) == 0)
        {
            DebugTotalSockets--;
        }
        slave_socket = INVALID_SOCKET;
    }
}

void close_sockets	(	bool	emergency,
		char *	message
	)

Definition at line 3336 of file bsd.cpp.

References aMainGamePorts, DebugTotalSockets, DESC_SAFEITER_ALL, descriptor_data::descriptor, INVALID_SOCKET, IS_SOCKET_ERROR, log_perror(), nMainGamePorts, queue_string(), queue_write_LEN(), R_GOING_DOWN, SD_BOTH, shutdownsock(), PortInfo::socket, SOCKET_CLOSE, and SOCKET_WRITE.

Referenced by emergency_shutdown(), and main().

{
    DESC *d, *dnext;

    DESC_SAFEITER_ALL(d, dnext)
    {
        if (emergency)
        {
            SOCKET_WRITE(d->descriptor, message, strlen(message), 0);
            if (IS_SOCKET_ERROR(shutdown(d->descriptor, SD_BOTH)))
            {
                log_perror("NET", "FAIL", NULL, "shutdown");
            }
            if (SOCKET_CLOSE(d->descriptor) == 0)
            {
                DebugTotalSockets--;
            }
        }
        else
        {
            queue_string(d, message);
            queue_write_LEN(d, "\r\n", 2);
            shutdownsock(d, R_GOING_DOWN);
        }
    }
    for (int i = 0; i < nMainGamePorts; i++)
    {
        if (SOCKET_CLOSE(aMainGamePorts[i].socket) == 0)
        {
            DebugTotalSockets--;
        }
        aMainGamePorts[i].socket = INVALID_SOCKET;
    }
}

static void config_socket

(

SOCKET

s

)

[static]

Definition at line 2202 of file bsd.cpp.

References make_nolinger(), and make_nonblocking().

Referenced by initializesock().

{
    make_nonblocking(s);
    make_nolinger(s);
}

static bool DesiredHimOption	(	DESC *	d,
		unsigned char	chOption
	)			[static]

Determine whether we want a particular option on his side of the link to be enabled.

Parameters:

	d	Player connection context.
	chOption	Telnet Option.

Returns:

Yes if we want it enabled.

Definition at line 2797 of file bsd.cpp.

References TELNET_EOR, TELNET_NAWS, TELNET_SGA, and UNUSED_PARAMETER.

Referenced by process_input_helper().

{
    UNUSED_PARAMETER(d);

    if (  TELNET_NAWS == chOption
       || TELNET_EOR  == chOption
       || TELNET_SGA  == chOption)
    {
        return true;
    }
    return false;
}

static bool DesiredUsOption	(	DESC *	d,
		unsigned char	chOption
	)			[static]

Determine whether we want a particular option on our side of the link to be enabled.

It doesn't make sense for NAWS to be enabled on the server side, and we only negotiate SGA on our side if we have already successfully negotiated the EOR option.

Parameters:

	d	Player connection context.
	chOption	Telnet Option.

Returns:

Yes if we want it enabled.

Definition at line 2822 of file bsd.cpp.

References OPTION_YES, TELNET_EOR, TELNET_SGA, and UsState().

Referenced by process_input_helper().

{
    if (  TELNET_EOR  == chOption
       || (  TELNET_SGA == chOption
          && OPTION_YES == UsState(d, TELNET_EOR)))
    {
        return true;
    }
    return false;
}

void DisableHim	(	DESC *	d,
		unsigned char	chOption
	)

Start the process of negotiating the disablement of an option on his side.

Whether we actually send anything across the wire to disable this depends on the negotiation state. The option could potentially already be disabled.

Parameters:

	d	Player connection context.
	chOption	Telnet Option.

Returns:

None.

Definition at line 2874 of file bsd.cpp.

References HimState(), OPTION_WANTNO_EMPTY, OPTION_WANTNO_OPPOSITE, OPTION_WANTYES_EMPTY, OPTION_WANTYES_OPPOSITE, OPTION_YES, SendDont(), and SetHimState().

{
    switch (HimState(d, chOption))
    {
    case OPTION_YES:
        SetHimState(d, chOption, OPTION_WANTNO_EMPTY);
        SendDont(d, chOption);
        break;

    case OPTION_WANTNO_OPPOSITE:
        SetHimState(d, chOption, OPTION_WANTNO_EMPTY);
        break;

    case OPTION_WANTYES_EMPTY:
        SetHimState(d, chOption, OPTION_WANTYES_OPPOSITE);
        break;
    }
}

void DisableUs	(	DESC *	d,
		unsigned char	chOption
	)

Start the process of negotiating the disablement of an option on our side.

Whether we actually send anything across the wire to disable this depends on the negotiation state. The option could potentially already be disabled.

Parameters:

	d	Player connection context.
	chOption	Telnet Option.

Returns:

None.

Definition at line 2934 of file bsd.cpp.

References HimState(), OPTION_WANTNO_EMPTY, OPTION_WANTNO_OPPOSITE, OPTION_WANTYES_EMPTY, OPTION_WANTYES_OPPOSITE, OPTION_YES, SendWont(), and SetUsState().

Referenced by SetUsState().

{
    switch (HimState(d, chOption))
    {
    case OPTION_YES:
        SetUsState(d, chOption, OPTION_WANTNO_EMPTY);
        SendWont(d, chOption);
        break;

    case OPTION_WANTNO_OPPOSITE:
        SetUsState(d, chOption, OPTION_WANTNO_EMPTY);
        break;

    case OPTION_WANTYES_EMPTY:
        SetUsState(d, chOption, OPTION_WANTYES_OPPOSITE);
        break;
    }
}

void emergency_shutdown

(

void

)

Definition at line 3371 of file bsd.cpp.

References close_sockets().

Referenced by do_shutdown().

{
    close_sockets(true, "Going down - Bye");
}

void EnableHim	(	DESC *	d,
		unsigned char	chOption
	)

Start the process of negotiating the enablement of an option on his side.

Whether we actually send anything across the wire to enable this depends on the negotiation state. The option could potentially already be enabled.

Parameters:

	d	Player connection context.
	chOption	Telnet Option.

Returns:

None.

Definition at line 2844 of file bsd.cpp.

References HimState(), OPTION_NO, OPTION_WANTNO_EMPTY, OPTION_WANTNO_OPPOSITE, OPTION_WANTYES_EMPTY, OPTION_WANTYES_OPPOSITE, SendDo(), and SetHimState().

Referenced by TelnetSetup().

{
    switch (HimState(d, chOption))
    {
    case OPTION_NO:
        SetHimState(d, chOption, OPTION_WANTYES_EMPTY);
        SendDo(d, chOption);
        break;

    case OPTION_WANTNO_EMPTY:
        SetHimState(d, chOption, OPTION_WANTNO_OPPOSITE);
        break;

    case OPTION_WANTYES_OPPOSITE:
        SetHimState(d, chOption, OPTION_WANTYES_EMPTY);
        break;
    }
}

void EnableUs	(	DESC *	d,
		unsigned char	chOption
	)

Start the process of negotiating the enablement of an option on our side.

Whether we actually send anything across the wire to enable this depends on the negotiation state. The option could potentially already be enabled.

Parameters:

	d	Player connection context.
	chOption	Telnet Option.

Returns:

None.

Definition at line 2904 of file bsd.cpp.

References HimState(), OPTION_NO, OPTION_WANTNO_EMPTY, OPTION_WANTNO_OPPOSITE, OPTION_WANTYES_EMPTY, OPTION_WANTYES_OPPOSITE, SendWill(), and SetUsState().

Referenced by SetUsState(), and TelnetSetup().

{
    switch (HimState(d, chOption))
    {
    case OPTION_NO:
        SetUsState(d, chOption, OPTION_WANTYES_EMPTY);
        SendWill(d, chOption);
        break;

    case OPTION_WANTNO_EMPTY:
        SetUsState(d, chOption, OPTION_WANTNO_OPPOSITE);
        break;

    case OPTION_WANTYES_OPPOSITE:
        SetUsState(d, chOption, OPTION_WANTYES_EMPTY);
        break;
    }
}

static int get_slave_result

(

void

)

[static]

Definition at line 806 of file bsd.cpp.

References A_LASTIP, A_LASTSITE, descriptor_data::addr, descriptor_data::address, alloc_lbuf, atr_add_raw(), CleanUpSlaveProcess(), CleanUpSlaveSocket(), descriptor_list, ENDLOG, free_lbuf, LBUF_SIZE, LOG_ALWAYS, log_text(), mudconf, descriptor_data::next, descriptor_data::player, slave_socket, SOCKET_EWOULDBLOCK, SOCKET_LAST_ERROR, STARTLOG, tprintf(), confdata::use_hostname, and descriptor_data::username.

Referenced by shovechars().

{
    int local_port, remote_port;
    DESC *d;

    char *buf = alloc_lbuf("slave_buf");

    int len = read(slave_socket, buf, LBUF_SIZE-1);
    if (len < 0)
    {
        int iSocketError = SOCKET_LAST_ERROR;
        if (  iSocketError == SOCKET_EAGAIN
           || iSocketError == SOCKET_EWOULDBLOCK)
        {
            free_lbuf(buf);
            return -1;
        }
        CleanUpSlaveSocket();
        CleanUpSlaveProcess();
        free_lbuf(buf);

        STARTLOG(LOG_ALWAYS, "NET", "SLAVE");
        log_text("read() of slave result failed. Slave stopped.");
        ENDLOG;

        return -1;
    }
    else if (len == 0)
    {
        free_lbuf(buf);
        return -1;
    }
    buf[len] = '\0';

    char *token = alloc_lbuf("slave_token");
    char *os = alloc_lbuf("slave_os");
    char *userid = alloc_lbuf("slave_userid");
    char *host = alloc_lbuf("slave_host");
    char *p;
    if (sscanf(buf, "%s %s", host, token) != 2)
    {
        goto Done;
    }
    p = strchr(buf, '\n');
    *p = '\0';
    if (mudconf.use_hostname)
    {
        for (d = descriptor_list; d; d = d->next)
        {
            if (strcmp(d->addr, host) != 0)
            {
                continue;
            }

            strncpy(d->addr, token, 50);
            d->addr[50] = '\0';
            if (d->player != 0)
            {
                if (d->username[0])
                {
                    atr_add_raw(d->player, A_LASTSITE, tprintf("%s@%s",
                        d->username, d->addr));
                }
                else
                {
                    atr_add_raw(d->player, A_LASTSITE, d->addr);
                }
                atr_add_raw(d->player, A_LASTIP, inet_ntoa((d->address).sin_addr));
            }
        }
    }

    if (sscanf(p + 1, "%s %d , %d : %s : %s : %s",
           host,
           &remote_port, &local_port,
           token, os, userid) != 6)
    {
        goto Done;
    }
    for (d = descriptor_list; d; d = d->next)
    {
        if (ntohs((d->address).sin_port) != remote_port)
            continue;
        strncpy(d->username, userid, 10);
        d->username[10] = '\0';
        if (d->player != 0)
        {
            atr_add_raw(d->player, A_LASTSITE, tprintf("%s@%s",
                             d->username, d->addr));
        }
    }
Done:
    free_lbuf(buf);
    free_lbuf(token);
    free_lbuf(os);
    free_lbuf(userid);
    free_lbuf(host);
    return 0;
}

int HimState	(	DESC *	d,
		unsigned char	chOption
	)

Return the other side's negotiation state.

The negotiation of each optional feature of telnet can be in one of six states (defined in interface.h): OPTION_NO, OPTION_YES, OPTION_WANTNO_EMPTY, OPTION_WANTNO_OPPOSITE, OPTION_WANTYES_EMPTY, and OPTION_WANTYES_OPPOSITE.

An option is only enabled when it is in the OPTION_YES state.

Parameters:

	d	Player connection context.
	chOption	Telnet Option

Returns:

One of six states.

Definition at line 2629 of file bsd.cpp.

References descriptor_data::nvt_eor_him_state, descriptor_data::nvt_naws_him_state, descriptor_data::nvt_sga_him_state, OPTION_NO, TELNET_EOR, TELNET_NAWS, and TELNET_SGA.

Referenced by DisableHim(), DisableUs(), EnableHim(), EnableUs(), and process_input_helper().

{
    if (TELNET_NAWS == chOption)
    {
        return d->nvt_naws_him_state;
    }
    else if (TELNET_EOR == chOption)
    {
        return d->nvt_eor_him_state;
    }
    else if (TELNET_SGA == chOption)
    {
        return d->nvt_sga_him_state;
    }
    return OPTION_NO;
}

DESC * initializesock	(	SOCKET	,
		struct sockaddr_in *
	)			[static]

Definition at line 2210 of file bsd.cpp.

References statedata::access_list, descriptor_data::addr, descriptor_data::address, alloc_desc, confdata::cmd_quota_max, descriptor_data::command_count, config_socket(), descriptor_data::connected_at, descriptor_data::descriptor, descriptor_list, descriptor_data::doing, descriptor_data::flags, CLinearTimeAbsolute::GetUTC(), descriptor_data::hashnext, descriptor_data::height, descriptor_data::host_info, confdata::idle_timeout, descriptor_data::input_head, descriptor_data::input_lost, descriptor_data::input_size, descriptor_data::input_tail, descriptor_data::input_tot, descriptor_data::last_time, mudconf, mudstate, ndescriptors, descriptor_data::next, descriptor_data::nOption, descriptor_data::nvt_eor_him_state, descriptor_data::nvt_eor_us_state, NVT_IS_NORMAL, descriptor_data::nvt_naws_him_state, descriptor_data::nvt_naws_us_state, descriptor_data::nvt_sga_him_state, descriptor_data::nvt_sga_us_state, OPTION_NO, descriptor_data::output_head, descriptor_data::output_lost, descriptor_data::output_prefix, descriptor_data::output_size, descriptor_data::output_suffix, descriptor_data::output_tail, descriptor_data::output_tot, descriptor_data::player, descriptor_data::prev, descriptor_data::program_data, descriptor_data::quota, descriptor_data::raw_input, descriptor_data::raw_input_at, descriptor_data::raw_input_state, descriptor_data::retries_left, confdata::retry_limit, site_check(), statedata::suspect_list, descriptor_data::timeout, descriptor_data::username, and descriptor_data::width.

Referenced by new_connection().

{
    DESC *d;

#ifdef WIN32
    // protect adding the descriptor from the linked list from
    // any interference from socket shutdowns
    //
    if (platform == VER_PLATFORM_WIN32_NT)
    {
        EnterCriticalSection(&csDescriptorList);
    }
#endif // WIN32

    d = alloc_desc("init_sock");

#ifdef WIN32
    if (platform == VER_PLATFORM_WIN32_NT)
    {
        LeaveCriticalSection(&csDescriptorList);
    }
#endif // WIN32

    d->descriptor = s;
    d->flags = 0;
    d->connected_at.GetUTC();
    d->last_time = d->connected_at;
    d->retries_left = mudconf.retry_limit;
    d->command_count = 0;
    d->timeout = mudconf.idle_timeout;
    d->host_info = site_check((*a).sin_addr, mudstate.access_list)
                 | site_check((*a).sin_addr, mudstate.suspect_list);

    // Be sure #0 isn't wizard. Shouldn't be.
    //
    d->player = 0;

    d->addr[0] = '\0';
    d->doing[0] = '\0';
    d->username[0] = '\0';
    config_socket(s);
    d->output_prefix = NULL;
    d->output_suffix = NULL;
    d->output_size = 0;
    d->output_tot = 0;
    d->output_lost = 0;
    d->output_head = NULL;
    d->output_tail = NULL;
    d->input_head = NULL;
    d->input_tail = NULL;
    d->input_size = 0;
    d->input_tot = 0;
    d->input_lost = 0;
    d->raw_input = NULL;
    d->raw_input_at = NULL;
    d->nOption = 0;
    d->raw_input_state = NVT_IS_NORMAL;
    d->nvt_sga_him_state = OPTION_NO;
    d->nvt_sga_us_state = OPTION_NO;
    d->nvt_eor_him_state = OPTION_NO;
    d->nvt_eor_us_state = OPTION_NO;
    d->nvt_naws_him_state = OPTION_NO;
    d->nvt_naws_us_state = OPTION_NO;
    d->height = 24;
    d->width = 78;
    d->quota = mudconf.cmd_quota_max;
    d->program_data = NULL;
    d->address = *a;
    strncpy(d->addr, inet_ntoa(a->sin_addr), 50);
    d->addr[50] = '\0';

#ifdef WIN32
    // protect adding the descriptor from the linked list from
    // any interference from socket shutdowns
    //
    if (platform == VER_PLATFORM_WIN32_NT)
    {
        EnterCriticalSection (&csDescriptorList);
    }
#endif // WIN32

    ndescriptors++;

    if (descriptor_list)
    {
        descriptor_list->prev = &d->next;
    }
    d->hashnext = NULL;
    d->next = descriptor_list;
    d->prev = &descriptor_list;
    descriptor_list = d;

#ifdef WIN32
    // ok to continue now
    //
    if (platform == VER_PLATFORM_WIN32_NT)
    {
        LeaveCriticalSection (&csDescriptorList);

        d->OutboundOverlapped.hEvent = NULL;
        d->InboundOverlapped.hEvent = NULL;
        d->InboundOverlapped.Offset = 0;
        d->InboundOverlapped.OffsetHigh = 0;
        d->bWritePending = false;   // no write pending yet
        d->bConnectionShutdown = false; // not shutdown yet
        d->bConnectionDropped = false; // not dropped yet
        d->bCallProcessOutputLater = false;
    }
#endif // WIN32
    return d;
}

void list_system_resources

(

dbref

player

)

Definition at line 4070 of file bsd.cpp.

References DebugTotalFiles, DebugTotalSockets, and notify.

Referenced by do_list().

{
    char buffer[80];

    int nTotal = 0;
    notify(player, "System Resources");

    sprintf(buffer, "Total Open Files: %ld", DebugTotalFiles);
    notify(player, buffer);
    nTotal += DebugTotalFiles;

    sprintf(buffer, "Total Sockets: %ld", DebugTotalSockets);
    notify(player, buffer);
    nTotal += DebugTotalSockets;

#ifdef WIN32
    sprintf(buffer, "Total Threads: %ld", DebugTotalThreads);
    notify(player, buffer);
    nTotal += DebugTotalThreads;

    sprintf(buffer, "Total Semaphores: %ld", DebugTotalSemaphores);
    notify(player, buffer);
    nTotal += DebugTotalSemaphores;
#endif // WIN32

    sprintf(buffer, "Total Handles (sum of above): %d", nTotal);
    notify(player, buffer);

#ifdef WIN32
    for (int i = 0; i < NUM_SLAVE_THREADS; i++)
    {
        sprintf(buffer, "Thread %d at line %u", i+1, SlaveThreadInfo[i].iDoing);
        notify(player, buffer);
    }
#endif // WIN32
}

static void log_signal

(

int

iSignal

)

[static]

Definition at line 3708 of file bsd.cpp.

References