cs2/PlaytimeHistory
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions

0.2.1: count queued writes in the writer, so css_pt_status doesn't throw

Browse source
This commit is contained in:
Astra 2026-10-04 21:59:48 +01:00
parent bba0471f20
commit 2576a8cc37
2 changed files with 15 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
PlaytimeHistory.cs
View file

@ -23,7 +23,7 @@ namespace PlaytimeHistory;
public class PlaytimeHistory : BasePlugin, IPluginConfig<PlaytimeHistoryConfig>
{
public override string ModuleName => "PlaytimeHistory";
public override string ModuleVersion => "0.2.0";
public override string ModuleVersion => "0.2.1";
public override string ModuleAuthor => "astra";
public override string ModuleDescription => "Records playtime per session, team and alive/dead state";

16
Writer.cs
View file

@ -38,7 +38,9 @@ public sealed class Writer
_logger = logger;
}
public int Queued => _queue.Reader.Count;
// Kept here: a single-reader unbounded channel can't count itself (Reader.Count throws).
private int _queued;
public int Queued => Volatile.Read(ref _queued);
public int Spooled => _spooled;
public bool Migrated => Volatile.Read(ref _migrated);
public bool Failing => Volatile.Read(ref _failing);
@ -48,7 +50,11 @@ public sealed class Writer
public void Start() => _loop = Task.Run(RunAsync);
// From the game thread. Never blocks.
public void Enqueue(Op op) => _queue.Writer.TryWrite(op);
public void Enqueue(Op op)
{
if (_queue.Writer.TryWrite(op))
Interlocked.Increment(ref _queued);
}
// On unload: sends what's queued, waiting up to `timeout`, then spools anything left.
public void Drain(TimeSpan timeout)
@ -66,8 +72,11 @@ public sealed class Writer
}
}
while (_queue.Reader.TryRead(out var op))
{
Interlocked.Decrement(ref _queued);
Spool(op);
}
}
private async Task RunAsync()
{
@ -87,7 +96,10 @@ public sealed class Writer
}
while (_queue.Reader.TryRead(out var op))
{
Interlocked.Decrement(ref _queued);
await HandleAsync(op, token);
}
bool more;
try