1 | using System;
|
---|
2 | using System.Collections.Generic;
|
---|
3 | using System.Threading;
|
---|
4 | using UnityEngine;
|
---|
5 |
|
---|
6 | namespace AllocsFixes.NetConnections
|
---|
7 | {
|
---|
8 | public class ConsoleOutputSeparator
|
---|
9 | {
|
---|
10 | public struct NetCommand
|
---|
11 | {
|
---|
12 | public string command;
|
---|
13 | public IConnection client;
|
---|
14 |
|
---|
15 | public NetCommand (string _cmd, IConnection _client)
|
---|
16 | {
|
---|
17 | command = _cmd;
|
---|
18 | client = _client;
|
---|
19 | }
|
---|
20 | }
|
---|
21 |
|
---|
22 | private static List<NetCommand> netCommandQueue = new List<NetCommand> ();
|
---|
23 | private static bool isCurrentCommandFromClient = false;
|
---|
24 | private static IConnection issuerOfCurrentCommand;
|
---|
25 |
|
---|
26 | public static void C_ExecuteCmdFromClient (ConsoleSdtd console, NetworkPlayer _networkPlayer, string _playerID, string _command)
|
---|
27 | {
|
---|
28 | Log.Out ("Executed command \"" + _command + "\" from player \"" + _playerID + "\"");
|
---|
29 |
|
---|
30 | object obj = netCommandQueue;
|
---|
31 | Monitor.Enter (obj);
|
---|
32 | try {
|
---|
33 | isCurrentCommandFromClient = true;
|
---|
34 | console.issuerOfCurrentClientCommand = _networkPlayer;
|
---|
35 | console.ExecuteClientCmdInternal (_playerID, _command);
|
---|
36 | isCurrentCommandFromClient = false;
|
---|
37 | } finally {
|
---|
38 | Monitor.Exit (obj);
|
---|
39 | }
|
---|
40 |
|
---|
41 | }
|
---|
42 |
|
---|
43 | public static void C_SendResult (ConsoleSdtd console, string _line)
|
---|
44 | {
|
---|
45 | if (isCurrentCommandFromClient) {
|
---|
46 | console.gameManager.GetRPCNetworkView ().RPC ("RPC_Console", console.issuerOfCurrentClientCommand, new object[]
|
---|
47 | {
|
---|
48 | _line,
|
---|
49 | false
|
---|
50 | }
|
---|
51 | );
|
---|
52 | } else {
|
---|
53 | if (console.telnetServer != null && issuerOfCurrentCommand != null)
|
---|
54 | NetTelnetServer.WriteToClient_Single (_line, issuerOfCurrentCommand);
|
---|
55 | else if (ControlPanel.IsStarted ())
|
---|
56 | ControlPanel.AddTextToOutputBuffer (_line);
|
---|
57 | }
|
---|
58 | }
|
---|
59 |
|
---|
60 | public static void C_Run (ConsoleSdtd console)
|
---|
61 | {
|
---|
62 | if (netCommandQueue.Count > 0) {
|
---|
63 | object obj = netCommandQueue;
|
---|
64 | Monitor.Enter (obj);
|
---|
65 | try {
|
---|
66 | issuerOfCurrentCommand = netCommandQueue [0].client;
|
---|
67 | console.ExecuteRemoteCmdInternal (netCommandQueue [0].command, false);
|
---|
68 | netCommandQueue.RemoveAt (0);
|
---|
69 | issuerOfCurrentCommand = null;
|
---|
70 | } finally {
|
---|
71 | Monitor.Exit (obj);
|
---|
72 | }
|
---|
73 | }
|
---|
74 | }
|
---|
75 |
|
---|
76 | public static void QueueNetCommand (string _line, IConnection _con)
|
---|
77 | {
|
---|
78 | object obj = netCommandQueue;
|
---|
79 | Monitor.Enter (obj);
|
---|
80 | try {
|
---|
81 | netCommandQueue.Add (new NetCommand (_line, _con));
|
---|
82 | } finally {
|
---|
83 | Monitor.Exit (obj);
|
---|
84 | }
|
---|
85 | }
|
---|
86 | }
|
---|
87 | }
|
---|