sim1222/osukey
1
1
Fork 0
mirror of https://github.com/osukey/osukey.git synced 2025-08-08 00:53:56 +09:00
Code Issues Packages Projects Releases Wiki Activity

Add logging of opened and created contexts

Browse Source
This commit is contained in:
Dean Herbert
2021-01-12 14:25:22 +09:00
parent ffb42c37df
commit 8cbad1dc1c
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
osu.Game/Database/RealmContextFactory.cs
View File

@ -48,7 +48,8 @@ namespace osu.Game.Database
private static readonly GlobalStatistic<int> writes = GlobalStatistics.Get<int>("Realm", "Get (Write)"); private static readonly GlobalStatistic<int> writes = GlobalStatistics.Get<int>("Realm", "Get (Write)");
private static readonly GlobalStatistic<int> commits = GlobalStatistics.Get<int>("Realm", "Commits"); private static readonly GlobalStatistic<int> commits = GlobalStatistics.Get<int>("Realm", "Commits");
private static readonly GlobalStatistic<int> rollbacks = GlobalStatistics.Get<int>("Realm", "Rollbacks"); private static readonly GlobalStatistic<int> rollbacks = GlobalStatistics.Get<int>("Realm", "Rollbacks");
private static readonly GlobalStatistic<int> contexts = GlobalStatistics.Get<int>("Realm", "Contexts"); private static readonly GlobalStatistic<int> contexts_open = GlobalStatistics.Get<int>("Realm", "Contexts (Open)");
private static readonly GlobalStatistic<int> contexts_created = GlobalStatistics.Get<int>("Realm", "Contexts (Created)");
/// <summary> /// <summary>
/// Get a context for the current thread for read-only usage. /// Get a context for the current thread for read-only usage.
@ -92,11 +93,16 @@ namespace osu.Game.Database
private Realm getContextForCurrentThread() private Realm getContextForCurrentThread()
{ {
var context = threadContexts.Value; var context = threadContexts.Value;
if (context?.IsClosed != false) if (context?.IsClosed != false)
threadContexts.Value = context = CreateContext(); threadContexts.Value = context = CreateContext();
contexts_open.Value = threadContexts.Values.Count;
if (!refreshCompleted.Value) if (!refreshCompleted.Value)
{ {
// to keep things simple, realm refreshes are currently performed per thread context at the point of retrieval.
// in the future this should likely be run as part of the update loop for the main (update thread) context.
context.Refresh(); context.Refresh();
refreshCompleted.Value = true; refreshCompleted.Value = true;
} }
@ -147,7 +153,8 @@ namespace osu.Game.Database
protected virtual Realm CreateContext() protected virtual Realm CreateContext()
{ {
contexts.Value++; contexts_created.Value++;
return Realm.GetInstance(new RealmConfiguration(storage.GetFullPath($"{database_name}.realm", true)) return Realm.GetInstance(new RealmConfiguration(storage.GetFullPath($"{database_name}.realm", true))
{ {
SchemaVersion = schema_version, SchemaVersion = schema_version,