Changeset 1113:eb4ce68b6e5c in freeDiameter for libfdproto/messages.c

Timestamp:

May 13, 2013, 8:17:13 PM (11 years ago)

Author:

Sebastien Decugis <sdecugis@freediameter.net>

Branch:

default

Phase:

public

Message:

Added calls to remaining hooks

File:

• libfdproto/messages.c (modified) (6 diffs)

libfdproto/messages.c

@@ -2670 +2670 @@
 
 /* Call all dispatch callbacks for a given message */
-int fd_msg_dispatch ( struct msg ** msg, struct session * session, enum disp_action *action, char ** error_code)
+int fd_msg_dispatch ( struct msg ** msg, struct session * session, enum disp_action *action, char ** error_code, char ** drop_reason, struct msg ** drop_msg)
 {
         struct dictionary  * dict;
@@ -2684 +2684 @@
         if (error_code)
                 *error_code = NULL;
+        if (drop_reason)
+                *drop_reason = NULL;
         *action = DISP_ACT_CONT;
         
@@ -2691 +2693 @@
         
         /* First, call the DISP_HOW_ANY callbacks */
-        CHECK_FCT_DO( ret = fd_disp_call_cb_int( NULL, msg, NULL, session, action, NULL, NULL, NULL, NULL ), goto out );
+        CHECK_FCT_DO( ret = fd_disp_call_cb_int( NULL, msg, NULL, session, action, NULL, NULL, NULL, NULL, drop_reason, drop_msg ), goto out );
 
         TEST_ACTION_STOP();
@@ -2708 +2710 @@
                         *action = DISP_ACT_ERROR;
                 } else {
-                        //fd_msg_log( FD_MSG_LOG_DROPPED, *msg, "Internal error: Received this answer to a local query with an unsupported application %d", (*msg)->msg_public.msg_appl);
-                        fd_msg_free(*msg);
+                        *drop_reason = "Internal error: Received this answer to a local query with an unsupported application";
+                        *drop_msg = *msg;
                         *msg = NULL;
                 }
@@ -2740 +2742 @@
                         
                         /* Call the callbacks */
-                        CHECK_FCT_DO( ret = fd_disp_call_cb_int( cb_list, msg, avp, session, action, app, cmd, avp->avp_model, enumval ), goto out );
+                        CHECK_FCT_DO( ret = fd_disp_call_cb_int( cb_list, msg, avp, session, action, app, cmd, avp->avp_model, enumval, drop_reason, drop_msg ), goto out );
                         TEST_ACTION_STOP();
                 }
@@ -2749 +2751 @@
         /* Now call command and application callbacks */
         CHECK_FCT_DO( ret = fd_dict_disp_cb(DICT_COMMAND, cmd, &cb_list), goto out );
-        CHECK_FCT_DO( ret = fd_disp_call_cb_int( cb_list, msg, NULL, session, action, app, cmd, NULL, NULL ), goto out );
+        CHECK_FCT_DO( ret = fd_disp_call_cb_int( cb_list, msg, NULL, session, action, app, cmd, NULL, NULL, drop_reason, drop_msg ), goto out );
         TEST_ACTION_STOP();
         
         if (app) {
                 CHECK_FCT_DO( ret = fd_dict_disp_cb(DICT_APPLICATION, app, &cb_list), goto out );
-                CHECK_FCT_DO( ret = fd_disp_call_cb_int( cb_list, msg, NULL, session, action, app, cmd, NULL, NULL ), goto out );
+                CHECK_FCT_DO( ret = fd_disp_call_cb_int( cb_list, msg, NULL, session, action, app, cmd, NULL, NULL, drop_reason, drop_msg ), goto out );
                 TEST_ACTION_STOP();
         }