g_queue.c

/*
Copyright (C) 2000 Shane Powell

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  

See the GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

 */

#include "g_local.h"

void addCmdQueue(int client, byte command, float timeout, unsigned long data, char *str) {
    char tmptext[128];

    proxyinfo[client].cmdQueue[proxyinfo[client].maxCmds].command = command;
    proxyinfo[client].cmdQueue[proxyinfo[client].maxCmds].timeout = ltime + timeout;
    proxyinfo[client].cmdQueue[proxyinfo[client].maxCmds].data = data;
    proxyinfo[client].cmdQueue[proxyinfo[client].maxCmds].str = str;
    proxyinfo[client].maxCmds++;

    if (command == QCMD_DISCONNECT) {
        gi.cprintf(NULL, PRINT_HIGH, "%s is being disconnected for %s.\n", proxyinfo[client].name, str);
    }

    if (proxyinfo[client].maxCmds >= ALLOWED_MAXCMDS_SAFETY) {
        proxyinfo[client].clientcommand |= CCMD_KICKED;
        gi.bprintf(PRINT_HIGH, "%s tried to flood the server.\n", proxyinfo[client].name);
        Q_snprintf(tmptext, sizeof(tmptext), "kick %d\n", client);
        //need to log
        gi.AddCommandString(tmptext);
    }
}

qboolean getCommandFromQueue(int client, byte *command, unsigned long *data, char **str) {
    unsigned int i;

    for (i = 0; i < proxyinfo[client].maxCmds; i++) {
        if (proxyinfo[client].cmdQueue[i].timeout < ltime) {
            // found good command..
            // get info to return
            *command = proxyinfo[client].cmdQueue[i].command;
            *data = proxyinfo[client].cmdQueue[i].data;

            if (str) {
                *str = proxyinfo[client].cmdQueue[i].str;
            }

            // remove command
            proxyinfo[client].maxCmds--;

            if (i < proxyinfo[client].maxCmds) {
                q2a_memmove(
                    proxyinfo[client].cmdQueue + i,
                    proxyinfo[client].cmdQueue + i + 1,
                    (proxyinfo[client].maxCmds - i) * sizeof (cmd_queue_t)
                );
            }

            return TRUE;
        }
    }

    return FALSE;
}

void removeClientCommand(int client, byte command) {
    unsigned int i = 0;

    while (i < proxyinfo[client].maxCmds) {
        if (proxyinfo[client].cmdQueue[i].command == command) {
            // remove command
            proxyinfo[client].maxCmds--;
            if (i < proxyinfo[client].maxCmds) {
                q2a_memmove(proxyinfo[client].cmdQueue + i, proxyinfo[client].cmdQueue + i + 1, (proxyinfo[client].maxCmds - i) * sizeof (cmd_queue_t));
            }
        } else {
            i++;
        }
    }
}

void removeClientCommands(int client) {
    proxyinfo[client].maxCmds = 0;
}