From f8f1b49b361a6a7cb5d8b56ba44ec1d0ce05c90e Mon Sep 17 00:00:00 2001 From: Kouichi Matsumura Date: Tue, 25 Aug 2020 18:05:52 +0900 Subject: [PATCH] FIX --- StreamServer/Source/StreamServer/Entry.cs | 3 --- StreamServer/Source/StreamServer/InputLoop.cs | 5 +++-- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/StreamServer/Source/StreamServer/Entry.cs b/StreamServer/Source/StreamServer/Entry.cs index a8cb1ee..c460e40 100644 --- a/StreamServer/Source/StreamServer/Entry.cs +++ b/StreamServer/Source/StreamServer/Entry.cs @@ -8,9 +8,6 @@ class Entry { static void Main(string[] args) { - ModelManager.Instance.Users["kai101"] = new User("kai101"); - ModelManager.Instance.Users["user2"] = new User("user2"); - ModelManager.Instance.Users["user3"] = new User("user3"); UdpClient udpClient = new UdpClient(5577); var input = new InputLoop(udpClient, 2); var output = new OutputLoop(udpClient, 33); diff --git a/StreamServer/Source/StreamServer/InputLoop.cs b/StreamServer/Source/StreamServer/InputLoop.cs index 8930492..9cd231e 100644 --- a/StreamServer/Source/StreamServer/InputLoop.cs +++ b/StreamServer/Source/StreamServer/InputLoop.cs @@ -49,10 +49,11 @@ private async Task Loop(CancellationToken token) var res = await udp.ReceiveAsync(); var buf = res.Buffer; var packets = Utility.BufferToPackets(buf); - if (packets != null && ModelManager.Instance.Users.ContainsKey(packets[0].PaketId)) + if (packets != null) { var packet = packets[0]; - var user = ModelManager.Instance.Users[packet.PaketId]; + var user = ModelManager.Instance.Users.GetOrAdd(packet.PaketId, + new User(packet.PaketId)); if (user.CurrentPacket == null) { PrintDbg($"Connected: [{user.UserId}] " +