/* Copyright (C) 1997-2001 Id Software, Inc. 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. */ // Created on 17.01.2004 by RST. // $Id: SV_USER.java,v 1.3.2.1 2004-07-09 08:38:25 hzi Exp $ package jake2.server; import jake2.game.*; import jake2.qcommon.*; import jake2.util.Lib; import java.io.IOException; public class SV_USER extends SV_SEND { static edict_t sv_player; /* ============================================================ USER STRINGCMD EXECUTION sv_client and sv_player will be valid. ============================================================ */ /* ================== SV_BeginDemoServer ================== */ public static void SV_BeginDemoserver() { String name; name= "demos/" + sv.name; try { sv.demofile= FS.FOpenFile(name); } catch (IOException e) { Com.Error(ERR_DROP, "Couldn't open " + name + "\n"); } if (sv.demofile == null) Com.Error(ERR_DROP, "Couldn't open " + name + "\n"); } /* ================ SV_New_f Sends the first message from the server to a connected client. This will be sent on the initial connection and upon each server load. ================ */ public static void SV_New_f() { String gamedir; int playernum; edict_t ent; Com.DPrintf("New() from " + sv_client.name + "\n"); if (sv_client.state != cs_connected) { Com.Printf("New not valid -- already spawned\n"); return; } // demo servers just dump the file message if (sv.state == ss_demo) { SV_BeginDemoserver(); return; } // // serverdata needs to go over for all types of servers // to make sure the protocol is right, and to set the gamedir // gamedir= Cvar.VariableString("gamedir"); // send the serverdata MSG.WriteByte(sv_client.netchan.message, svc_serverdata); MSG.WriteInt(sv_client.netchan.message, PROTOCOL_VERSION); MSG.WriteLong(sv_client.netchan.message, svs.spawncount); MSG.WriteByte(sv_client.netchan.message, sv.attractloop ? 1 : 0); MSG.WriteString(sv_client.netchan.message, gamedir); if (sv.state == ss_cinematic || sv.state == ss_pic) playernum= -1; else //playernum = sv_client - svs.clients; playernum= sv_client.serverindex; MSG.WriteShort(sv_client.netchan.message, playernum); // send full levelname MSG.WriteString(sv_client.netchan.message, sv.configstrings[CS_NAME]); // // game server // if (sv.state == ss_game) { // set up the entity for the client ent= SV_GAME.ge.edicts[playernum + 1]; ent.s.number= playernum + 1; sv_client.edict= ent; sv_client.lastcmd= new usercmd_t(); // begin fetching configstrings MSG.WriteByte(sv_client.netchan.message, svc_stufftext); MSG.WriteString(sv_client.netchan.message, "cmd configstrings " + svs.spawncount + " 0\n"); } } /* ================== SV_Configstrings_f ================== */ public static void SV_Configstrings_f() { int start; Com.DPrintf("Configstrings() from " + sv_client.name + "\n"); if (sv_client.state != cs_connected) { Com.Printf("configstrings not valid -- already spawned\n"); return; } // handle the case of a level changing while a client was connecting if (atoi(Cmd.Argv(1)) != svs.spawncount) { Com.Printf("SV_Configstrings_f from different level\n"); SV_New_f(); return; } start= atoi(Cmd.Argv(2)); // write a packet full of data while (sv_client.netchan.message.cursize < MAX_MSGLEN / 2 && start < MAX_CONFIGSTRINGS) { if (sv.configstrings[start] != null && sv.configstrings[start].length() != 0) { MSG.WriteByte(sv_client.netchan.message, svc_configstring); MSG.WriteShort(sv_client.netchan.message, start); MSG.WriteString(sv_client.netchan.message, sv.configstrings[start]); } start++; } // send next command if (start == MAX_CONFIGSTRINGS) { MSG.WriteByte(sv_client.netchan.message, svc_stufftext); MSG.WriteString(sv_client.netchan.message, "cmd baselines " + svs.spawncount + " 0\n"); } else { MSG.WriteByte(sv_client.netchan.message, svc_stufftext); MSG.WriteString(sv_client.netchan.message, "cmd configstrings " + svs.spawncount + " " + start + "\n"); } } /* ================== SV_Baselines_f ================== */ public static void SV_Baselines_f() { int start; entity_state_t nullstate; entity_state_t base; Com.DPrintf("Baselines() from " + sv_client.name + "\n"); if (sv_client.state != cs_connected) { Com.Printf("baselines not valid -- already spawned\n"); return; } // handle the case of a level changing while a client was connecting if (atoi(Cmd.Argv(1)) != svs.spawncount) { Com.Printf("SV_Baselines_f from different level\n"); SV_New_f(); return; } start= atoi(Cmd.Argv(2)); //memset (&nullstate, 0, sizeof(nullstate)); nullstate= new entity_state_t(null); // write a packet full of data while (sv_client.netchan.message.cursize < MAX_MSGLEN / 2 && start < MAX_EDICTS) { base= sv.baselines[start]; if (base.modelindex != 0 || base.sound != 0 || base.effects != 0) { MSG.WriteByte(sv_client.netchan.message, svc_spawnbaseline); MSG.WriteDeltaEntity(nullstate, base, sv_client.netchan.message, true, true); } start++; } // send next command if (start == MAX_EDICTS) { MSG.WriteByte(sv_client.netchan.message, svc_stufftext); MSG.WriteString(sv_client.netchan.message, "precache " + svs.spawncount + "\n"); } else { MSG.WriteByte(sv_client.netchan.message, svc_stufftext); MSG.WriteString(sv_client.netchan.message, "cmd baselines " + svs.spawncount + " " + start + "\n"); } } /* ================== SV_Begin_f ================== */ public static void SV_Begin_f() { Com.DPrintf("Begin() from " + sv_client.name + "\n"); // handle the case of a level changing while a client was connecting if (atoi(Cmd.Argv(1)) != svs.spawncount) { Com.Printf("SV_Begin_f from different level\n"); SV_New_f(); return; } sv_client.state= cs_spawned; // call the game begin function SV_GAME.ge.ClientBegin(sv_player); Cbuf.InsertFromDefer(); } //============================================================================= /* ================== SV_NextDownload_f ================== */ public static void SV_NextDownload_f() { int r; int percent; int size; if (sv_client.download == null) return; r= sv_client.downloadsize - sv_client.downloadcount; if (r > 1024) r= 1024; MSG.WriteByte(sv_client.netchan.message, svc_download); MSG.WriteShort(sv_client.netchan.message, r); sv_client.downloadcount += r; size= sv_client.downloadsize; if (size == 0) size= 1; percent= sv_client.downloadcount * 100 / size; MSG.WriteByte(sv_client.netchan.message, percent); SZ.Write(sv_client.netchan.message, sv_client.download, sv_client.downloadcount - r, r); if (sv_client.downloadcount != sv_client.downloadsize) return; FS.FreeFile(sv_client.download); sv_client.download= null; } /* ================== SV_BeginDownload_f ================== */ public static void SV_BeginDownload_f() { String name; int offset= 0; name= Cmd.Argv(1); if (Cmd.Argc() > 2) offset= atoi(Cmd.Argv(2)); // downloaded offset // hacked by zoid to allow more conrol over download // first off, no .. or global allow check if (name.indexOf("..") != -1 || allow_download.value == 0 // leading dot is no good || name.charAt(0) == '.' // leading slash bad as well, must be in subdir || name.charAt(0) == '/' // next up, skin check || (name.startsWith("players/") && 0 == allow_download_players.value) // now models || (name.startsWith("models/") && 0 == allow_download_models.value) // now sounds || (name.startsWith("sound/") && 0 == allow_download_sounds.value) // now maps (note special case for maps, must not be in pak) || (name.startsWith("maps/") && 0 == allow_download_maps.value) // MUST be in a subdirectory || name.indexOf('/') == -1) { // don't allow anything with .. path MSG.WriteByte(sv_client.netchan.message, svc_download); MSG.WriteShort(sv_client.netchan.message, -1); MSG.WriteByte(sv_client.netchan.message, 0); return; } if (sv_client.download != null) FS.FreeFile(sv_client.download); sv_client.download= FS.LoadFile(name); sv_client.downloadsize= sv_client.download.length; sv_client.downloadcount= offset; if (offset > sv_client.downloadsize) sv_client.downloadcount= sv_client.downloadsize; if (sv_client.download == null // special check for maps, if it came from a pak file, don't allow // download ZOID || (name.startsWith("maps/") && FS.file_from_pak != 0)) { Com.DPrintf("Couldn't download " + name + " to " + sv_client.name + "\n"); if (sv_client.download != null) { FS.FreeFile(sv_client.download); sv_client.download= null; } MSG.WriteByte(sv_client.netchan.message, svc_download); MSG.WriteShort(sv_client.netchan.message, -1); MSG.WriteByte(sv_client.netchan.message, 0); return; } SV_NextDownload_f(); Com.DPrintf("Downloading " + name + " to " + sv_client.name + "\n"); } //============================================================================ /* ================= SV_Disconnect_f The client is going to disconnect, so remove the connection immediately ================= */ public static void SV_Disconnect_f() { // SV_EndRedirect (); SV_DropClient(sv_client); } /* ================== SV_ShowServerinfo_f Dumps the serverinfo info string ================== */ public static void SV_ShowServerinfo_f() { Info.Print(Cvar.Serverinfo()); } public static void SV_Nextserver() { String v; //ZOID, ss_pic can be nextserver'd in coop mode if (sv.state == ss_game || (sv.state == ss_pic && 0 == Cvar.VariableValue("coop"))) return; // can't nextserver while playing a normal game svs.spawncount++; // make sure another doesn't sneak in v= Cvar.VariableString("nextserver"); //if (!v[0]) if (v.length() == 0) Cbuf.AddText("killserver\n"); else { Cbuf.AddText(v); Cbuf.AddText("\n"); } Cvar.Set("nextserver", ""); } /* ================== SV_Nextserver_f A cinematic has completed or been aborted by a client, so move to the next server, ================== */ public static void SV_Nextserver_f() { if (Lib.atoi(Cmd.Argv(1)) != svs.spawncount) { Com.DPrintf("Nextserver() from wrong level, from " + sv_client.name + "\n"); return; // leftover from last server } Com.DPrintf("Nextserver() from " + sv_client.name + "\n"); SV_Nextserver(); } public static class ucmd_t { public ucmd_t(String n, Runnable r) { name= n; this.r= r; } String name; Runnable r; } static ucmd_t u1= new ucmd_t("new", new Runnable() { public void run() { SV_New_f(); } }); static ucmd_t ucmds[]= { // auto issued new ucmd_t("new", new Runnable() { public void run() { SV_New_f(); } }), new ucmd_t("configstrings", new Runnable() { public void run() { SV_Configstrings_f(); } }), new ucmd_t("baselines", new Runnable() { public void run() { SV_Baselines_f(); } }), new ucmd_t("begin", new Runnable() { public void run() { SV_Begin_f(); } }), new ucmd_t("nextserver", new Runnable() { public void run() { SV_Nextserver_f(); } }), new ucmd_t("disconnect", new Runnable() { public void run() { SV_Disconnect_f(); } }), // issued by hand at client consoles new ucmd_t("info", new Runnable() { public void run() { SV_ShowServerinfo_f(); } }), new ucmd_t("download", new Runnable() { public void run() { SV_BeginDownload_f(); } }), new ucmd_t("nextdl", new Runnable() { public void run() { SV_NextDownload_f(); } }) }; /* ================== SV_ExecuteUserCommand ================== */ public static void SV_ExecuteUserCommand(String s) { ucmd_t u= null; Cmd.TokenizeString(s.toCharArray(), true); sv_player= sv_client.edict; // SV_BeginRedirect (RD_CLIENT); int i= 0; for (; i < ucmds.length; i++) { u= ucmds[i]; if (0 == strcmp(Cmd.Argv(0), u.name)) { u.r.run(); break; } } if (i == ucmds.length && sv.state == ss_game) SV_GAME.ge.ClientCommand(sv_player); // SV_EndRedirect (); } /* =========================================================================== USER CMD EXECUTION =========================================================================== */ public static void SV_ClientThink(client_t cl, usercmd_t cmd) { cl.commandMsec -= cmd.msec & 0xFF; if (cl.commandMsec < 0 && sv_enforcetime.value != 0) { Com.DPrintf("commandMsec underflow from " + cl.name + "\n"); return; } SV_GAME.ge.ClientThink(cl.edict, cmd); } public static final int MAX_STRINGCMDS= 8; /* =================== SV_ExecuteClientMessage The current net_message is parsed for the given client =================== */ public static void SV_ExecuteClientMessage(client_t cl) { int c; String s; usercmd_t nullcmd= new usercmd_t(); usercmd_t oldest= new usercmd_t(), oldcmd= new usercmd_t(), newcmd= new usercmd_t(); int net_drop; int stringCmdCount; int checksum, calculatedChecksum; int checksumIndex; boolean move_issued; int lastframe; sv_client= cl; sv_player= sv_client.edict; // only allow one move command move_issued= false; stringCmdCount= 0; while (true) { if (net_message.readcount > net_message.cursize) { Com.Printf("SV_ReadClientMessage: bad read:\n"); Com.Printf(Lib.hexDump(net_message.data, 32, false)); SV_DropClient(cl); return; } c= MSG.ReadByte(net_message); if (c == -1) break; switch (c) { default : Com.Printf("SV_ReadClientMessage: unknown command char\n"); SV_DropClient(cl); return; case clc_nop : break; case clc_userinfo : cl.userinfo= MSG.ReadString(net_message); SV_MAIN.SV_UserinfoChanged(cl); break; case clc_move : if (move_issued) return; // someone is trying to cheat... move_issued= true; checksumIndex= net_message.readcount; checksum= MSG.ReadByte(net_message); lastframe= MSG.ReadLong(net_message); if (lastframe != cl.lastframe) { cl.lastframe= lastframe; if (cl.lastframe > 0) { cl.frame_latency[cl.lastframe & (LATENCY_COUNTS - 1)]= svs.realtime - cl.frames[cl.lastframe & UPDATE_MASK].senttime; } } //memset (nullcmd, 0, sizeof(nullcmd)); nullcmd= new usercmd_t(); MSG.ReadDeltaUsercmd(net_message, nullcmd, oldest); MSG.ReadDeltaUsercmd(net_message, oldest, oldcmd); MSG.ReadDeltaUsercmd(net_message, oldcmd, newcmd); if (cl.state != cs_spawned) { cl.lastframe= -1; break; } // if the checksum fails, ignore the rest of the packet calculatedChecksum= Com.BlockSequenceCRCByte( net_message.data, checksumIndex + 1, net_message.readcount - checksumIndex - 1, cl.netchan.incoming_sequence); if ((calculatedChecksum &0xff) != checksum) { Com.DPrintf( "Failed command checksum for " + cl.name + " (" + calculatedChecksum + " != " + checksum + ")/" + cl.netchan.incoming_sequence + "\n"); return; } if (0 == sv_paused.value) { net_drop= cl.netchan.dropped; if (net_drop < 20) { //if (net_drop > 2) // Com.Printf ("drop %i\n", net_drop); while (net_drop > 2) { SV_ClientThink(cl, cl.lastcmd); net_drop--; } if (net_drop > 1) SV_ClientThink(cl, oldest); if (net_drop > 0) SV_ClientThink(cl, oldcmd); } SV_ClientThink(cl, newcmd); } // copy. cl.lastcmd.set(newcmd); break; case clc_stringcmd : s= MSG.ReadString(net_message); // malicious users may try using too many string commands if (++stringCmdCount < MAX_STRINGCMDS) SV_ExecuteUserCommand(s); if (cl.state == cs_zombie) return; // disconnect command break; } } } }