niko
52 lines
2.7 KiB
C#
52 lines
2.7 KiB
C#
using System.Collections;
|
|
|
|
namespace CampusNet.Services;
|
|
|
|
/// <summary>
|
|
/// Joins that hang on the loading screen (25%, "Waiting to receive buffered message"). A joiner
|
|
/// that loads streams its transform (event 28) and sends one request to the master client
|
|
/// (receiver group 2) within seconds; the stuck ones do neither (Rec Center 2026-09-26: every
|
|
/// join after a certain point hung while the players already inside were fine). After
|
|
/// AfterSeconds with neither, the Campus server is told (POST /photon/stuckload, localhost): it
|
|
/// stops matchmaking anyone into that instance and moves the player out of it, so they are not
|
|
/// left loading forever and their next join gets a working instance. The room's creator is
|
|
/// exempt (their load builds the room). CAMPUSNET_STUCK_LOAD_SECONDS=0 turns it off.
|
|
/// </summary>
|
|
public static class StuckLoad
|
|
{
|
|
public static readonly int AfterSeconds =
|
|
int.TryParse(Environment.GetEnvironmentVariable("CAMPUSNET_STUCK_LOAD_SECONDS"), out var s) ? (s <= 0 ? int.MaxValue : s) : 90;
|
|
private static readonly string Url = Environment.GetEnvironmentVariable("CAMPUSNET_STUCKLOAD_URL") ?? "http://127.0.0.1:8080/photon/stuckload";
|
|
private static readonly HttpClient Http = new() { Timeout = TimeSpan.FromSeconds(3) };
|
|
|
|
public static void Report(string userId, string room, int secs)
|
|
{
|
|
Log.Warn($"[stuck-load] u{userId} in '{room}' has not finished loading after {secs}s - reporting");
|
|
if (string.IsNullOrEmpty(userId) || !ulong.TryParse(userId, out _)) return;
|
|
_ = Task.Run(async () =>
|
|
{
|
|
try
|
|
{
|
|
using var body = new FormUrlEncodedContent(new[]
|
|
{
|
|
new KeyValuePair<string, string>("id", userId),
|
|
new KeyValuePair<string, string>("room", room),
|
|
new KeyValuePair<string, string>("seconds", secs.ToString()),
|
|
});
|
|
using var resp = await Http.PostAsync(Url, body);
|
|
}
|
|
catch (Exception ex) { Log.Warn($"[stuck-load] report for u{userId} failed: {ex.Message}"); }
|
|
});
|
|
}
|
|
|
|
/// <summary>Does any string inside the payload contain this text?</summary>
|
|
public static bool ContainsString(object? o, string needle, int depth = 0)
|
|
{
|
|
if (o == null || depth > 4) return false;
|
|
if (o is string str) return str.Contains(needle, StringComparison.Ordinal);
|
|
if (o is Hashtable ht) { foreach (DictionaryEntry e in ht) if (ContainsString(e.Value, needle, depth + 1)) return true; return false; }
|
|
if (o is IEnumerable en and not byte[]) { int n = 0; foreach (var x in en) { if (n++ > 64) break; if (ContainsString(x, needle, depth + 1)) return true; } }
|
|
return false;
|
|
}
|
|
}
|