diff --git a/src/dthinker.cpp b/src/dthinker.cpp index 5e536065127..a415dff030b 100644 --- a/src/dthinker.cpp +++ b/src/dthinker.cpp @@ -462,6 +462,21 @@ void DThinker::DestroyThinkersInList (FThinkerList &list) // // //========================================================================== +CVAR(Bool, profilethinkers, false, 0) + +struct ProfileInfo +{ + int numcalls = 0; + cycle_t timer; + + ProfileInfo() + { + timer.Reset(); + } +}; + +TMap Profiles; + void DThinker::RunThinkers () { @@ -475,21 +490,50 @@ void DThinker::RunThinkers () ThinkCycles.Clock(); - // Tick every thinker left from last time - for (i = STAT_FIRST_THINKING; i <= MAX_STATNUM; ++i) + if (!profilethinkers) { - TickThinkers (&Thinkers[i], NULL); - } + // Tick every thinker left from last time + for (i = STAT_FIRST_THINKING; i <= MAX_STATNUM; ++i) + { + TickThinkers(&Thinkers[i], NULL); + } - // Keep ticking the fresh thinkers until there are no new ones. - do + // Keep ticking the fresh thinkers until there are no new ones. + do + { + count = 0; + for (i = STAT_FIRST_THINKING; i <= MAX_STATNUM; ++i) + { + count += TickThinkers(&FreshThinkers[i], &Thinkers[i]); + } + } while (count != 0); + } + else { - count = 0; + Profiles.Clear(); + // Tick every thinker left from last time for (i = STAT_FIRST_THINKING; i <= MAX_STATNUM; ++i) { - count += TickThinkers (&FreshThinkers[i], &Thinkers[i]); + ProfileThinkers(&Thinkers[i], NULL); } - } while (count != 0); + + // Keep ticking the fresh thinkers until there are no new ones. + do + { + count = 0; + for (i = STAT_FIRST_THINKING; i <= MAX_STATNUM; ++i) + { + count += ProfileThinkers(&FreshThinkers[i], &Thinkers[i]); + } + } while (count != 0); + auto it = TMap::Iterator(Profiles); + TMap::Pair *pair; + while (it.NextPair(pair)) + { + Printf("%s, %dx, %fms\n", pair->Key.GetChars(), pair->Value.numcalls, pair->Value.timer.TimeMS()); + } + profilethinkers = false; + } ThinkCycles.Unclock(); } @@ -541,6 +585,57 @@ int DThinker::TickThinkers (FThinkerList *list, FThinkerList *dest) return count; } +//========================================================================== +// +// +// +//========================================================================== +int DThinker::ProfileThinkers(FThinkerList *list, FThinkerList *dest) +{ + int count = 0; + DThinker *node = list->GetHead(); + + if (node == NULL) + { + return 0; + } + + while (node != list->Sentinel) + { + ++count; + NextToThink = node->NextThinker; + if (node->ObjectFlags & OF_JustSpawned) + { + // Leave OF_JustSpawn set until after Tick() so the ticker can check it. + if (dest != NULL) + { // Move thinker from this list to the destination list + node->Remove(); + dest->AddTail(node); + } + node->CallPostBeginPlay(); + } + else if (dest != NULL) + { + I_Error("There is a thinker in the fresh list that has already ticked.\n"); + } + + if (!(node->ObjectFlags & OF_EuthanizeMe)) + { // Only tick thinkers not scheduled for destruction + ThinkCount++; + + auto &prof = Profiles[node->GetClass()->TypeName]; + prof.numcalls++; + prof.timer.Clock(); + node->CallTick(); + prof.timer.Unclock(); + node->ObjectFlags &= ~OF_JustSpawned; + GC::CheckGC(); + } + node = NextToThink; + } + return count; +} + //========================================================================== // // diff --git a/src/dthinker.h b/src/dthinker.h index da7eced7d35..c9a2f7ba1bc 100644 --- a/src/dthinker.h +++ b/src/dthinker.h @@ -97,6 +97,7 @@ class DThinker : public DObject private: static void DestroyThinkersInList (FThinkerList &list); static int TickThinkers (FThinkerList *list, FThinkerList *dest); // Returns: # of thinkers ticked + static int ProfileThinkers(FThinkerList *list, FThinkerList *dest); static void SaveList(FSerializer &arc, DThinker *node); void Remove();