Changeset 182


Ignore:
Timestamp:
Sep 9, 2014, 8:04:37 PM (10 years ago)
Author:
alloc
Message:

fixes

Location:
binary-improvements
Files:
1 added
9 edited

Legend:

Unmodified
Added
Removed

  • binary-improvements/7dtd-server-fixes/7dtd-server-fixes.csproj

    r174 r182  
    119119    <Compile Include="src\NetConnections\Servers\Web\API\GetPlayerInventory.cs" />
    120120    <Compile Include="src\NetConnections\Servers\Web\API\GetLandClaims.cs" />
     121    <Compile Include="src\BlockingQueue.cs" />
    121122  </ItemGroup>
    122123  <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />

  • binary-improvements/7dtd-server-fixes/src/AssemblyInfo.cs

    r164 r182  
    1818// and "{Major}.{Minor}.{Build}.*" will update just the revision.
    1919
    20 [assembly: AssemblyVersion("0.092.*")]
     20[assembly: AssemblyVersion("0.093.*")]
    2121
    2222// The following attributes are used to specify the signing key for the assembly,

  • binary-improvements/7dtd-server-fixes/src/NetConnections/NetTelnetServer.cs

    r133 r182  
    44using System.Net;
    55using System.Net.Sockets;
    6 using System.Reflection;
    76using System.Threading;
    87using UnityEngine;
    … …  
    1716                {
    1817                        try {
    19                                 Log.Out ("[7dtd-server-fixes by Alloc] Version: " + Assembly.GetExecutingAssembly ().GetName ().Version);
    20                                 servers.Add (new Servers.Telnet.Telnet (port));
    21 
    22                                 int webPort = GamePrefs.GetInt (EnumGamePrefs.ControlPanelPort);
    23                                 if (GamePrefs.GetBool (EnumGamePrefs.ControlPanelEnabled) && webPort > 0 && webPort < 65534) {
    24                                         if (Directory.Exists (Application.dataPath + "/../webserver")) {
    25                                                 servers.Add (new Servers.Web.Web (webPort + 2));
    26                                         }
    27                                 }
    2818                        } catch (Exception e) {
    2919                                Log.Out ("Error in NetTelnetServer.init: " + e);
    3020                        }
     21                }
     22
     23                public static void RegisterServer (IServer serv)
     24                {
     25                        servers.Add (serv);
    3126                }
    3227

  • binary-improvements/7dtd-server-fixes/src/NetConnections/Servers/Telnet/Telnet.cs

    r142 r182  
    99        public class Telnet : IServer
    1010        {
    11                 private static Thread telnetThread = null;
    12                 private static TcpListener listener = null;
    13                 private static bool closed = false;
    14                 private static bool authEnabled = false;
    15                 private static List<TelnetConnection> connections = new List<TelnetConnection> ();
     11                private Thread telnetThread = null;
     12                private TcpListener listener = null;
     13                private bool closed = false;
     14                private bool authEnabled = false;
     15                private List<TelnetConnection> connections = new List<TelnetConnection> ();
    1616
    17                 public Telnet (int port)
     17                public Telnet ()
    1818                {
    1919                        try {
     20                                if (!GamePrefs.GetBool (EnumGamePrefs.TelnetEnabled)) {
     21                                        return;
     22                                }
     23
     24                                int port = GamePrefs.GetInt (EnumGamePrefs.TelnetPort);
     25
    2026                                authEnabled = GamePrefs.GetString (EnumGamePrefs.TelnetPassword).Length != 0;
    2127                                if (authEnabled)
    … …  
    2531                                telnetThread = ThreadMaster.Create ("thread TelnetListenThread", new ThreadStart (telnetListenThread));
    2632                                telnetThread.Start ();
    27                                 Log.Out ("Started Telnet thread on " + port);
     33
     34                                NetTelnetServer.RegisterServer (this);
     35
     36                                Log.Out ("Started Telnet on " + port);
    2837                        } catch (Exception e) {
    2938                                Log.Out ("Error in Telnet.ctor: " + e);
    … …  
    3443                {
    3544                        try {
    36                                 Log.Out ("Started thread_TelnetListenThread()");
    3745                                listener.Start ();
    38                                 while (!closed) {
    39                                         Thread.Sleep (10);
    40                                         if (listener.Pending ()) {
     46                                try {
     47                                        while (!closed) {
    4148                                                TelnetConnection c = new TelnetConnection (listener.AcceptTcpClient (), authEnabled);
    4249                                                connections.Add (c);
    43                                                 Log.Out ("Telnet connection from: " + c.GetEndPoint ());
    44                                                 if (authEnabled) {
    45                                                         c.WriteLine ("Please enter password:");
    46                                                 } else {
    47                                                         LoginMessage (c);
    48                                                 }
    4950                                        }
    50 
    51                                         foreach (TelnetConnection c in connections) {
    52                                                 if (c.IsClosed ()) {
    53                                                         c.Close ();
    54                                                         connections.Remove (c);
    55                                                         break;
    56                                                 }
    57                                                 if (c.Read ()) {
    58                                                         string line = lineCorrecter (c.GetLine ());
    59                                                         if (!c.IsAuthenticated ()) {
    60                                                                 if (line.Equals (GamePrefs.GetString (EnumGamePrefs.TelnetPassword))) {
    61                                                                         c.SetAuthenticated ();
    62                                                                         c.WriteLine ("Logon successful.");
    63                                                                         c.WriteLine (string.Empty);
    64                                                                         c.WriteLine (string.Empty);
    65                                                                         c.WriteLine (string.Empty);
    66                                                                         LoginMessage (c);
    67                                                                 } else {
    68                                                                         c.WriteLine ("Password incorrect, please enter password:");
    69                                                                 }
    70                                                         } else {
    71                                                                 if (line.ToLower ().Equals ("exit")) {
    72                                                                         Log.Out ("Telnet connection closed by client: " + c.GetEndPoint ());
    73                                                                         c.Close ();
    74                                                                         connections.Remove (c);
    75                                                                         break;
    76                                                                 }
    77                                                                 Log.Out ("Telnet executed \"" + line + "\" from: " + c.GetEndPoint ());
    78                                                                 ConsoleOutputSeparator.QueueNetCommand (line, c);
    79                                                         }
    80                                                 }
    81                                         }
     51                                } catch (SocketException) {
     52                                } catch (ThreadInterruptedException) {
    8253                                }
    83                                 Log.Out ("Exited thread_TelnetListenThread()");
    8454                                ThreadMaster.Remove (Thread.CurrentThread.Name);
    8555                        } catch (Exception ex) {
    86                                 Log.Out ("Error in TelnetListenThread: " + ex.Message);
    87                                 Log.Out ("Stack Trace: " + ex.StackTrace);
     56                                Log.Out ("Error in TelnetListenThread: " + ex);
    8857                        }
    89                 }
    90 
    91                 private void LoginMessage (TelnetConnection c)
    92                 {
    93                         c.WriteLine ("*** Connected with 7DTD server.");
    94                         c.WriteLine ("*** Dedicated server only build");
    95                         c.WriteLine ("*** Allocs server fixes loaded");
    96                         c.WriteLine (string.Empty);
    97                         c.WriteLine ("Server IP:   " +
    98                                 ((GamePrefs.GetString (EnumGamePrefs.ServerIP) != null && GamePrefs.GetString (EnumGamePrefs.ServerIP).Length != 0) ? GamePrefs.GetString (EnumGamePrefs.ServerIP) : "Any")
    99                         );
    100                         c.WriteLine ("Server port: " + GamePrefs.GetInt (EnumGamePrefs.ServerPort));
    101                         c.WriteLine ("Max players: " + GamePrefs.GetInt (EnumGamePrefs.ServerMaxPlayerCount));
    102                         c.WriteLine ("Game mode:   " + GamePrefs.GetString (EnumGamePrefs.GameMode));
    103                         c.WriteLine ("World:       " + GamePrefs.GetString (EnumGamePrefs.GameWorld));
    104                         c.WriteLine ("Game name:   " + GamePrefs.GetString (EnumGamePrefs.GameName));
    105                         c.WriteLine ("Difficulty:  " + GamePrefs.GetInt (EnumGamePrefs.GameDifficulty));
    106                         c.WriteLine (string.Empty);
    107                         c.WriteLine ("Press 'help' to get a list of all commands. Press 'exit' to end session.");
    108                         c.WriteLine (string.Empty);
    109                 }
    110 
    111                 private string lineCorrecter (string line)
    112                 {
    113                         string res = "";
    114                         for (int i = 0; i < line.Length; i++) {
    115                                 if (line [i] >= ' ' && line [i] != '\'') {
    116                                         res += line [i];
    117                                 }
    118                         }
    119                         return res.Trim ();
    12058                }
    12159
    … …  
    12664                                if (listener != null) {
    12765                                        listener.Stop ();
     66                                        listener = null;
    12867                                }
    12968                                foreach (TelnetConnection c in connections) {
    … …  
    13170                                }
    13271                                Thread.Sleep (100);
     72                                if (telnetThread != null) {
     73                                        telnetThread.Interrupt ();
     74                                }
    13375                        } catch (Exception e) {
    13476                                Log.Out ("Error in Telnet.Disconnect: " + e);
    … …  
    13981                {
    14082                        try {
     83                                List<TelnetConnection> toRemove = new List<TelnetConnection> ();
    14184                                foreach (TelnetConnection c in connections) {
    142                                         if (c.IsClosed ()) {
    143                                                 c.Close ();
    144                                         }
     85                                        if (c.IsClosed ())
     86                                                toRemove.Add (c);
     87                                }
     88                                foreach (TelnetConnection c in toRemove) {
     89                                        connections.Remove (c);
    14590                                }
    14691                        } catch (Exception e) {

  • binary-improvements/7dtd-server-fixes/src/NetConnections/Servers/Telnet/TelnetConnection.cs

    r174 r182  
    11using System;
     2using System.Collections.Generic;
     3using System.IO;
    24using System.Net;
    35using System.Net.Sockets;
    46using System.Text;
     7using System.Threading;
    58
    69namespace AllocsFixes.NetConnections.Servers.Telnet
    … …  
    811        public class TelnetConnection : IConnection
    912        {
     13                BlockingQueue<string> toClientQueue = new BlockingQueue<string> ();
     14                private Thread receiveThread = null;
     15                private Thread sendThread = null;
    1016                private bool authenticated = false;
    1117                private bool authEnabled;
    1218                private TcpClient client;
    1319                private NetworkStream stream;
    14                 private int lineBufferLength = 0;
    15                 private byte[] lineBuffer = new byte[200];
    1620                private EndPoint endpoint;
    1721
    … …  
    2226                        this.stream = client.GetStream ();
    2327                        this.endpoint = client.Client.RemoteEndPoint;
     28
     29                        Log.Out ("Telnet connection from: " + endpoint);
     30
     31                        receiveThread = ThreadMaster.Create ("TelnetClientReceive", new ThreadStart (ReceiveThread));
     32                        receiveThread.Start ();
     33                        sendThread = ThreadMaster.Create ("TelnetClientSend", new ThreadStart (SendThread));
     34                        sendThread.Start ();
     35
     36                        if (authEnabled) {
     37                                WriteLine ("Please enter password:");
     38                        } else {
     39                                LoginMessage ();
     40                        }
    2441                }
    2542
    26                 public EndPoint GetEndPoint ()
     43                private void LoginMessage ()
    2744                {
    28                         return endpoint;
     45                        WriteLine ("*** Connected with 7DTD server.");
     46                        WriteLine ("*** Dedicated server only build");
     47                        WriteLine ("*** Allocs server fixes loaded");
     48                        WriteLine (string.Empty);
     49                        WriteLine ("Server IP:   " +
     50                                ((GamePrefs.GetString (EnumGamePrefs.ServerIP) != null && GamePrefs.GetString (EnumGamePrefs.ServerIP).Length != 0) ? GamePrefs.GetString (EnumGamePrefs.ServerIP) : "Any")
     51                        );
     52                        WriteLine ("Server port: " + GamePrefs.GetInt (EnumGamePrefs.ServerPort));
     53                        WriteLine ("Max players: " + GamePrefs.GetInt (EnumGamePrefs.ServerMaxPlayerCount));
     54                        WriteLine ("Game mode:   " + GamePrefs.GetString (EnumGamePrefs.GameMode));
     55                        WriteLine ("World:       " + GamePrefs.GetString (EnumGamePrefs.GameWorld));
     56                        WriteLine ("Game name:   " + GamePrefs.GetString (EnumGamePrefs.GameName));
     57                        WriteLine ("Difficulty:  " + GamePrefs.GetInt (EnumGamePrefs.GameDifficulty));
     58                        WriteLine (string.Empty);
     59                        WriteLine ("Press 'help' to get a list of all commands. Press 'exit' to end session.");
     60                        WriteLine (string.Empty);
    2961                }
    3062
    31                 private void WriteByte (byte v)
     63                private void ReceiveThread ()
    3264                {
    33                         if (!IsClosed () && stream.CanWrite) {
    34                                 stream.WriteByte (v);
     65                        try {
     66                                StreamReader reader = new StreamReader (stream);
     67                                try {
     68                                        while (!IsClosed()) {
     69                                                string line = reader.ReadLine ();
     70                                                if (line != null) {
     71                                                        line = line.Trim ();
     72
     73                                                        if (!IsAuthenticated ()) {
     74                                                                if (line.Equals (GamePrefs.GetString (EnumGamePrefs.TelnetPassword))) {
     75                                                                        authenticated = true;
     76                                                                        WriteLine ("Logon successful.");
     77                                                                        WriteLine (string.Empty);
     78                                                                        WriteLine (string.Empty);
     79                                                                        WriteLine (string.Empty);
     80                                                                        LoginMessage ();
     81                                                                } else {
     82                                                                        WriteLine ("Password incorrect, please enter password:");
     83                                                                }
     84                                                        } else {
     85                                                                if (line.ToLower ().Equals ("exit")) {
     86                                                                        Log.Out ("Telnet connection closed by client: " + endpoint);
     87                                                                        Close ();
     88                                                                        break;
     89                                                                }
     90                                                                Log.Out ("Telnet executed \"" + line + "\" from: " + endpoint);
     91                                                                ConsoleOutputSeparator.QueueNetCommand (line, this);
     92                                                        }
     93                                                }
     94                                        }
     95                                } catch (IOException) {
     96                                } catch (ThreadInterruptedException) {
     97                                }
     98                                ThreadMaster.Remove (Thread.CurrentThread.Name);
     99                        } catch (Exception ex) {
     100                                Log.Out ("Error in TelnetClientReceive: " + ex);
    35101                        }
     102
     103                }
     104
     105                private void SendThread ()
     106                {
     107                        try {
     108                                while (!IsClosed() && stream.CanWrite) {
     109                                        try {
     110                                                string line = toClientQueue.Dequeue ();
     111                                                if (!IsClosed () && stream.CanWrite) {
     112                                                        byte[] utfData = Encoding.UTF8.GetBytes (line);
     113                                                        stream.Write (utfData, 0, utfData.Length);
     114                                                        stream.WriteByte (13);
     115                                                        stream.WriteByte (10);
     116                                                }
     117                                        } catch (IOException) {
     118                                        } catch (ThreadInterruptedException) {
     119                                        } catch (Exception e) {
     120                                                Log.Out ("Error writing to client: " + e);
     121                                        }
     122                                }
     123
     124                                ThreadMaster.Remove (Thread.CurrentThread.Name);
     125                        } catch (Exception ex) {
     126                                Log.Out ("Error in TelnetClientSend: " + ex);
     127                        }
     128
    36129                }
    37130
    38131                public void WriteLine (string s)
    39132                {
    40                         try {
    41                                 if (!IsClosed () && stream.CanWrite) {
    42                                         byte[] utfData = Encoding.UTF8.GetBytes (s);
    43                                         stream.Write (utfData, 0, utfData.Length);
    44                                         WriteByte (13);
    45                                         WriteByte (10);
    46                                 }
    47                         } catch (Exception e) {
    48                                 Log.Out ("Error writing to client: " + e);
    49                         }
     133                        toClientQueue.Enqueue (s);
    50134                }
    51135
    52136                public void Close ()
    53137                {
     138                        if (receiveThread != null) {
     139                                receiveThread.Interrupt ();
     140                        }
     141                        if (sendThread != null) {
     142                                sendThread.Interrupt ();
     143                        }
    54144                        if (client != null)
    55145                                client.Close ();
    … …  
    61151                        if (client != null && !client.Connected) {
    62152                                Log.Out ("Telnet connection interrupted: " + endpoint);
     153                                Close ();
    63154                        }
    64155                        return (client == null) || (!client.Connected);
    … …  
    70161                }
    71162
    72                 public void SetAuthenticated ()
    73                 {
    74                         authenticated = true;
    75                 }
    76 
    77                 public bool Read ()
    78                 {
    79                         while (!IsClosed() && stream.CanRead && stream.DataAvailable) {
    80                                 int b = stream.ReadByte ();
    81                                 if (b == '\r' || b == '\n') {
    82                                         if (lineBufferLength > 0) {
    83                                                 return true;
    84                                         }
    85                                 } else if (b >= 0) {
    86                                         lineBuffer [lineBufferLength] = (byte)b;
    87                                         lineBufferLength++;
    88                                 }
    89                         }
    90                         return false;
    91                 }
    92 
    93                 public string GetLine ()
    94                 {
    95                         string res = Encoding.UTF8.GetString (lineBuffer, 0, lineBufferLength);
    96                         lineBufferLength = 0;
    97                         return res;
    98                 }
    99 
    100163        }
    101164}

  • binary-improvements/7dtd-server-fixes/src/NetConnections/Servers/Web/Web.cs

    r172 r182  
    1616                private string realm = "7dtd Admin Panel";
    1717
    18                 public Web (int port)
     18                public Web ()
    1919                {
    2020                        try {
     21                                int webPort = GamePrefs.GetInt (EnumGamePrefs.ControlPanelPort);
     22                                if (!GamePrefs.GetBool (EnumGamePrefs.ControlPanelEnabled) || webPort < 1 || webPort > 65533) {
     23                                        Log.Out ("Webserver not started (ControlPanel not enabled or ControlPanelPort not within 1-65534)");
     24                                        return;
     25                                }
     26                                if (!Directory.Exists (Application.dataPath + "/../webserver")) {
     27                                        Log.Out ("Webserver not started (folder \"webserver\" not found in game folder)");
     28                                        return;
     29                                }
     30
    2131                                if (!HttpListener.IsSupported)
    2232                                        throw new NotSupportedException ("Needs Windows XP SP2, Server 2003 or later.");
    … …  
    2737                                handlers.Add ("/api/", new ApiHandler ("/api/"));
    2838
    29                                 _listener.Prefixes.Add (String.Format ("http://*:{0}/", port));
     39                                _listener.Prefixes.Add (String.Format ("http://*:{0}/", webPort + 2));
    3040                                authEnabled = File.Exists (Application.dataPath + "/../webserver/protect");
    3141                                if (authEnabled)
    … …  
    4959                                );
    5060
    51                                 Log.Out ("Started Webserver on " + port + " (authentication " + (authEnabled ? "enabled" : "disabled") + ")");
     61                                NetTelnetServer.RegisterServer(this);
     62
     63
     64                                Log.Out ("Started Webserver on " + (webPort + 2) + " (authentication " + (authEnabled ? "enabled" : "disabled") + ")");
    5265                        } catch (Exception e) {
    5366                                Log.Out ("Error in Web.ctor: " + e);

  • binary-improvements/7dtd-server-fixes/src/StateManager.cs

    r145 r182  
     1using AllocsFixes.NetConnections.Servers.Telnet;
     2using AllocsFixes.NetConnections.Servers.Web;
    13using System;
     4using System.Reflection;
    25
    36namespace AllocsFixes
    … …  
    811                {
    912                        try {
     13                                Log.Out ("[7dtd-server-fixes by Alloc] Version: " + Assembly.GetExecutingAssembly ().GetName ().Version);
     14                                new Web();
     15                                new Telnet();
     16
    1017                                CommandExtensions.InitCommandExtensions (manager);
     18
    1119                                PersistentData.PersistentContainer.Load ();
    1220                        } catch (Exception e) {

  • binary-improvements/bin/Release/7dtd-server-fixes_version.txt

    r180 r182  
    1 Version:       0.92.5364.31430
     1Version:       0.92.5365.35778
Note: See TracChangeset for help on using the changeset viewer.