itti_msg_sxyz messages

src/common/msg/itti_async_shell_cmd.hpp

+/*
+ * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The OpenAirInterface Software Alliance licenses this file to You under
+ * the OAI Public License, Version 1.1  (the "License"); you may not use this file
+ * except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.openairinterface.org/?page_id=698
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *-------------------------------------------------------------------------------
+ * For more information about the OpenAirInterface (OAI) Software Alliance:
+ *      contact@openairinterface.org
+ */
+
+/*! \file itti_async_shell_cmd.hpp
+  \brief
+  \author Lionel Gauthier
+  \company Eurecom
+  \email: lionel.gauthier@eurecom.fr
+*/
+
+#ifndef FILE_ITTI_ASYNC_SHELL_CMD_SEEN
+#define FILE_ITTI_ASYNC_SHELL_CMD_SEEN
+
+#include "itti_msg.hpp"
+
+namespace oai::cn::core::itti {
+
+class itti_async_shell_cmd : public  itti_msg {
+public:
+  itti_async_shell_cmd(const  task_id_t origin, const  task_id_t destination, const std::string& system_cmd, bool is_abort_on_error, const char * src_file, const int src_line):
+    itti_msg( ASYNC_SHELL_CMD, origin, destination), system_command(system_cmd), is_abort_on_error(is_abort_on_error), src_file(src_file), src_line(src_line)  {}
+  itti_async_shell_cmd(const itti_async_shell_cmd& i) :
+    itti_msg(i), system_command(i.system_command), is_abort_on_error(i.is_abort_on_error), src_file(i.src_file), src_line(i.src_line) {}
+  const char* get_msg_name() {return typeid( itti_msg_ping).name();};
+  std::string              system_command;
+  bool                     is_abort_on_error;
+  // debug
+  std::string              src_file;
+  int                      src_line;
+} ;
+}
+#endif /* FILE_ITTI_ASYNC_SHELL_CMD_SEEN */

src/common/msg/itti_msg_s1u.hpp

+/*
+ * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The OpenAirInterface Software Alliance licenses this file to You under
+ * the Apache License, Version 2.0  (the "License"); you may not use this file
+ * except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *-------------------------------------------------------------------------------
+ * For more information about the OpenAirInterface (OAI) Software Alliance:
+ *      contact@openairinterface.org
+ */
+
+/*
+ *  itti_msg_s1u.hpp
+ *
+ *  Created on: Feb 05, 2019
+ *  Author: lionel.gauthier@eurecom.fr
+ */
+
+#ifndef ITTI_MSG_S1U_HPP_INCLUDED_
+#define ITTI_MSG_S1U_HPP_INCLUDED_
+
+#include "itti_msg.hpp"
+#include "3gpp_29.281.hpp"
+#include "msg_gtpv1u.hpp"
+
+#include <sys/socket.h>
+
+namespace oai::cn::core::itti {
+
+class itti_s1u_msg : public itti_msg {
+public:
+  itti_s1u_msg(const itti_msg_type_t  msg_type, const task_id_t orig, const task_id_t dest):
+    itti_msg(msg_type, orig, dest) {
+    l_endpoint = {};
+    l_endpoint_addr_len = sizeof(l_endpoint);
+    r_endpoint = {};
+    l_endpoint_addr_len = sizeof(r_endpoint);
+    teid = UNASSIGNED_TEID;
+    gtpu_tx_id = 0;
+  }
+
+  itti_s1u_msg(const itti_s1u_msg& i) : itti_msg(i)  {
+    l_endpoint = i.l_endpoint;
+    l_endpoint_addr_len = i.l_endpoint_addr_len;
+    r_endpoint = i.r_endpoint;
+    r_endpoint_addr_len = i.r_endpoint_addr_len;
+    teid = i.teid;
+    gtpu_tx_id = i.gtpu_tx_id;
+  }
+
+  itti_s1u_msg(const itti_s1u_msg& i, const task_id_t orig, const task_id_t dest) : itti_s1u_msg(i)  {
+    origin = orig;
+    destination = dest;
+  }
+
+  struct sockaddr_storage l_endpoint;
+  socklen_t               l_endpoint_addr_len;
+  struct sockaddr_storage r_endpoint;
+  socklen_t               r_endpoint_addr_len;
+  teid_t                  teid;
+  uint64_t                gtpu_tx_id;
+};
+//------------------------------------------------------------------------------
+class itti_s1u_echo_request : public itti_s1u_msg {
+public:
+  itti_s1u_echo_request(const task_id_t orig, const task_id_t dest):
+    itti_s1u_msg(S1U_ECHO_REQUEST, orig, dest) {
+  }
+  itti_s1u_echo_request(const itti_s1u_echo_request& i) : itti_s1u_msg(i)  {
+    gtp_ies = i.gtp_ies;
+  }
+  itti_s1u_echo_request(const itti_s1u_echo_request& i, const task_id_t orig, const task_id_t dest) :
+    itti_s1u_msg(i, orig, dest)  {
+    gtp_ies = i.gtp_ies;
+  }
+  const char* get_msg_name() {return typeid(itti_s1u_echo_request).name();};
+
+  proto::gtpv1u::gtpv1u_echo_request gtp_ies;
+};
+//------------------------------------------------------------------------------
+class itti_s1u_echo_response : public itti_s1u_msg {
+public:
+  itti_s1u_echo_response(const task_id_t orig, const task_id_t dest):
+    itti_s1u_msg(S1U_ECHO_RESPONSE, orig, dest) {
+  }
+  itti_s1u_echo_response(const itti_s1u_echo_response& i) : itti_s1u_msg(i)  {
+    gtp_ies = i.gtp_ies;
+  }
+  itti_s1u_echo_response(const itti_s1u_echo_response& i, const task_id_t orig, const task_id_t dest) :
+    itti_s1u_msg(i, orig, dest)  {
+    gtp_ies = i.gtp_ies;
+  }
+  const char* get_msg_name() {return typeid(itti_s1u_echo_response).name();};
+
+  proto::gtpv1u::gtpv1u_echo_response gtp_ies;
+};
+//------------------------------------------------------------------------------
+class itti_s1u_error_indication : public itti_s1u_msg {
+public:
+  itti_s1u_error_indication(const task_id_t orig, const task_id_t dest):
+    itti_s1u_msg(S1U_ERROR_INDICATION, orig, dest) {
+  }
+  itti_s1u_error_indication(const itti_s1u_error_indication& i) : itti_s1u_msg(i)  {
+    gtp_ies = i.gtp_ies;
+  }
+  itti_s1u_error_indication(const itti_s1u_error_indication& i, const task_id_t orig, const task_id_t dest) :
+    itti_s1u_msg(i, orig, dest)  {
+    gtp_ies = i.gtp_ies;
+  }
+  const char* get_msg_name() {return typeid(itti_s1u_error_indication).name();};
+
+  proto::gtpv1u::gtpv1u_error_indication gtp_ies;
+};
+//------------------------------------------------------------------------------
+class itti_s1u_supported_extension_headers_notification : public itti_s1u_msg {
+public:
+  itti_s1u_supported_extension_headers_notification(const task_id_t orig, const task_id_t dest):
+    itti_s1u_msg(S1U_SUPPORTED_EXTENSION_HEADERS_NOTIFICATION, orig, dest) {
+  }
+  itti_s1u_supported_extension_headers_notification(const itti_s1u_supported_extension_headers_notification& i) : itti_s1u_msg(i)  {
+    gtp_ies = i.gtp_ies;
+  }
+  itti_s1u_supported_extension_headers_notification(const itti_s1u_supported_extension_headers_notification& i, const task_id_t orig, const task_id_t dest) :
+    itti_s1u_msg(i, orig, dest)  {
+    gtp_ies = i.gtp_ies;
+  }
+  const char* get_msg_name() {return typeid(itti_s1u_supported_extension_headers_notification).name();};
+
+  proto::gtpv1u::gtpv1u_supported_extension_headers_notification gtp_ies;
+};
+//------------------------------------------------------------------------------
+class itti_s1u_end_marker : public itti_s1u_msg {
+public:
+  itti_s1u_end_marker(const task_id_t orig, const task_id_t dest):
+    itti_s1u_msg(S1U_END_MARKER, orig, dest) {
+  }
+  itti_s1u_end_marker(const itti_s1u_end_marker& i) : itti_s1u_msg(i)  {
+    gtp_ies = i.gtp_ies;
+  }
+  itti_s1u_end_marker(const itti_s1u_end_marker& i, const task_id_t orig, const task_id_t dest) :
+    itti_s1u_msg(i, orig, dest)  {
+    gtp_ies = i.gtp_ies;
+  }
+  const char* get_msg_name() {return typeid(itti_s1u_end_marker).name();};
+
+  proto::gtpv1u::gtpv1u_end_marker gtp_ies;
+};
+
+} // namespace itti
+
+#endif /* ITTI_MSG_S1U_HPP_INCLUDED_ */