Communicator.NetworkCommunicator Class Reference

Class to manage the TCP network function More...

Inheritance diagram for Communicator.NetworkCommunicator:

Collaboration diagram for Communicator.NetworkCommunicator:

Public Member Functions
void	ListenForIncommingRequests ()
	Runs in background TcpServerThread; Handles incomming TcpClient requests More...
void	ResetThings ()
void	SendMessage (ref String outStructSerialized)
	Send message to client using socket connection. More...

Public Attributes
AC_BaseAirplane_Input	currentReadings
InputHandle	inputHandle
OutputHandle	outputHandle

Detailed Description

Class to manage the TCP network function

Definition at line 21 of file NetworkCommunicator.cs.

Member Function Documentation

ListenForIncommingRequests()

void Communicator.NetworkCommunicator.ListenForIncommingRequests ( )

inline

Runs in background TcpServerThread; Handles incomming TcpClient requests

Definition at line 66 of file NetworkCommunicator.cs.

                                                  {         
            try {           
                // Create listener on localhost port 8052.          
                tcpListener = new TcpListener(IPAddress.Parse("0.0.0.0"), CommonFunctions.ServerPort);  
                    
                tcpListener.Start();              
                Debug.Log("Started Server At Port "+CommonFunctions.ServerPort);              
                Byte[] bytes = new Byte[1024];
                if(inputHandle)
                {
                    while (true) {              
                            using (connectedTcpClient = tcpListener.AcceptTcpClient()) {                    
                                // Get a stream object for reading  
                                            
                                using (NetworkStream stream = connectedTcpClient.GetStream()) {                         
                                    int length;                         
                                    // Read incomming stream into byte arrary.              
                                    while ((length = stream.Read(bytes, 0, bytes.Length)) != 0) 
                                    {
                                        try
                                        {
                                            var incommingData = new byte[length];                           
                                            Array.Copy(bytes, 0, incommingData, 0, length);                             
                                            // Convert byte array to string message.                            
                                            string clientMessage = Encoding.ASCII.GetString(incommingData); 
                                            clientMessage = clientMessage.Replace("}{", "} | {");
                                            string [] inputArray = clientMessage.Split('|');
                                            foreach(string eachInput in inputArray)
                                            {
                                                isOutput = false;
                                                try{
                                                    var inputJson =  JObject.Parse(eachInput);
                                                    inputHandle.ParseInput(inputJson);  
                                                    isOutput = bool.Parse(inputJson["IsOutput"].ToString());
                                                }
                                                catch (SocketException e){
                                                    Debug.LogError($"JsonReaderException : { e.Source}");
                                                    isOutput = true;
                                                }
                                                catch (JsonReaderException e){
                                                    Debug.LogError($"JsonReaderException : { e.Source}");
                                                    isOutput = true;
                                                }   
                                                // once received the message, send message in return
                                                if(isOutput){
 
                                                    outputHandle.ParseOutput(ref  outputmsg);
                                                    SendMessage(ref outputmsg);
                                                }
                                                else{
                                                    string logOutput = outputHandle.LogOutput();
                                                    SendMessage(ref logOutput);
                                                }
                                            }
                                        }
                                        catch(Exception ex)
                                        {
                                            Debug.LogWarning("Socket exception: " + ex.ToString());
                                            isOutput = true;
                                        }
                                        ResetThings();
                                    }                   
                                }           
                            }
                        } 
                }
                else
                {
                    Debug.Log("InputHandle is detached in from Network manager. Go to Unity Hierarchy, look at inspector, drag and drop InputHandle onto Network communicator");
                }       
            }       
            catch (SocketException ex) {            
                Debug.LogWarning("Socket exception: " + ex.ToString());
                // tcpListener.Stop();
                isOutput = true;
            }     
        }

SendMessage()

void Communicator.NetworkCommunicator.SendMessage ( ref String  outStructSerialized )

inline

Send message to client using socket connection.

Definition at line 159 of file NetworkCommunicator.cs.

                                                                {       
            if (connectedTcpClient == null) {  
                return;         
            }       
            try {                   
                NetworkStream stream = connectedTcpClient.GetStream();  
                if (stream.CanWrite) {  
                    // string serverMessage = "This is a message from your server.";            
                    // Convert string message to byte array.                 
                    byte[] serverMessageAsByteArray = Encoding.ASCII.GetBytes(outStructSerialized);                 
                    // Write byte array to socketConnection stream.               
                    stream.Write(serverMessageAsByteArray, 0, serverMessageAsByteArray.Length);               
                }       
            }       
            catch (SocketException socketException) {             
                Debug.LogWarning("Socket exception: " + socketException);         
            }   
        } 

---

The documentation for this class was generated from the following file:

• NetworkCommunicator.cs