Changeset 29:5ba91682f0bc in freeDiameter for freeDiameter/p_psm.c

Timestamp:

Oct 28, 2009, 3:19:50 PM (14 years ago)

Author:

Sebastien Decugis <sdecugis@nict.go.jp>

Branch:

default

Phase:

public

Message:

Added a test for cnxctx (tbc) and fixed some bugs

File:

• freeDiameter/p_psm.c (modified) (2 diffs)

freeDiameter/p_psm.c

@@ -209 +209 @@
         }
         
+        /* A new connection was established and CER containing this peer id was received */
+        if (event == FDEVP_CNX_INCOMING) {
+                struct cnx_incoming * params = ev_data;
+                ASSERT(params);
+                
+                switch (peer->p_hdr.info.pi_state) {
+                        case STATE_CLOSED:
+                                TODO("Handle the CER, validate the peer if needed (and set expiry), set the alt_fifo in the connection, reply a CEA, eventually handshake, move to OPEN or REOPEN state");
+                                break;
+                                
+                        case STATE_WAITCNXACK:
+                        case STATE_WAITCEA:
+                                TODO("Election");
+                                break;
+                                
+                        default:
+                                TODO("Reply with error CEA");
+                                TODO("Close the connection");
+                                /* reject_incoming_connection */
+                        
+                }
+                
+                free(ev_data);
+                goto psm_loop;
+        }
+        
         /* MSG_RECEIVED: fd_p_expi_update(struct fd_peer * peer ) */
         /* If timeout or OPEN : call cb if defined */
@@ -223 +249 @@
 psm_end:
         pthread_cleanup_pop(1); /* set STATE_ZOMBIE */
-        pthread_detach(peer->p_psm);
         peer->p_psm = (pthread_t)NULL;
+        pthread_detach(pthread_self());
         return NULL;
 }