Add the instance id in the sctp_itti_send_new_message_ind

openair3/SCTP/sctp_eNB_itti_messaging.c

@@ -24,7 +24,8 @@
 #include "sctp_common.h"
 #include "sctp_eNB_itti_messaging.h"
 
-int sctp_itti_send_new_message_ind(task_id_t task_id, uint32_t assoc_id, uint8_t *buffer,
+int sctp_itti_send_new_message_ind(task_id_t task_id, instance_t instance, 
+                                   uint32_t assoc_id, uint8_t *buffer,
                                    uint32_t buffer_length, uint16_t stream)
 {
   MessageDef      *message_p;
@@ -43,7 +44,7 @@ int sctp_itti_send_new_message_ind(task_id_t task_id, uint32_t assoc_id, uint8_t
   sctp_data_ind_p->buffer_length = buffer_length;
   sctp_data_ind_p->assoc_id      = assoc_id;
 
-  return itti_send_msg_to_task(task_id, INSTANCE_DEFAULT, message_p);
+  return itti_send_msg_to_task(task_id, instance, message_p);
 }
 
 int sctp_itti_send_association_resp(task_id_t task_id, instance_t instance,

openair3/SCTP/sctp_eNB_itti_messaging.h

@@ -22,7 +22,8 @@
 #ifndef SCTP_ITTI_MESSAGING_H_
 #define SCTP_ITTI_MESSAGING_H_
 
-int sctp_itti_send_new_message_ind(task_id_t task_id, uint32_t assoc_id, uint8_t *buffer,
+int sctp_itti_send_new_message_ind(task_id_t task_id, instance_t instance, 
+	                               uint32_t assoc_id, uint8_t *buffer,
                                    uint32_t buffer_length, uint16_t stream);
 
 int sctp_itti_send_association_resp(task_id_t task_id, instance_t instance,

openair3/SCTP/sctp_eNB_task.c

@@ -749,6 +749,7 @@ sctp_eNB_read_from_socket(
                sinfo.sinfo_stream, ntohl(sinfo.sinfo_ppid));
 
     sctp_itti_send_new_message_ind(sctp_cnx->task_id,
+                                   sctp_cnx->instance,
                                    sinfo.sinfo_assoc_id,
                                    buffer, n, sinfo.sinfo_stream);
   }