Add more CandidatePair stats

Author: mickel8

lib/ex_ice/candidate_pair.ex

@@ -15,11 +15,17 @@ defmodule ExICE.CandidatePair do
           valid?: boolean(),
           last_seen: integer(),
           # stats
+          packets_sent: non_neg_integer(),
+          packets_received: non_neg_integer(),
+          bytes_sent: non_neg_integer(),
+          bytes_received: non_neg_integer(),
           requests_received: non_neg_integer(),
           requests_sent: non_neg_integer(),
           responses_received: non_neg_integer(),
           non_symmetric_responses_received: non_neg_integer(),
-          responses_sent: non_neg_integer()
+          responses_sent: non_neg_integer(),
+          packets_discarded_on_send: non_neg_integer(),
+          bytes_discarded_on_send: non_neg_integer()
         }
 
   @enforce_keys [:id, :local_cand_id, :remote_cand_id, :priority]
@@ -29,10 +35,16 @@ defmodule ExICE.CandidatePair do
                 state: :frozen,
                 valid?: false,
                 last_seen: nil,
+                packets_sent: 0,
+                packets_received: 0,
+                bytes_sent: 0,
+                bytes_received: 0,
                 requests_received: 0,
                 requests_sent: 0,
                 responses_received: 0,
                 non_symmetric_responses_received: 0,
-                responses_sent: 0
+                responses_sent: 0,
+                packets_discarded_on_send: 0,
+                bytes_discarded_on_send: 0
               ]
 end

lib/ex_ice/priv/candidate_pair.ex

@@ -22,11 +22,17 @@ defmodule ExICE.Priv.CandidatePair do
           discovered_pair_id: integer() | nil,
           keepalive_timer: reference() | nil,
           last_seen: integer(),
+          packets_sent: non_neg_integer(),
+          packets_received: non_neg_integer(),
+          bytes_sent: non_neg_integer(),
+          bytes_received: non_neg_integer(),
           requests_received: non_neg_integer(),
           requests_sent: non_neg_integer(),
           responses_received: non_neg_integer(),
           non_symmetric_responses_received: non_neg_integer(),
-          responses_sent: non_neg_integer()
+          responses_sent: non_neg_integer(),
+          packets_discarded_on_send: non_neg_integer(),
+          bytes_discarded_on_send: non_neg_integer()
         }
 
   @enforce_keys [:id, :local_cand_id, :remote_cand_id, :priority]
@@ -42,11 +48,17 @@ defmodule ExICE.Priv.CandidatePair do
                 # Time when this pair has received some data
                 # or sent conn check.
                 last_seen: nil,
+                packets_sent: 0,
+                packets_received: 0,
+                bytes_sent: 0,
+                bytes_received: 0,
                 requests_received: 0,
                 requests_sent: 0,
                 responses_received: 0,
                 non_symmetric_responses_received: 0,
-                responses_sent: 0
+                responses_sent: 0,
+                packets_discarded_on_send: 0,
+                bytes_discarded_on_send: 0
               ]
 
   @doc false

lib/ex_ice/priv/conn_check_handler/controlled.ex

@@ -190,7 +190,12 @@ defmodule ExICE.Priv.ConnCheckHandler.Controlled do
     cond do
       ice_agent.selected_pair_id == nil ->
         Logger.debug("Selecting pair: #{pair_id}")
-        %ICEAgent{ice_agent | selected_pair_id: pair.id}
+
+        %ICEAgent{
+          ice_agent
+          | selected_pair_id: pair.id,
+            selected_candidate_pair_changes: ice_agent.selected_candidate_pair_changes + 1
+        }
 
       ice_agent.selected_pair_id != nil and pair.id != ice_agent.selected_pair_id ->
         selected_pair = Map.fetch!(ice_agent.checklist, ice_agent.selected_pair_id)
@@ -201,7 +206,11 @@ defmodule ExICE.Priv.ConnCheckHandler.Controlled do
           New pair: #{pair_id}, old pair: #{ice_agent.selected_pair_id}.\
           """)
 
-          %ICEAgent{ice_agent | selected_pair_id: pair.id}
+          %ICEAgent{
+            ice_agent
+            | selected_pair_id: pair.id,
+              selected_candidate_pair_changes: ice_agent.selected_candidate_pair_changes + 1
+          }
         else
           Logger.debug("Not selecting a new pair as it has lower priority.")
           ice_agent

lib/ex_ice/priv/conn_check_handler/controlling.ex

@@ -113,7 +113,12 @@ defmodule ExICE.Priv.ConnCheckHandler.Controlling do
       cond do
         ice_agent.selected_pair_id == nil ->
           Logger.debug("Selecting pair: #{pair_id}")
-          %ICEAgent{ice_agent | selected_pair_id: pair.id}
+
+          %ICEAgent{
+            ice_agent
+            | selected_pair_id: pair.id,
+              selected_candidate_pair_changes: ice_agent.selected_candidate_pair_changes + 1
+          }
 
         ice_agent.selected_pair_id != nil and pair.id != ice_agent.selected_pair_id ->
           selected_pair = Map.fetch!(ice_agent.checklist, ice_agent.selected_pair_id)
@@ -124,7 +129,11 @@ defmodule ExICE.Priv.ConnCheckHandler.Controlling do
             New pair: #{pair_id}, old pair: #{ice_agent.selected_pair_id}.\
             """)
 
-            %ICEAgent{ice_agent | selected_pair_id: pair.id}
+            %ICEAgent{
+              ice_agent
+              | selected_pair_id: pair.id,
+                selected_candidate_pair_changes: ice_agent.selected_candidate_pair_changes + 1
+            }
           else
             Logger.debug("Not selecting a new pair as it has lower priority.")
             ice_agent