]> de.git.xonotic.org Git - xonotic/darkplaces.git/blobdiff - host.c
major overhaul for thread-safety - many global variables and static
[xonotic/darkplaces.git] / host.c
diff --git a/host.c b/host.c
index cedb41b4a34c5a4b845f336153f4b06e06dc72df..88eed4bde5161cff7c3be4c527c15d4ad895397a 100644 (file)
--- a/host.c
+++ b/host.c
@@ -30,6 +30,7 @@ Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 #include "sv_demo.h"
 #include "snd_main.h"
 #include "thread.h"
+#include "utf8lib.h"
 
 /*
 
@@ -48,14 +49,15 @@ int host_framecount = 0;
 // LordHavoc: set when quit is executed
 qboolean host_shuttingdown = false;
 
-// the real time since application started, without any slowmo or clamping
+// the accumulated mainloop time since application started (with filtering), without any slowmo or clamping
 double realtime;
+// the main loop wall time for this frame
+double host_dirtytime;
 
 // current client
 client_t *host_client;
 
 jmp_buf host_abortframe;
-double host_starttime = 0;
 
 // pretend frames take this amount of time (in seconds), 0 = realtime
 cvar_t host_framerate = {0, "host_framerate","0", "locks frame timing to this value in seconds, 0.05 is 20fps for example, note that this can easily run too fast, use cl_maxfps if you want to limit your framerate instead, or sys_ticrate to limit server speed"};
@@ -104,8 +106,8 @@ This shuts down both the client and server
 */
 void Host_Error (const char *error, ...)
 {
-       static char hosterrorstring1[MAX_INPUTLINE];
-       static char hosterrorstring2[MAX_INPUTLINE];
+       static char hosterrorstring1[MAX_INPUTLINE]; // THREAD UNSAFE
+       static char hosterrorstring2[MAX_INPUTLINE]; // THREAD UNSAFE
        static qboolean hosterror = false;
        va_list argptr;
 
@@ -137,10 +139,17 @@ void Host_Error (const char *error, ...)
        //PR_Crash();
 
        // print out where the crash happened, if it was caused by QC (and do a cleanup)
-       PRVM_Crash();
+       PRVM_Crash(SVVM_prog);
+       PRVM_Crash(CLVM_prog);
+       PRVM_Crash(MVM_prog);
 
+       cl.csqc_loaded = false;
+       Cvar_SetValueQuick(&csqc_progcrc, -1);
+       Cvar_SetValueQuick(&csqc_progsize, -1);
 
+       SV_LockThreadMutex();
        Host_ShutdownServer ();
+       SV_UnlockThreadMutex();
 
        if (cls.state == ca_dedicated)
                Sys_Error ("Host_Error: %s",hosterrorstring2);  // dedicated servers exit
@@ -153,7 +162,7 @@ void Host_Error (const char *error, ...)
        Host_AbortCurrentFrame();
 }
 
-void Host_ServerOptions (void)
+static void Host_ServerOptions (void)
 {
        int i;
 
@@ -253,7 +262,7 @@ Host_SaveConfig_f
 Writes key bindings and archived cvars to config.cfg
 ===============
 */
-void Host_SaveConfig_to(const char *file)
+static void Host_SaveConfig_to(const char *file)
 {
        qfile_t *f;
 
@@ -291,7 +300,7 @@ void Host_SaveConfig_f(void)
        Host_SaveConfig_to(file);
 }
 
-void Host_AddConfigText(void)
+static void Host_AddConfigText(void)
 {
        // set up the default startmap_sp and startmap_dm aliases (mods can
        // override these) and then execute the quake.rc startup script
@@ -436,6 +445,7 @@ if (crash = true), don't bother sending signofs
 */
 void SV_DropClient(qboolean crash)
 {
+       prvm_prog_t *prog = SVVM_prog;
        int i;
        Con_Printf("Client \"%s\" dropped\n", host_client->name);
 
@@ -471,8 +481,9 @@ void SV_DropClient(qboolean crash)
                // this will set the body to a dead frame, among other things
                int saveSelf = PRVM_serverglobaledict(self);
                host_client->clientconnectcalled = false;
+               PRVM_serverglobalfloat(time) = sv.time;
                PRVM_serverglobaledict(self) = PRVM_EDICT_TO_PROG(host_client->edict);
-               PRVM_ExecuteProgram(PRVM_serverfunction(ClientDisconnect), "QC function ClientDisconnect is missing");
+               prog->ExecuteProgram(prog, PRVM_serverfunction(ClientDisconnect), "QC function ClientDisconnect is missing");
                PRVM_serverglobaledict(self) = saveSelf;
        }
 
@@ -522,7 +533,7 @@ void SV_DropClient(qboolean crash)
        if (sv.active)
        {
                // clear a fields that matter to DP_SV_CLIENTNAME and DP_SV_CLIENTCOLORS, and also frags
-               PRVM_ED_ClearEdict(host_client->edict);
+               PRVM_ED_ClearEdict(prog, host_client->edict);
        }
 
        // clear the client struct (this sets active to false)
@@ -554,6 +565,7 @@ This only happens at the end of a game, not between levels
 */
 void Host_ShutdownServer(void)
 {
+       prvm_prog_t *prog = SVVM_prog;
        int i;
 
        Con_DPrintf("Host_ShutdownServer\n");
@@ -565,19 +577,20 @@ void Host_ShutdownServer(void)
        NetConn_Heartbeat(2);
 
 // make sure all the clients know we're disconnecting
-       SV_VM_Begin();
        World_End(&sv.world);
        if(prog->loaded)
+       {
                if(PRVM_serverfunction(SV_Shutdown))
                {
                        func_t s = PRVM_serverfunction(SV_Shutdown);
+                       PRVM_serverglobalfloat(time) = sv.time;
                        PRVM_serverfunction(SV_Shutdown) = 0; // prevent it from getting called again
-                       PRVM_ExecuteProgram(s,"SV_Shutdown() required");
+                       prog->ExecuteProgram(prog, s,"SV_Shutdown() required");
                }
+       }
        for (i = 0, host_client = svs.clients;i < svs.maxclients;i++, host_client++)
                if (host_client->active)
                        SV_DropClient(false); // server shutdown
-       SV_VM_End();
 
        NetConn_CloseServerPorts();
 
@@ -587,6 +600,8 @@ void Host_ShutdownServer(void)
 //
        memset(&sv, 0, sizeof(sv));
        memset(svs.clients, 0, svs.maxclients*sizeof(client_t));
+
+       cl.islocalgame = false;
 }
 
 
@@ -599,7 +614,7 @@ Host_GetConsoleCommands
 Add them exactly as if they had been typed at the console
 ===================
 */
-void Host_GetConsoleCommands (void)
+static void Host_GetConsoleCommands (void)
 {
        char *cmd;
 
@@ -619,21 +634,34 @@ Host_TimeReport
 Returns a time report string, for example for
 ==================
 */
-const char *Host_TimingReport(void)
+const char *Host_TimingReport(char *buf, size_t buflen)
 {
-       return va("%.1f%% CPU, %.2f%% lost, offset avg %.1fms, max %.1fms, sdev %.1fms", svs.perf_cpuload * 100, svs.perf_lost * 100, svs.perf_offset_avg * 1000, svs.perf_offset_max * 1000, svs.perf_offset_sdev * 1000);
+       return va(buf, buflen, "%.1f%% CPU, %.2f%% lost, offset avg %.1fms, max %.1fms, sdev %.1fms", svs.perf_cpuload * 100, svs.perf_lost * 100, svs.perf_offset_avg * 1000, svs.perf_offset_max * 1000, svs.perf_offset_sdev * 1000);
 }
 
-void Host_Mingled(void)
+/*
+==================
+Host_Frame
+
+Runs all active servers
+==================
+*/
+static void Host_Init(void);
+void Host_Main(void)
 {
        double time1 = 0;
        double time2 = 0;
        double time3 = 0;
        double cl_timer = 0, sv_timer = 0;
-       double clframetime, deltarealtime, oldrealtime;
+       double clframetime, deltacleantime, olddirtytime, dirtytime;
        double wait;
        int pass1, pass2, pass3, i;
+       char vabuf[1024];
 
+       Host_Init();
+
+       realtime = 0;
+       dirtytime = Sys_DirtyTime();
        for (;;)
        {
                if (setjmp(host_abortframe))
@@ -642,39 +670,56 @@ void Host_Mingled(void)
                        continue;                       // something bad happened, or the server disconnected
                }
 
-               oldrealtime = realtime;
-               realtime = Sys_DoubleTime();
-
-               deltarealtime = realtime - oldrealtime;
-               cl_timer += deltarealtime;
-               sv_timer += deltarealtime;
-
-               svs.perf_acc_realtime += deltarealtime;
-
-               // Look for clients who have spawned
-               for (i = 0, host_client = svs.clients;i < svs.maxclients;i++, host_client++)
-                       if(host_client->spawned)
-                               if(host_client->netconnection)
-                                       break;
-               if(i == svs.maxclients)
+               olddirtytime = host_dirtytime;
+               dirtytime = Sys_DirtyTime();
+               deltacleantime = dirtytime - olddirtytime;
+               if (deltacleantime < 0)
+               {
+                       // warn if it's significant
+                       if (deltacleantime < -0.01)
+                               Con_Printf("Host_Mingled: time stepped backwards (went from %f to %f, difference %f)\n", olddirtytime, dirtytime, deltacleantime);
+                       deltacleantime = 0;
+               }
+               else if (deltacleantime >= 1800)
                {
-                       // Nobody is looking? Then we won't do timing...
-                       // Instead, reset it to zero
-                       svs.perf_acc_realtime = svs.perf_acc_sleeptime = svs.perf_acc_lost = svs.perf_acc_offset = svs.perf_acc_offset_squared = svs.perf_acc_offset_max = svs.perf_acc_offset_samples = 0;
+                       Con_Printf("Host_Mingled: time stepped forward (went from %f to %f, difference %f)\n", olddirtytime, dirtytime, deltacleantime);
+                       deltacleantime = 0;
                }
-               else if(svs.perf_acc_realtime > 5)
+               realtime += deltacleantime;
+               host_dirtytime = dirtytime;
+
+               cl_timer += deltacleantime;
+               sv_timer += deltacleantime;
+
+               if (!svs.threaded)
                {
-                       svs.perf_cpuload = 1 - svs.perf_acc_sleeptime / svs.perf_acc_realtime;
-                       svs.perf_lost = svs.perf_acc_lost / svs.perf_acc_realtime;
-                       if(svs.perf_acc_offset_samples > 0)
+                       svs.perf_acc_realtime += deltacleantime;
+
+                       // Look for clients who have spawned
+                       for (i = 0, host_client = svs.clients;i < svs.maxclients;i++, host_client++)
+                               if(host_client->spawned)
+                                       if(host_client->netconnection)
+                                               break;
+                       if(i == svs.maxclients)
+                       {
+                               // Nobody is looking? Then we won't do timing...
+                               // Instead, reset it to zero
+                               svs.perf_acc_realtime = svs.perf_acc_sleeptime = svs.perf_acc_lost = svs.perf_acc_offset = svs.perf_acc_offset_squared = svs.perf_acc_offset_max = svs.perf_acc_offset_samples = 0;
+                       }
+                       else if(svs.perf_acc_realtime > 5)
                        {
-                               svs.perf_offset_max = svs.perf_acc_offset_max;
-                               svs.perf_offset_avg = svs.perf_acc_offset / svs.perf_acc_offset_samples;
-                               svs.perf_offset_sdev = sqrt(svs.perf_acc_offset_squared / svs.perf_acc_offset_samples - svs.perf_offset_avg * svs.perf_offset_avg);
+                               svs.perf_cpuload = 1 - svs.perf_acc_sleeptime / svs.perf_acc_realtime;
+                               svs.perf_lost = svs.perf_acc_lost / svs.perf_acc_realtime;
+                               if(svs.perf_acc_offset_samples > 0)
+                               {
+                                       svs.perf_offset_max = svs.perf_acc_offset_max;
+                                       svs.perf_offset_avg = svs.perf_acc_offset / svs.perf_acc_offset_samples;
+                                       svs.perf_offset_sdev = sqrt(svs.perf_acc_offset_squared / svs.perf_acc_offset_samples - svs.perf_offset_avg * svs.perf_offset_avg);
+                               }
+                               if(svs.perf_lost > 0 && developer_extra.integer)
+                                       Con_DPrintf("Server can't keep up: %s\n", Host_TimingReport(vabuf, sizeof(vabuf)));
+                               svs.perf_acc_realtime = svs.perf_acc_sleeptime = svs.perf_acc_lost = svs.perf_acc_offset = svs.perf_acc_offset_squared = svs.perf_acc_offset_max = svs.perf_acc_offset_samples = 0;
                        }
-                       if(svs.perf_lost > 0 && developer_extra.integer)
-                               Con_DPrintf("Server can't keep up: %s\n", Host_TimingReport());
-                       svs.perf_acc_realtime = svs.perf_acc_sleeptime = svs.perf_acc_lost = svs.perf_acc_offset = svs.perf_acc_offset_squared = svs.perf_acc_offset_max = svs.perf_acc_offset_samples = 0;
                }
 
                if (slowmo.value < 0.00001 && slowmo.value != 0)
@@ -686,8 +731,6 @@ void Host_Mingled(void)
                if(!*sv_random_seed.string && !cls.demoplayback)
                        rand();
 
-               cl.islocalgame = NetConn_IsLocalGame();
-
                // get new key events
                Key_EventQueue_Unblock();
                SndSys_SendKeyEvents();
@@ -699,7 +742,7 @@ void Host_Mingled(void)
 
                // receive packets on each main loop iteration, as the main loop may
                // be undersleeping due to select() detecting a new packet
-               if (sv.active)
+               if (sv.active && !svs.threaded)
                        NetConn_ServerFrame();
 
                Curl_Run();
@@ -724,14 +767,14 @@ void Host_Mingled(void)
                // if the accumulators haven't become positive yet, wait a while
                if (cls.state == ca_dedicated)
                        wait = sv_timer * -1000000.0;
-               else if (!sv.active)
+               else if (!sv.active || svs.threaded)
                        wait = cl_timer * -1000000.0;
                else
                        wait = max(cl_timer, sv_timer) * -1000000.0;
 
                if (!cls.timedemo && wait >= 1)
                {
-                       double time0;
+                       double time0, delta;
 
                        if(host_maxwait.value <= 0)
                                wait = min(wait, 1000000.0);
@@ -740,12 +783,15 @@ void Host_Mingled(void)
                        if(wait < 1)
                                wait = 1; // because we cast to int
 
-                       time0 = Sys_DoubleTime();
-                       if (sv_checkforpacketsduringsleep.integer && !sys_usenoclockbutbenchmark.integer)
+                       time0 = Sys_DirtyTime();
+                       if (sv_checkforpacketsduringsleep.integer && !sys_usenoclockbutbenchmark.integer && !svs.threaded)
                                NetConn_SleepMicroseconds((int)wait);
                        else
                                Sys_Sleep((int)wait);
-                       svs.perf_acc_sleeptime += Sys_DoubleTime() - time0;
+                       delta = Sys_DirtyTime() - time0;
+                       if (delta < 0 || delta >= 1800) delta = 0;
+                       if (!svs.threaded)
+                               svs.perf_acc_sleeptime += delta;
 //                     R_TimeReport("sleep");
                        continue;
                }
@@ -753,6 +799,12 @@ void Host_Mingled(void)
                // limit the frametime steps to no more than 100ms each
                if (cl_timer > 0.1)
                        cl_timer = 0.1;
+               if (sv_timer > 0.1)
+               {
+                       if (!svs.threaded)
+                               svs.perf_acc_lost += (sv_timer - 0.1);
+                       sv_timer = 0.1;
+               }
 
                R_TimeReport("---");
 
@@ -763,13 +815,7 @@ void Host_Mingled(void)
        //-------------------
 
                // limit the frametime steps to no more than 100ms each
-               if (sv_timer > 0.1)
-               {
-                       svs.perf_acc_lost += (sv_timer - 0.1);
-                       sv_timer = 0.1;
-               }
-
-               if (sv.active && sv_timer > 0)
+               if (sv.active && sv_timer > 0 && !svs.threaded)
                {
                        // execute one or more server frames, with an upper limit on how much
                        // execution time to spend on server frames to avoid freezing the game if
@@ -778,9 +824,7 @@ void Host_Mingled(void)
                        int framecount, framelimit = 1;
                        double advancetime, aborttime = 0;
                        float offset;
-
-                       if (cls.state == ca_dedicated)
-                               Collision_Cache_NewFrame();
+                       prvm_prog_t *prog = SVVM_prog;
 
                        // run the world state
                        // don't allow simulation to run too fast or too slow or logic glitches can occur
@@ -812,7 +856,8 @@ void Host_Mingled(void)
 
                        if(advancetime > 0)
                        {
-                               offset = sv_timer + (Sys_DoubleTime() - realtime);
+                               offset = Sys_DirtyTime() - realtime;if (offset < 0 || offset >= 1800) offset = 0;
+                               offset += sv_timer;
                                ++svs.perf_acc_offset_samples;
                                svs.perf_acc_offset += offset;
                                svs.perf_acc_offset_squared += offset * offset;
@@ -828,9 +873,6 @@ void Host_Mingled(void)
                        if (sv.paused || (cl.islocalgame && (key_dest != key_game || key_consoleactive || cl.csqc_paused)))
                                sv.frametime = 0;
 
-                       // setup the VM frame
-                       SV_VM_Begin();
-
                        for (framecount = 0;framecount < framelimit && sv_timer > 0;framecount++)
                        {
                                sv_timer -= advancetime;
@@ -840,27 +882,25 @@ void Host_Mingled(void)
                                        SV_Physics();
 
                                // if this server frame took too long, break out of the loop
-                               if (framelimit > 1 && Sys_DoubleTime() >= aborttime)
+                               if (framelimit > 1 && Sys_DirtyTime() >= aborttime)
                                        break;
                        }
                        R_TimeReport("serverphysics");
 
                        // send all messages to the clients
                        SV_SendClientMessages();
-                       
+
                        if (sv.paused == 1 && realtime > sv.pausedstart && sv.pausedstart > 0) {
                                prog->globals.generic[OFS_PARM0] = realtime - sv.pausedstart;
-                               PRVM_ExecuteProgram(PRVM_serverfunction(SV_PausedTic), "QC function SV_PausedTic is missing");
+                               PRVM_serverglobalfloat(time) = sv.time;
+                               prog->ExecuteProgram(prog, PRVM_serverfunction(SV_PausedTic), "QC function SV_PausedTic is missing");
                        }
 
-                       // end the server VM frame
-                       SV_VM_End();
-
                        // send an heartbeat if enough time has passed since the last one
                        NetConn_Heartbeat(0);
                        R_TimeReport("servernetwork");
                }
-               else
+               else if (!svs.threaded)
                {
                        // don't let r_speeds display jump around
                        R_TimeReport("serverphysics");
@@ -932,7 +972,7 @@ void Host_Mingled(void)
 
                        // update video
                        if (host_speeds.integer)
-                               time1 = Sys_DoubleTime();
+                               time1 = Sys_DirtyTime();
                        R_TimeReport("pre-input");
 
                        // Collect input into cmd
@@ -963,7 +1003,7 @@ void Host_Mingled(void)
                        R_TimeReport("render");
 
                        if (host_speeds.integer)
-                               time2 = Sys_DoubleTime();
+                               time2 = Sys_DirtyTime();
 
                        // update audio
                        if(cl.csqc_usecsqclistener)
@@ -983,7 +1023,7 @@ void Host_Mingled(void)
                        if (host_speeds.integer)
                        {
                                pass1 = (int)((time1 - time3)*1000000);
-                               time3 = Sys_DoubleTime();
+                               time3 = Sys_DirtyTime();
                                pass2 = (int)((time2 - time1)*1000000);
                                pass3 = (int)((time3 - time2)*1000000);
                                Con_Printf("%6ius total %6ius server %6ius gfx %6ius snd\n",
@@ -1003,7 +1043,8 @@ void Host_Mingled(void)
                        cl_timer = 0;
                if (sv_timer >= 0)
                {
-                       svs.perf_acc_lost += sv_timer;
+                       if (!svs.threaded)
+                               svs.perf_acc_lost += sv_timer;
                        sv_timer = 0;
                }
 
@@ -1011,242 +1052,6 @@ void Host_Mingled(void)
        }
 }
 
-void Host_Threaded(void)
-{
-       double time1 = 0;
-       double time2 = 0;
-       double time3 = 0;
-       double cl_timer = 0;
-       double clframetime, deltarealtime, oldrealtime;
-       double wait;
-       int pass1, pass2, pass3;
-
-       for (;;)
-       {
-               if (setjmp(host_abortframe))
-               {
-                       SCR_ClearLoadingScreen(false);
-                       continue;                       // something bad happened, or the server disconnected
-               }
-
-               oldrealtime = realtime;
-               realtime = Sys_DoubleTime();
-
-               deltarealtime = realtime - oldrealtime;
-               cl_timer += deltarealtime;
-
-               if (slowmo.value < 0.00001 && slowmo.value != 0)
-                       Cvar_SetValue("slowmo", 0);
-               if (host_framerate.value < 0.00001 && host_framerate.value != 0)
-                       Cvar_SetValue("host_framerate", 0);
-
-               // keep the random time dependent, but not when playing demos/benchmarking
-               if(!*sv_random_seed.string && !cls.demoplayback)
-                       rand();
-
-               cl.islocalgame = NetConn_IsLocalGame();
-
-               // get new key events
-               Key_EventQueue_Unblock();
-               SndSys_SendKeyEvents();
-               Sys_SendKeyEvents();
-
-               NetConn_UpdateSockets();
-
-               Log_DestBuffer_Flush();
-
-               Curl_Run();
-
-               // check for commands typed to the host
-               Host_GetConsoleCommands();
-
-               // process console commands
-//             R_TimeReport("preconsole");
-               CL_VM_PreventInformationLeaks();
-               Cbuf_Execute();
-//             R_TimeReport("console");
-
-               //Con_Printf("%6.0f %6.0f\n", cl_timer * 1000000.0, sv_timer * 1000000.0);
-
-               // if the accumulators haven't become positive yet, wait a while
-               wait = cl_timer * -1000000.0;
-
-               if (!cls.timedemo && wait >= 1)
-               {
-                       double time0;
-
-                       if(host_maxwait.value <= 0)
-                               wait = min(wait, 1000000.0);
-                       else
-                               wait = min(wait, host_maxwait.value * 1000.0);
-                       if(wait < 1)
-                               wait = 1; // because we cast to int
-
-                       time0 = Sys_DoubleTime();
-                       Sys_Sleep((int)wait);
-//                     R_TimeReport("sleep");
-                       continue;
-               }
-
-               // limit the frametime steps to no more than 100ms each
-               if (cl_timer > 0.1)
-                       cl_timer = 0.1;
-
-               R_TimeReport("---");
-
-               if (cl_timer > 0 || cls.timedemo || ((vid_activewindow ? cl_maxfps : cl_maxidlefps).value < 1))
-               {
-                       R_TimeReport("---");
-                       Collision_Cache_NewFrame();
-                       R_TimeReport("collisioncache");
-                       // decide the simulation time
-                       if (cls.capturevideo.active)
-                       {
-                               //***
-                               if (cls.capturevideo.realtime)
-                                       clframetime = cl.realframetime = max(cl_timer, 1.0 / cls.capturevideo.framerate);
-                               else
-                               {
-                                       clframetime = 1.0 / cls.capturevideo.framerate;
-                                       cl.realframetime = max(cl_timer, clframetime);
-                               }
-                       }
-                       else if (vid_activewindow && cl_maxfps.value >= 1 && !cls.timedemo)
-                       {
-                               clframetime = cl.realframetime = max(cl_timer, 1.0 / cl_maxfps.value);
-                               // when running slow, we need to sleep to keep input responsive
-                               wait = bound(0, cl_maxfps_alwayssleep.value * 1000, 100000);
-                               if (wait > 0)
-                                       Sys_Sleep((int)wait);
-                       }
-                       else if (!vid_activewindow && cl_maxidlefps.value >= 1 && !cls.timedemo)
-                               clframetime = cl.realframetime = max(cl_timer, 1.0 / cl_maxidlefps.value);
-                       else
-                               clframetime = cl.realframetime = cl_timer;
-
-                       // apply slowmo scaling
-                       clframetime *= cl.movevars_timescale;
-                       // scale playback speed of demos by slowmo cvar
-                       if (cls.demoplayback)
-                       {
-                               clframetime *= slowmo.value;
-                               // if demo playback is paused, don't advance time at all
-                               if (cls.demopaused)
-                                       clframetime = 0;
-                       }
-
-                       // host_framerate overrides all else
-                       if (host_framerate.value)
-                               clframetime = host_framerate.value;
-
-                       if (cl.paused || (cl.islocalgame && (key_dest != key_game || key_consoleactive || cl.csqc_paused)))
-                               clframetime = 0;
-
-                       if (cls.timedemo)
-                               clframetime = cl.realframetime = cl_timer;
-
-                       // deduct the frame time from the accumulator
-                       cl_timer -= cl.realframetime;
-
-                       cl.oldtime = cl.time;
-                       cl.time += clframetime;
-
-                       // update video
-                       if (host_speeds.integer)
-                               time1 = Sys_DoubleTime();
-                       R_TimeReport("pre-input");
-
-                       // Collect input into cmd
-                       CL_Input();
-
-                       R_TimeReport("input");
-
-                       // check for new packets
-                       NetConn_ClientFrame();
-
-                       // read a new frame from a demo if needed
-                       CL_ReadDemoMessage();
-                       R_TimeReport("clientnetwork");
-
-                       // now that packets have been read, send input to server
-                       CL_SendMove();
-                       R_TimeReport("sendmove");
-
-                       // update client world (interpolate entities, create trails, etc)
-                       CL_UpdateWorld();
-                       R_TimeReport("lerpworld");
-
-                       CL_Video_Frame();
-
-                       R_TimeReport("client");
-
-                       CL_UpdateScreen();
-                       R_TimeReport("render");
-
-                       if (host_speeds.integer)
-                               time2 = Sys_DoubleTime();
-
-                       // update audio
-                       if(cl.csqc_usecsqclistener)
-                       {
-                               S_Update(&cl.csqc_listenermatrix);
-                               cl.csqc_usecsqclistener = false;
-                       }
-                       else
-                               S_Update(&r_refdef.view.matrix);
-
-                       CDAudio_Update();
-                       R_TimeReport("audio");
-
-                       // reset gathering of mouse input
-                       in_mouse_x = in_mouse_y = 0;
-
-                       if (host_speeds.integer)
-                       {
-                               pass1 = (int)((time1 - time3)*1000000);
-                               time3 = Sys_DoubleTime();
-                               pass2 = (int)((time2 - time1)*1000000);
-                               pass3 = (int)((time3 - time2)*1000000);
-                               Con_Printf("%6ius total %6ius other %6ius gfx %6ius snd\n",
-                                                       pass1+pass2+pass3, pass1, pass2, pass3);
-                       }
-               }
-
-#if MEMPARANOIA
-               Mem_CheckSentinelsGlobal();
-#else
-               if (developer_memorydebug.integer)
-                       Mem_CheckSentinelsGlobal();
-#endif
-
-               // if there is some time remaining from this frame, reset the timers
-               if (cl_timer >= 0)
-                       cl_timer = 0;
-
-               host_framecount++;
-       }
-}
-
-/*
-==================
-Host_Frame
-
-Runs all active servers
-==================
-*/
-static void Host_Init(void);
-void Host_Main(void)
-{
-       Host_Init();
-
-       realtime = host_starttime = Sys_DoubleTime();
-
-       if (svs.threaded)
-               Host_Threaded();
-       else
-               Host_Mingled();
-}
-
 //============================================================================
 
 qboolean vid_opened = false;
@@ -1266,15 +1071,6 @@ char engineversion[128];
 
 qboolean sys_nostdout = false;
 
-extern void u8_Init(void);
-extern void Render_Init(void);
-extern void Mathlib_Init(void);
-extern void FS_Init_SelfPack(void);
-extern void FS_Init(void);
-extern void FS_Shutdown(void);
-extern void PR_Cmd_Init(void);
-extern void COM_Init_Commands(void);
-extern void FS_Init_Commands(void);
 extern qboolean host_stuffcmdsrun;
 
 /*
@@ -1286,6 +1082,7 @@ static void Host_Init (void)
 {
        int i;
        const char* os;
+       char vabuf[1024];
 
        if (COM_CheckParm("-profilegameonly"))
                Sys_AllowProfiling(false);
@@ -1443,7 +1240,7 @@ static void Host_Init (void)
        if (i && i + 1 < com_argc)
        if (!sv.active && !cls.demoplayback && !cls.connect_trying)
        {
-               Cbuf_AddText(va("timedemo %s\n", com_argv[i + 1]));
+               Cbuf_AddText(va(vabuf, sizeof(vabuf), "timedemo %s\n", com_argv[i + 1]));
                Cbuf_Execute();
        }
 
@@ -1453,7 +1250,7 @@ static void Host_Init (void)
        if (i && i + 1 < com_argc)
        if (!sv.active && !cls.demoplayback && !cls.connect_trying)
        {
-               Cbuf_AddText(va("playdemo %s\n", com_argv[i + 1]));
+               Cbuf_AddText(va(vabuf, sizeof(vabuf), "playdemo %s\n", com_argv[i + 1]));
                Cbuf_Execute();
        }
 
@@ -1462,7 +1259,7 @@ static void Host_Init (void)
        if (i && i + 1 < com_argc)
        if (!sv.active && !cls.demoplayback && !cls.connect_trying)
        {
-               Cbuf_AddText(va("playdemo %s\ncl_capturevideo 1\n", com_argv[i + 1]));
+               Cbuf_AddText(va(vabuf, sizeof(vabuf), "playdemo %s\ncl_capturevideo 1\n", com_argv[i + 1]));
                Cbuf_Execute();
        }
 
@@ -1519,7 +1316,13 @@ void Host_Shutdown(void)
        CL_Disconnect();
 
        // shut down local server if active
+       SV_LockThreadMutex();
        Host_ShutdownServer ();
+       SV_UnlockThreadMutex();
+
+       // end the server thread
+       if (svs.threaded)
+               SV_StopThread();
 
        // Shutdown menu
        if(MR_Shutdown)