source: binary-improvements/7dtd-server-fixes/src/NetConnections/ConsoleOutputSeparator.cs@ 152

Last change on this file since 152 was 132, checked in by alloc, 10 years ago

Fixes: Source cleanups

File size: 2.2 KB
Line 
1using System;
2using System.Collections.Generic;
3using System.Threading;
4using UnityEngine;
5
6namespace 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}
Note: See TracBrowser for help on using the repository browser.