Changeset 1259:82280e745a89 in freeDiameter for extensions/rt_redirect/redir_fwd.c

Timestamp:

Mar 24, 2014, 9:13:38 PM (10 years ago)

Author:

Thomas Klausner <tk@giga.or.at>

Branch:

default

Phase:

public

Message:

Remove whitespace at end of line.

File:

• extensions/rt_redirect/redir_fwd.c (modified) (16 diffs)

extensions/rt_redirect/redir_fwd.c

@@ -59 +59 @@
         int nbrh = 0;
         struct redir_entry * entry;
-        
+
         TRACE_ENTRY("%p %p", cbdata, msg);
-        
+
         CHECK_PARAMS(msg && *msg);
-        
+
         m = *msg;
-        
+
         /* First get the header */
         CHECK_FCT( fd_msg_hdr(m, &hdr) );
-        
+
         /* Check if we have an error */
         ASSERT(!(hdr->msg_flags & CMD_FLAG_REQUEST));
@@ -75 +75 @@
                 return 0;
         }
-        
+
         /* Now get the AVPs we are interested in */
         CHECK_FCT(  fd_msg_browse(m, MSG_BRW_FIRST_CHILD, &avp, NULL)  );
         while (avp) {
                 struct avp_hdr * ahdr;
-                        
+
                 CHECK_FCT(  fd_msg_avp_hdr( avp, &ahdr )  );
                 if (! (ahdr->avp_flags & AVP_FLAG_VENDOR)) {
@@ -90 +90 @@
                                         a_oh = ahdr->avp_value;
                                         break;
-                                        
+
                                 case AC_RESULT_CODE:
                                         /* Parse this AVP */
@@ -96 +96 @@
                                         ASSERT( ahdr->avp_value );
                                         a_rc = ahdr->avp_value;
-                                        
+
                                         if (a_rc->u32 != ER_DIAMETER_REDIRECT_INDICATION) {
                                                 /* It is not a REDIRECT error, we don't do anything */
@@ -102 +102 @@
                                         }
                                         break;
-                                        
+
                                 case AC_REDIRECT_HOST:
                                         {
@@ -112 +112 @@
                                                 int      l4 = 0;
                                                 char     proto = 0;
-                                                
+
                                                 /* Parse this AVP */
                                                 CHECK_FCT( fd_msg_parse_dict ( avp, fd_g_config->cnf_dict, NULL ) );
                                                 ASSERT( ahdr->avp_value );
-                                                
+
                                                 nbrh++;
-                                                
-                                                CHECK_FCT_DO( fd_os_parse_DiameterURI(ahdr->avp_value->os.data, ahdr->avp_value->os.len, 
+
+                                                CHECK_FCT_DO( fd_os_parse_DiameterURI(ahdr->avp_value->os.data, ahdr->avp_value->os.len,
                                                                         &id, &len, &secure, &port, &l4, &proto),
                                                         {
@@ -125 +125 @@
                                                                 break;
                                                         } );
-                                                
+
                                                 /* Now check if the transport & protocol are supported */
                                                 if (proto && (proto != 'd')) {
@@ -137 +137 @@
                                                         break;
                                                 }
-                                                
+
                                                 /* It looks OK, save this entry. */
-                                                
+
                                                 CHECK_MALLOC( h = malloc(sizeof(struct redir_host)) );
                                                 memset(h, 0, sizeof(struct redir_host));
@@ -146 +146 @@
                                                 h->len = len;
                                                 /* later: secure, port */
-                                                
+
                                                 /* The list is kept ordered by id so that it is faster to compare to candidates later */
                                                 for (li = task.rh.next; li != &task.rh; li = li->next) {
@@ -183 +183 @@
                 CHECK_FCT(  fd_msg_browse(avp, MSG_BRW_NEXT, &avp, NULL)  );
         }
-        
+
         /* Check we have received the necessary information */
         if (!a_rc) {
@@ -189 +189 @@
                 goto out;
         }
-        
+
         if (!a_oh) {
                 TRACE_DEBUG(FULL, "Invalid Diameter answer without an Origin-Host AVP, Redirect module gave up");
                 goto out;
         }
-        
+
         if (FD_IS_LIST_EMPTY(&task.rh)) {
                 TRACE_DEBUG(FULL, "Diameter answer with a DIAMETER_REDIRECT_INDICATION Result-Code AVP but no valid/supported Redirect-Host AVP, Redirect module gave up");
@@ -204 +204 @@
                 goto out;
         }
-        
+
         /* It looks like we can process the Redirect indication */
-        
+
         /* Search for the peers we already know */
         for (li = task.rh.next; li != &task.rh; li = li->next) {
                 struct redir_host * h = li->o;
                 struct peer_hdr * peer;
-                
+
                 CHECK_FCT( fd_peer_getbyid( h->id, h->len, 1, &peer ) );
                 if (peer) {
@@ -221 +221 @@
                 }
         }
-        
+
         TRACE_DEBUG(FULL, "Redirect module: received %d Redirect-Hosts, %d are known peers, %d have an OPEN connection", nbrh, known, actives);
-        
+
         /* in this version, we only redirect when there are known active peers. TODO: add new peers via fd_peer_add when no active peer is available */
-        
+
         if (!actives) {
                 TRACE_DEBUG(INFO, "Unable to comply to Redirect indication: none of the peers included is in OPEN state");
                 goto out;
         }
-        
+
         /* From this point, we will re-send the query to a different peer, so stop forwarding the answer here */
         *msg = NULL;
-        
+
         /* Get the query's routing data & add the new error */
         CHECK_FCT( fd_msg_answ_getq(m, &q) );
@@ -239 +239 @@
         CHECK_FCT( fd_msg_source_get( m, &nh, &nhlen ) );
         CHECK_FCT( fd_rtd_error_add(rtd, nh, nhlen, a_oh->os.data, a_oh->os.len, a_rc->u32, NULL, NULL) );
-        
+
         /* Create a redir_rule  */
         CHECK_FCT( redir_entry_new(&entry, &task.rh, task.rhu, q, nh, nhlen, a_oh->os.data, a_oh->os.len) );
-                
+
         CHECK_POSIX(  pthread_mutex_lock(&redir_exp_peer_lock)  );
         /* Insert in the split list */
@@ -253 +253 @@
         CHECK_FCT( fd_msg_answ_detach(m) );
         CHECK_FCT( fd_msg_free(m) );
-        
+
         /* Send it */
         CHECK_FCT( fd_msg_send(&q, NULL, NULL) );
-        
+
         /* Done! */
-        
+
 out:
         while (!FD_IS_LIST_EMPTY(&task.rh)) {
@@ -266 +266 @@
                 free(h);
         }
-                
+
         return 0;