Added connection close error handling

Author: Vect0rZ

QuicNet.Tests.ConsoleClient/Program.cs

@@ -19,14 +19,22 @@ static void Main(string[] args)
             QuicConnection connection = client.Connect("127.0.0.1", 11000);   // Connect to peer (Server)
             Console.WriteLine("Connected");
 
-            QuicStream stream = connection.CreateStream(QuickNet.Utilities.StreamType.ClientUnidirectional); // Create a data stream
+            QuicStream stream = connection.CreateStream(QuickNet.Utilities.StreamType.ClientBidirectional); // Create a data stream
             Console.WriteLine("Create stream with id: " + stream.StreamId.IntegerValue.ToString());
 
             Console.WriteLine("Send 'Hello From Client!'");
             stream.Send(Encoding.UTF8.GetBytes("Hello from Client!"));        // Send Data
             Console.WriteLine("Waiting for message from the server");
-            // byte[] data = stream.Receive();                                   // Receive from server
-            // Console.WriteLine("Received: " + Encoding.UTF8.GetString(data));
+            try
+            {
+                byte[] data = stream.Receive();                                   // Receive from server
+                Console.WriteLine("Received: " + Encoding.UTF8.GetString(data));
+            }
+            catch (Exception e)
+            {
+                Console.WriteLine(e.Message);
+            }
+
             Console.ReadKey();
         }
     }

QuicNet/Connections/QuicConnection.cs

@@ -1,5 +1,6 @@
 using QuickNet.Utilities;
 using QuicNet.Context;
+using QuicNet.Exceptions;
 using QuicNet.Infrastructure.Frames;
 using QuicNet.Infrastructure.PacketProcessing;
 using QuicNet.Infrastructure.Packets;
@@ -17,6 +18,7 @@ public class QuicConnection
     {
         private UInt64 _currentTransferRate;
         private ConnectionState _state;
+        private string _lastError;
         private Dictionary<UInt64, QuicStream> _streams;
 
         private PacketWireTransfer _pwt;
@@ -52,8 +54,6 @@ public void ProcessFrames(List<Frame> frames)
             {
                 if (frame.Type == 0x01)
                     OnRstStreamFrame(frame);
-                if (frame.Type == 0x02)
-                    OnConnectionCloseFrame(frame);
                 if (frame.Type == 0x04)
                     OnRstStreamFrame(frame);
                 if (frame.Type >= 0x08 && frame.Type <= 0x0f)
@@ -66,6 +66,8 @@ public void ProcessFrames(List<Frame> frames)
                     OnMaxStreamFrame(frame);
                 if (frame.Type == 0x14)
                     OnDataBlockedFrame(frame);
+                if (frame.Type == 0x1c)
+                    OnConnectionCloseFrame(frame);
             }
         }
 
@@ -84,7 +86,9 @@ public bool MaximumReached()
 
         private void OnConnectionCloseFrame(Frame frame)
         {
+            ConnectionCloseFrame ccf = (ConnectionCloseFrame)frame;
             _state = ConnectionState.Draining;
+            _lastError = ccf.ReasonPhrase;
         }
 
         private void OnRstStreamFrame(Frame frame)
@@ -175,6 +179,7 @@ internal QuicConnection(ConnectionData connection)
         {
             _currentTransferRate = 0;
             _state = ConnectionState.Open;
+            _lastError = string.Empty;
             _streams = new Dictionary<UInt64, QuicStream>();
             _pwt = connection.PWT;
 
@@ -199,6 +204,18 @@ internal void ReceivePacket()
                 ShortHeaderPacket shp = (ShortHeaderPacket)packet;
                 ProcessFrames(shp.GetFrames());
             }
+
+            // If the connection has been closed
+            if (_state == ConnectionState.Draining)
+            {
+                if (string.IsNullOrWhiteSpace(_lastError))
+                    _lastError = "Protocol error";
+
+                TerminateConnection();
+
+                throw new QuicConnectivityException(_lastError);
+            }
+
         }
 
         internal bool SendData(Packet packet)

QuicNet/Streams/QuicStream.cs

@@ -127,7 +127,7 @@ public void ProcessData(StreamFrame frame)
             // Terminate connection if maximum stream data is reached
             if (_currentTransferRate >= _maximumStreamData)
             {
-                ShortHeaderPacket errorPacket = _connection.PacketCreator.CreateConnectionClosePacket(Infrastructure.ErrorCode.FLOW_CONTROL_ERROR, "Maximum stream data reached.");
+                ShortHeaderPacket errorPacket = _connection.PacketCreator.CreateConnectionClosePacket(Infrastructure.ErrorCode.FLOW_CONTROL_ERROR, "Maximum stream data transfer reached.");
                 _connection.SendData(errorPacket);
                 _connection.TerminateConnection();