//------------------------------------------------------------------------- /* Copyright (C) 2010 EDuke32 developers and contributors This file is part of EDuke32. EDuke32 is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License version 2 as published by the Free Software Foundation. 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. */ //------------------------------------------------------------------------- #include "ns.h" // Must come before everything else! #include "demo.h" #include "duke3d.h" #include "input.h" #include "menus.h" #include "savegame.h" #include "screens.h" #include "i_specialpaths.h" #include "vfs.h" BEGIN_DUKE_NS char g_firstDemoFile[BMAX_PATH]; buildvfs_FILE g_demo_filePtr{}; // write FileReader g_demo_recFilePtr; // read int32_t g_demo_cnt; int32_t g_demo_goalCnt=0; int32_t g_demo_totalCnt; int32_t g_demo_paused=0; int32_t g_demo_rewind=0; int32_t g_demo_showStats=1; static int32_t g_demo_soundToggle; static int32_t demo_hasdiffs, demorec_diffs=1, demorec_difftics = 2*REALGAMETICSPERSEC; int32_t demoplay_diffs=1; static int32_t demo_synccompress=1, demorec_seeds=1, demo_hasseeds; static void Demo_RestoreModes(int32_t menu) { if (menu) Menu_Open(myconnectindex); else Menu_Close(myconnectindex); g_player[myconnectindex].ps->gm &= ~MODE_GAME; g_player[myconnectindex].ps->gm |= MODE_DEMO; } // This is utterly gross. Global configuration should not be manipulated like this. void Demo_PrepareWarp(void) { if (!g_demo_paused) { g_demo_soundToggle = userConfig.nosound; userConfig.nosound = true; } FX_StopAllSounds(); S_ClearSoundLocks(); } static int32_t G_OpenDemoRead(int32_t g_whichDemo) // 0 = mine { int32_t i; savehead_t saveh; char demofn[14]; const char *demofnptr; if (g_whichDemo == 1 && g_firstDemoFile[0]) { demofnptr = g_firstDemoFile; } else { Bsprintf(demofn, DEMOFN_FMT, g_whichDemo); demofnptr = demofn; } g_demo_recFilePtr = fopenFileReader(demofnptr, g_loadFromGroupOnly); if (!g_demo_recFilePtr.isOpen()) return 0; Bassert(g_whichDemo >= 1); i = sv_loadsnapshot(g_demo_recFilePtr, -g_whichDemo, &saveh); if (i) { OSD_Printf(OSD_ERROR "There were errors opening demo %d (code: %d).\n", g_whichDemo, i); g_demo_recFilePtr.Close(); return 0; } demo_hasdiffs = saveh.recdiffsp; g_demo_totalCnt = saveh.reccnt; demo_synccompress = saveh.synccompress; demo_hasseeds = demo_synccompress&2; demo_synccompress &= 1; i = g_demo_totalCnt/REALGAMETICSPERSEC; OSD_Printf("demo %d duration: %d min %d sec\n", g_whichDemo, i/60, i%60); g_demo_cnt = 1; ud.reccnt = 0; ud.god = ud.cashman = ud.eog = ud.showallmap = 0; ud.noclip = ud.scrollmode = ud.overhead_on = 0; //= ud.pause_on = 0; totalclock = ototalclock = lockclock = 0; return 1; } #if KRANDDEBUG extern void krd_enable(int32_t which); extern int32_t krd_print(const char *filename); #endif void G_OpenDemoWrite(void) { char demofn[BMAX_PATH]; int32_t i, demonum=1; if (ud.recstat == 2) { g_demo_recFilePtr.Close(); } if ((g_player[myconnectindex].ps->gm&MODE_GAME) && g_player[myconnectindex].ps->dead_flag) { Bstrcpy(apStrings[QUOTE_RESERVED4], "CANNOT START DEMO RECORDING WHEN DEAD!"); P_DoQuote(QUOTE_RESERVED4, g_player[myconnectindex].ps); ud.recstat = ud.m_recstat = 0; return; } do { if (demonum == MAXDEMOS) return; if (snprintf(demofn, sizeof(demofn), "%s" DEMOFN_FMT, M_GetDemoPath().GetChars(), demonum)) { initprintf("Couldn't start demo writing: INTERNAL ERROR: file name too long\n"); goto error_wopen_demo; } demonum++; g_demo_filePtr = buildvfs_fopen_read(demofn); if (g_demo_filePtr == NULL) break; MAYBE_FCLOSE_AND_NULL(g_demo_filePtr); } while (1); g_demo_filePtr = buildvfs_fopen_write(demofn); if (g_demo_filePtr == NULL) return; i=sv_saveandmakesnapshot(g_demo_filePtr, nullptr, -1, demorec_diffs_cvar, demorec_diffcompress_cvar, demorec_synccompress_cvar|(demorec_seeds_cvar<<1)); if (i) { MAYBE_FCLOSE_AND_NULL(g_demo_filePtr); error_wopen_demo: Bstrcpy(apStrings[QUOTE_RESERVED4], "FAILED STARTING DEMO RECORDING. SEE OSD FOR DETAILS."); P_DoQuote(QUOTE_RESERVED4, g_player[myconnectindex].ps); ud.recstat = ud.m_recstat = 0; return; } demorec_seeds = demorec_seeds_cvar; demorec_diffs = demorec_diffs_cvar; demo_synccompress = demorec_synccompress_cvar; demorec_difftics = demorec_difftics_cvar; Bsprintf(apStrings[QUOTE_RESERVED4], "DEMO %d RECORDING STARTED", demonum-1); P_DoQuote(QUOTE_RESERVED4, g_player[myconnectindex].ps); ud.reccnt = 0; ud.recstat = ud.m_recstat = 1; // # if KRANDDEBUG krd_enable(1); # endif g_demo_cnt = 1; } // demo_profile: < 0: prepare static int32_t g_demo_playFirstFlag, g_demo_profile, g_demo_stopProfile; static int32_t g_demo_exitAfter; void Demo_PlayFirst(int32_t prof, int32_t exitafter) { g_demo_playFirstFlag = 1; g_demo_exitAfter = exitafter; Bassert(prof >= 0); g_demo_profile = -prof; // prepare } void Demo_SetFirst(const char *demostr) { char *tailptr; int32_t i = Bstrtol(demostr, &tailptr, 10); if (tailptr==demostr+Bstrlen(demostr) && (unsigned)i < MAXDEMOS) // demo number passed Bsprintf(g_firstDemoFile, DEMOFN_FMT, i); else // demo file name passed maybe_append_ext(g_firstDemoFile, sizeof(g_firstDemoFile), demostr, ".edm"); } static uint8_t g_demo_seedbuf[RECSYNCBUFSIZ]; static void Demo_WriteSync() { int16_t tmpreccnt; buildvfs_fwrite("sYnC", 4, 1, g_demo_filePtr); tmpreccnt = (int16_t)ud.reccnt; buildvfs_fwrite(&tmpreccnt, sizeof(int16_t), 1, g_demo_filePtr); if (demorec_seeds) buildvfs_fwrite(g_demo_seedbuf, 1, ud.reccnt, g_demo_filePtr); if (demo_synccompress) dfwrite_LZ4(recsync, sizeof(input_t), ud.reccnt, g_demo_filePtr); else //if (demo_synccompress==0) buildvfs_fwrite(recsync, sizeof(input_t), ud.reccnt, g_demo_filePtr); ud.reccnt = 0; } void G_DemoRecord(void) { int16_t i; g_demo_cnt++; if (demorec_diffs && (g_demo_cnt%demorec_difftics == 1)) { sv_writediff(g_demo_filePtr); demorec_difftics = demorec_difftics_cvar; } if (demorec_seeds) g_demo_seedbuf[ud.reccnt] = (uint8_t)(randomseed>>24); for (TRAVERSE_CONNECT(i)) { Bmemcpy(&recsync[ud.reccnt], g_player[i].input, sizeof(input_t)); ud.reccnt++; } if (ud.reccnt > RECSYNCBUFSIZ-MAXPLAYERS || (demorec_diffs && (g_demo_cnt%demorec_difftics == 0))) Demo_WriteSync(); } void G_CloseDemoWrite(void) { if (ud.recstat == 1) { if (ud.reccnt > 0) Demo_WriteSync(); buildvfs_fwrite("EnD!", 4, 1, g_demo_filePtr); // lastly, we need to write the number of written recsyncs to the demo file if (buildvfs_fseek_abs(g_demo_filePtr, offsetof(savehead_t, reccnt))) perror("G_CloseDemoWrite: final fseek"); else buildvfs_fwrite(&g_demo_cnt, sizeof(g_demo_cnt), 1, g_demo_filePtr); ud.recstat = ud.m_recstat = 0; MAYBE_FCLOSE_AND_NULL(g_demo_filePtr); sv_freemem(); Bstrcpy(apStrings[QUOTE_RESERVED4], "DEMO RECORDING STOPPED"); P_DoQuote(QUOTE_RESERVED4, g_player[myconnectindex].ps); } #if KRANDDEBUG krd_print("krandrec.log"); #endif } static int32_t g_whichDemo = 1; static int32_t Demo_UpdateState(int32_t frominit) { int32_t j = g_player[myconnectindex].ps->gm&MODE_MENU; int32_t k = sv_updatestate(frominit); // tmpdifftime = g_demo_cnt+12; Demo_RestoreModes(j); if (k) OSD_Printf("sv_updatestate() returned %d.\n", k); return k; } #define CORRUPT(code) do { corruptcode=code; goto corrupt; } while(0) static int32_t Demo_ReadSync(int32_t errcode) { uint16_t si; int32_t i; if (g_demo_recFilePtr.Read(&si, sizeof(uint16_t)) != sizeof(uint16_t)) return errcode; i = si; if (demo_hasseeds) { if (g_demo_recFilePtr.Read(g_demo_seedbuf, i) != i) return errcode; } if (demo_synccompress) { if (kdfread_LZ4(recsync, sizeof(input_t), i, g_demo_recFilePtr) != i) return errcode+1; } else { int32_t bytes = sizeof(input_t)*i; if (g_demo_recFilePtr.Read(recsync, bytes) != bytes) return errcode+2; } ud.reccnt = i; return 0; } ////////// DEMO PROFILING (TIMEDEMO MODE) ////////// static struct { int32_t numtics, numframes; double totalgamems; double totalroomsdrawms, totalrestdrawms; double starthiticks; } g_prof; int32_t Demo_IsProfiling(void) { return (g_demo_profile > 0); } static void Demo_StopProfiling(void) { g_demo_stopProfile = 1; } static void Demo_GToc(double t) { g_prof.numtics++; g_prof.totalgamems += timerGetHiTicks()-t; } static void Demo_RToc(double t1, double t2) { g_prof.numframes++; g_prof.totalroomsdrawms += t2-t1; g_prof.totalrestdrawms += timerGetHiTicks()-t2; } static void Demo_DisplayProfStatus(void) { char buf[64]; static int32_t lastpercent=-1; int32_t percent = (100*g_demo_cnt)/g_demo_totalCnt; if (lastpercent == percent) return; lastpercent = percent; videoClearScreen(0); Bsnprintf(buf, sizeof(buf), "timing... %d/%d game tics (%d %%)", g_demo_cnt, g_demo_totalCnt, percent); gametext_center(60, buf); videoNextPage(); } static void Demo_SetupProfile(void) { g_demo_profile *= -1; // now >0: profile for real g_demo_soundToggle = userConfig.nosound; userConfig.nosound = true; // restored by Demo_FinishProfile() Bmemset(&g_prof, 0, sizeof(g_prof)); g_prof.starthiticks = timerGetHiTicks(); } static void Demo_FinishProfile(void) { if (Demo_IsProfiling()) { int32_t dn=g_whichDemo-1; int32_t nt=g_prof.numtics, nf=g_prof.numframes; double gms=g_prof.totalgamems; double dms1=g_prof.totalroomsdrawms, dms2=g_prof.totalrestdrawms; userConfig.nosound = g_demo_soundToggle; if (nt > 0) { OSD_Printf("== demo %d: %d gametics\n", dn, nt); OSD_Printf("== demo %d game times: %.03f ms (%.03f us/gametic)\n", dn, gms, (gms*1000.0)/nt); } if (nf > 0) { OSD_Printf("== demo %d: %d frames (%d frames/gametic)\n", dn, nf, g_demo_profile-1); OSD_Printf("== demo %d drawrooms times: %.03f s (%.03f ms/frame)\n", dn, dms1/1000.0, dms1/nf); OSD_Printf("== demo %d drawrest times: %.03f s (%.03f ms/frame)\n", dn, dms2/1000.0, dms2/nf); } { double totalprofms = gms+dms1+dms2; double totalms = timerGetHiTicks()-g_prof.starthiticks; if (totalprofms != 0) OSD_Printf("== demo %d: non-profiled time overhead: %.02f %%\n", dn, 100.0*totalms/totalprofms - 100.0); } } g_demo_profile = 0; g_demo_stopProfile = 0; } //////////////////// int32_t G_PlaybackDemo(void) { int32_t bigi, j, initsyncofs = 0, lastsyncofs = 0, lastsynctic = 0, lastsyncclock = 0; int32_t foundemo = 0, corruptcode, outofsync=0; static int32_t in_menu = 0; // static int32_t tmpdifftime=0; totalclock = 0; ototalclock = 0; lockclock = 0; if (ready2send) return 0; if (!g_demo_playFirstFlag) g_demo_profile = 0; RECHECK: if (g_demo_playFirstFlag) g_demo_playFirstFlag = 0; else if (g_demo_exitAfter) G_GameExit(" "); #if KRANDDEBUG if (foundemo) krd_print("krandplay.log"); #endif in_menu = g_player[myconnectindex].ps->gm&MODE_MENU; pub = NUMPAGES; pus = NUMPAGES; renderFlushPerms(); #ifdef PLAYDEMOLOOP // Todo: Make a CVar. if (!g_netServer && ud.multimode < 2) foundemo = G_OpenDemoRead(g_whichDemo); #endif if (foundemo == 0) { ud.recstat = 0; if (g_whichDemo > 1) { g_whichDemo = 1; goto RECHECK; } fadepal(0,0,0, 0,252,28); P_SetGamePalette(g_player[myconnectindex].ps, BASEPAL, 1); // JBF 20040308 G_DrawBackground(); M_DisplayMenus(); videoNextPage(); fadepal(0,0,0, 252,0,-28); ud.reccnt = 0; } else { ud.recstat = 2; g_whichDemo++; if (g_whichDemo == MAXDEMOS) g_whichDemo = 1; g_player[myconnectindex].ps->gm &= ~MODE_GAME; g_player[myconnectindex].ps->gm |= MODE_DEMO; lastsyncofs = g_demo_recFilePtr.Tell(); initsyncofs = lastsyncofs; lastsynctic = g_demo_cnt; lastsyncclock = (int32_t) totalclock; outofsync = 0; #if KRANDDEBUG krd_enable(2); #endif if (g_demo_profile < 0) { Demo_SetupProfile(); } } if (foundemo == 0 || in_menu || I_CheckAllInput() || numplayers > 1) { FX_StopAllSounds(); S_ClearSoundLocks(); Menu_Open(myconnectindex); } ready2send = 0; bigi = 0; I_ClearAllInput(); // OSD_Printf("ticcnt=%d, total=%d\n", g_demo_cnt, g_demo_totalCnt); while (g_demo_cnt < g_demo_totalCnt || foundemo==0) { // Main loop here. It also runs when there's no demo to show, // so maybe a better name for this function would be // G_MainLoopWhenNotInGame()? // Demo requested from the OSD, its name is in g_firstDemoFile[] if (g_demo_playFirstFlag) { g_demo_playFirstFlag = 0; g_whichDemo = 1; // force g_firstDemoFile[] g_demo_paused = 0; goto nextdemo_nomenu; } if (foundemo && (!g_demo_paused || g_demo_goalCnt)) { if (g_demo_goalCnt>0 && g_demo_goalCnt < g_demo_cnt) { // initialize rewind int32_t menu = g_player[myconnectindex].ps->gm&MODE_MENU; if (g_demo_goalCnt > lastsynctic) { // we can use a previous diff if (Demo_UpdateState(0)==0) { g_demo_cnt = lastsynctic; g_demo_recFilePtr.Seek(lastsyncofs, FileReader::SeekSet); ud.reccnt = 0; totalclock = ototalclock = lockclock = lastsyncclock; } else CORRUPT(-1); } else { // update to initial state if (Demo_UpdateState(1) == 0) { g_demo_recFilePtr.Seek(initsyncofs, FileReader::SeekSet); g_levelTextTime = 0; g_demo_cnt = 1; ud.reccnt = 0; // ud.god = ud.cashman = ud.eog = ud.showallmap = 0; // ud.noclip = ud.scrollmode = ud.overhead_on = ud.pause_on = 0; totalclock = ototalclock = lockclock = 0; } else CORRUPT(0); } Demo_RestoreModes(menu); } if (g_demo_stopProfile) Demo_FinishProfile(); while (totalclock >= (lockclock+TICSPERFRAME) // || (ud.reccnt > REALGAMETICSPERSEC*2 && ud.pause_on) || (g_demo_goalCnt>0 && g_demo_cnt0 && ud.reccnt/ud.multimode >= g_demo_goalCnt-g_demo_cnt)) { Demo_UpdateState(0); } } } else if (Bmemcmp(tmpbuf, "EnD!", 4)==0) goto nextdemo; else CORRUPT(12); if (0) { corrupt: OSD_Printf(OSD_ERROR "Demo %d is corrupt (code %d).\n", g_whichDemo-1, corruptcode); nextdemo: Menu_Open(myconnectindex); nextdemo_nomenu: foundemo = 0; ud.reccnt = 0; g_demo_recFilePtr.Close(); if (g_demo_goalCnt>0) { g_demo_goalCnt=0; userConfig.nosound = g_demo_soundToggle; } if (Demo_IsProfiling()) // don't reset g_demo_profile if it's < 0 Demo_FinishProfile(); goto RECHECK; } } if (demo_hasseeds) outofsync = ((uint8_t)(randomseed>>24) != g_demo_seedbuf[bigi]); for (TRAVERSE_CONNECT(j)) { Bmemcpy(&inputfifo[0][j], &recsync[bigi], sizeof(input_t)); bigi++; ud.reccnt--; } g_demo_cnt++; if (Demo_IsProfiling()) { double t = timerGetHiTicks(); G_DoMoveThings(); Demo_GToc(t); } else if (!g_demo_paused) { // assumption that ud.multimode doesn't change in a demo may not be true // sometime in the future v v v v v v v v v if (g_demo_goalCnt==0 || !demo_hasdiffs || ud.reccnt/ud.multimode>=g_demo_goalCnt-g_demo_cnt) { G_DoMoveThings(); // increases lockclock by TICSPERFRAME } else { lockclock += TICSPERFRAME; } } else { int32_t k = userConfig.nosound; userConfig.nosound = true; G_DoMoveThings(); userConfig.nosound = k; } ototalclock += TICSPERFRAME; if (g_demo_goalCnt > 0) { // if fast-forwarding, we must update totalclock totalclock += TICSPERFRAME; // OSD_Printf("t:%d, l+T:%d; cnt:%d, goal:%d%s", totalclock, (lockclock+TICSPERFRAME), // g_demo_cnt, g_demo_goalCnt, g_demo_cnt>=g_demo_goalCnt?" ":"\n"); if (g_demo_cnt>=g_demo_goalCnt) { g_demo_goalCnt = 0; userConfig.nosound = g_demo_soundToggle; } } } } else if (foundemo && g_demo_paused) { totalclock = lockclock; } if (Demo_IsProfiling()) totalclock += TICSPERFRAME; if (G_FPSLimit()) { if (foundemo == 0) { G_DrawBackground(); } else { // NOTE: currently, no key/mouse events will be seen while // demo-profiling because we need 'totalclock' for ourselves. // And handleevents() -> sampletimer() would mess that up. G_HandleLocalKeys(); // Render one frame (potentially many if profiling) if (Demo_IsProfiling()) { int32_t i, num = g_demo_profile-1; Bassert(totalclock-ototalclock==4); for (i=0; i>16); G_DrawRooms(screenpeek, j); t2 = timerGetHiTicks(); G_DisplayRest(j); Demo_RToc(t1, t2); } totalclock = ototalclock+4; // draw status Demo_DisplayProfStatus(); if (handleevents_peekkeys()) Demo_StopProfiling(); } else { j = calc_smoothratio_demo(totalclock, ototalclock); if (g_demo_paused && g_demo_rewind) j = 65536-j; G_DrawRooms(screenpeek, j); G_DisplayRest(j); } // totalclocklock = totalclock; if (!Demo_IsProfiling() && (g_player[myconnectindex].ps->gm&MODE_MENU) == 0) { if (demoplay_showsync && outofsync) gametext_center(100, "OUT OF SYNC"); if (g_demo_showStats) { #if 0 if (g_demo_cnt 1) && g_player[myconnectindex].ps->gm) Net_GetPackets(); if (g_player[myconnectindex].gotvote == 0 && voting != -1 && voting != myconnectindex) gametext_center(60, "Press F1 to Accept, F2 to Decline"); } if ((g_player[myconnectindex].ps->gm&MODE_MENU) && (g_player[myconnectindex].ps->gm&MODE_EOL)) { Demo_FinishProfile(); videoNextPage(); goto RECHECK; } if (I_EscapeTrigger() && (g_player[myconnectindex].ps->gm&MODE_MENU) == 0 && (g_player[myconnectindex].ps->gm&MODE_TYPE) == 0) { I_EscapeTriggerClear(); FX_StopAllSounds(); S_ClearSoundLocks(); Menu_Open(myconnectindex); Menu_Change(MENU_MAIN); S_MenuSound(); } if (Demo_IsProfiling()) { // Do nothing: sampletimer() is reached from M_DisplayMenus() -> // Net_GetPackets() else. } else if (g_player[myconnectindex].ps->gm&MODE_TYPE) { Net_SendMessage(); if ((g_player[myconnectindex].ps->gm&MODE_TYPE) != MODE_TYPE) { g_player[myconnectindex].ps->gm = 0; Menu_Open(myconnectindex); } } else { if (ud.recstat != 2) M_DisplayMenus(); if ((g_netServer || ud.multimode > 1) && !Menu_IsTextInput(m_currentMenu)) { ControlInfo noshareinfo; CONTROL_GetInput(&noshareinfo); if (inputState.BUTTON(gamefunc_SendMessage)) { inputState.keyFlushChars(); inputState.ClearButton(gamefunc_SendMessage); g_player[myconnectindex].ps->gm = MODE_TYPE; typebuf[0] = 0; } } } if (!Demo_IsProfiling()) G_PrintGameQuotes(screenpeek); if (ud.last_camsprite != ud.camerasprite) ud.last_camsprite = ud.camerasprite; if (VOLUMEONE) { if (ud.show_help == 0 && (g_player[myconnectindex].ps->gm&MODE_MENU) == 0) rotatesprite_fs((320-50)<<16, 9<<16, 65536L, 0, BETAVERSION, 0, 0, 2+8+16+128); } videoNextPage(); } // NOTE: We must prevent handleevents() and Net_GetPackets() from // updating totalclock when profiling (both via sampletimer()): if (!Demo_IsProfiling()) gameHandleEvents(); if (g_player[myconnectindex].ps->gm == MODE_GAME) { // user wants to play a game, quit showing demo! if (foundemo) { #if KRANDDEBUG krd_print("krandplay.log"); #endif g_demo_recFilePtr.Close(); } return 0; } } ud.multimode = numplayers; // fixes 2 infinite loops after watching demo g_demo_recFilePtr.Close(); Demo_FinishProfile(); // if we're in the menu, try next demo immediately if (g_player[myconnectindex].ps->gm&MODE_MENU) goto RECHECK; #if KRANDDEBUG if (foundemo) krd_print("krandplay.log"); #endif // finished playing a demo and not in menu: // return so that e.g. the title can be shown return 1; } END_DUKE_NS