add agent_connectivity_reset while at CONTROLLED mode

sepfy · Nov 19, 2024 · 9951b64 · 9951b64
1 parent 68cdc65
commit 9951b64
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/src/agent.c b/src/agent.c
@@ -469,6 +469,12 @@ int agent_connectivity_check(Agent* agent) {
   return -1;
 }
 
+void agent_connectivity_reset(Agent* agent) {
+  for (int i = 0; i < agent->candidate_pairs_num; i++) {
+    agent->candidate_pairs[i].state = ICE_CANDIDATE_STATE_FROZEN;
+  }
+}
+
 int agent_select_candidate_pair(Agent* agent) {
   int i;
   for (i = 0; i < agent->candidate_pairs_num; i++) {

diff --git a/src/agent.h b/src/agent.h
@@ -82,6 +82,8 @@ int agent_recv(Agent* agent, uint8_t* buf, int len);
 
 void agent_set_remote_description(Agent* agent, char* description);
 
+void agent_connectivity_reset(Agent* agent);
+
 int agent_select_candidate_pair(Agent* agent);
 
 int agent_connectivity_check(Agent* agent);

diff --git a/src/peer_connection.c b/src/peer_connection.c
@@ -467,6 +467,7 @@ int peer_connection_loop(PeerConnection* pc) {
       }
 
       if (KEEPALIVE_CONNCHECK > 0 && (ports_get_epoch_time() - pc->agent.binding_request_time) > KEEPALIVE_CONNCHECK) {
+        agent_connectivity_reset(&pc->agent);
         LOGI("binding request timeout");
         STATE_CHANGED(pc, PEER_CONNECTION_CLOSED);
       }