aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/common/oml.c121
-rw-r--r--src/osmo-bts-sysmo/main.c2
-rw-r--r--src/osmo-bts-sysmo/utils.c121
-rw-r--r--src/osmo-bts-sysmo/utils.h7
4 files changed, 123 insertions, 128 deletions
diff --git a/src/common/oml.c b/src/common/oml.c
index b7c12f7c..6cb8e56e 100644
--- a/src/common/oml.c
+++ b/src/common/oml.c
@@ -93,6 +93,7 @@ static struct tlv_definition abis_nm_att_tlvdef_ipa = {
/* ip.access nanoBTS specific commands */
static const char ipaccess_magic[] = "com.ipaccess";
+static const char osmocom_magic[] = "org.osmocom";
static int oml_ipa_set_attr(struct gsm_bts *bts, struct msgb *msg);
/*
@@ -159,6 +160,126 @@ struct msgb *oml_msgb_alloc(void)
return msgb_alloc_headroom(1024, 128, "OML");
}
+int oml_check_manuf(struct abis_om_hdr *hdr, size_t msg_size)
+{
+ if (msg_size < 1) {
+ LOGP(DL1C, LOGL_ERROR, "No ManId Length Indicator %d\n",
+ msg_size);
+ return -1;
+ }
+
+ if (hdr->data[0] >= msg_size - 1) {
+ LOGP(DL1C, LOGL_ERROR,
+ "Insuficient message space for this ManId Lenght %d %d\n",
+ hdr->data[0], msg_size - 1);
+ return -1;
+ }
+
+ if (hdr->data[0] == sizeof(ipaccess_magic) &&
+ strncmp(ipaccess_magic, (const char *)hdr->data + 1,
+ sizeof(ipaccess_magic)) == 0) {
+ return OML_MSG_TYPE_IPA;
+ } else if (hdr->data[0] == sizeof(osmocom_magic) &&
+ strncmp(osmocom_magic, (const char *) hdr->data + 1,
+ sizeof(osmocom_magic)) == 0) {
+ return OML_MSG_TYPE_OSMO;
+ } else {
+ LOGP(DL1C, LOGL_ERROR,
+ "Manuf Label Unknown\n");
+ return -1;
+ }
+}
+
+static int oml_check_fom(struct abis_om_hdr *omh, size_t len)
+{
+ if (omh->length != len) {
+ LOGP(DL1C, LOGL_ERROR, "Incorrect om length value %d %d\n",
+ omh->length, len);
+ return -1;
+ }
+
+ if (len < sizeof(struct abis_om_fom_hdr)) {
+ LOGP(DL1C, LOGL_ERROR, "Fom header insufficient space %d %d\n",
+ len, sizeof(struct abis_om_fom_hdr));
+ return -1;
+ }
+
+ return 0;
+}
+
+/**
+ * \brief Check that the data in \param msg is a proper OML message
+ *
+ * This function verifies that the data in \param in msg is a proper
+ * OML message and can be handled by later functions. In the successful
+ * case the msg->l2h will now point to the OML header and the msg->l3h
+ * will point to the FOM header. The value of l2h/l3h is undefined in
+ * case the verification of the \param msg is failing.
+ *
+ * \param msg The message to analyze. msg->len starting from msg->data
+ * will be analyzed.
+ * \return This function returns the msg with the l2h/l3h pointers in the right
+ * direction on success and on failure, in the case that the msg doesn't contain
+ * the OML header or the OML header values aren't the expect, the function
+ * doesn't set the l2h and l3h. In the case that the msg don't contains the FOM
+ * header or the FOM header values aren't the expect, the function set the l2h
+ * but doesn't set the l3h.
+ */
+
+int oml_check_msg(struct msgb *msg)
+{
+ struct abis_om_hdr *omh;
+ int ret = OML_MSG_TYPE_ETSI;
+
+ if (msg->len < sizeof(*omh)) {
+ LOGP(DL1C, LOGL_ERROR, "Om header insufficient space %d %d\n",
+ msg->len, sizeof(*omh));
+ return -1;
+ }
+
+ msg->l2h = msg->data;
+
+ omh = (struct abis_om_hdr *) msg->l2h;
+
+ if (omh->mdisc != ABIS_OM_MDISC_FOM &&
+ omh->mdisc != ABIS_OM_MDISC_MANUF) {
+ LOGP(DL1C, LOGL_ERROR, "Incorrect om mdisc value %x\n",
+ omh->mdisc);
+ return -1;
+ }
+
+ if (omh->placement != ABIS_OM_PLACEMENT_ONLY) {
+ LOGP(DL1C, LOGL_ERROR, "Incorrect om placement value %x %x\n",
+ omh->placement, ABIS_OM_PLACEMENT_ONLY);
+ return -1;
+ }
+
+ if (omh->sequence != 0) {
+ LOGP(DL1C, LOGL_ERROR, "Incorrect om sequence value %d\n",
+ omh->sequence);
+ return -1;
+ }
+
+ if (omh->mdisc == ABIS_OM_MDISC_MANUF)
+ ret = oml_check_manuf(omh, msgb_l2len(msg) - sizeof(*omh));
+
+ if (ret == OML_MSG_TYPE_OSMO)
+ msg->l3h = omh->data + sizeof(osmocom_magic) + 1;
+ else if (ret == OML_MSG_TYPE_IPA)
+ msg->l3h = omh->data + sizeof(ipaccess_magic) + 1;
+ else if (ret == OML_MSG_TYPE_ETSI)
+ msg->l3h = omh->data;
+ else
+ msg->l3h = NULL;
+
+ if (ret < 0)
+ return -1;
+
+ oml_check_fom(omh, msgb_l3len(msg));
+
+ return ret;
+}
+
int oml_send_msg(struct msgb *msg, int is_manuf)
{
struct abis_om_hdr *omh;
diff --git a/src/osmo-bts-sysmo/main.c b/src/osmo-bts-sysmo/main.c
index 81f6474c..48342fab 100644
--- a/src/osmo-bts-sysmo/main.c
+++ b/src/osmo-bts-sysmo/main.c
@@ -325,7 +325,7 @@ static int read_sock(struct osmo_fd *fd, unsigned int what)
msgb_pull(msg, sizeof(struct ipaccess_head));
- rc = check_oml_msg(msg);
+ rc = oml_check_msg(msg);
if (rc < 0) {
LOGP(DL1C, LOGL_ERROR, "Malformed receive message\n");
goto err;
diff --git a/src/osmo-bts-sysmo/utils.c b/src/osmo-bts-sysmo/utils.c
index f867a424..bd75c81d 100644
--- a/src/osmo-bts-sysmo/utils.c
+++ b/src/osmo-bts-sysmo/utils.c
@@ -26,6 +26,7 @@
#include <osmo-bts/bts.h>
#include <osmo-bts/gsm_data.h>
#include <osmo-bts/logging.h>
+#include <osmo-bts/oml.h>
#include <osmocom/core/msgb.h>
#include <osmocom/gsm/protocol/ipaccess.h>
@@ -160,126 +161,6 @@ void prepend_oml_ipa_header(struct msgb *msg)
hh->len = htons(msg->len - sizeof(struct ipaccess_head));
}
-static int check_oml_fom(struct abis_om_hdr *omh, size_t len)
-{
- if (omh->length != len) {
- LOGP(DL1C, LOGL_ERROR, "Incorrect om length value %d %d\n",
- omh->length, len);
- return -1;
- }
-
- if (len < sizeof(struct abis_om_fom_hdr)) {
- LOGP(DL1C, LOGL_ERROR, "Fom header insufficient space %d %d\n",
- len, sizeof(struct abis_om_fom_hdr));
- return -1;
- }
-
- return 0;
-}
-
-static int check_oml_manuf(struct abis_om_hdr *hdr, size_t msg_size)
-{
- if (msg_size < 1) {
- LOGP(DL1C, LOGL_ERROR, "No ManId Length Indicator %d\n",
- msg_size);
- return -1;
- }
-
- if (hdr->data[0] >= msg_size - 1) {
- LOGP(DL1C, LOGL_ERROR,
- "Insuficient message space for this ManId Lenght %d %d\n",
- hdr->data[0], msg_size - 1);
- return -1;
- }
-
- if (hdr->data[0] == sizeof(ipaccess_magic) &&
- strncmp(ipaccess_magic, (const char *)hdr->data + 1,
- sizeof(ipaccess_magic)) == 0) {
- return OML_MSG_TYPE_IPA;
- } else if (hdr->data[0] == sizeof(osmocom_magic) &&
- strncmp(osmocom_magic, (const char *) hdr->data + 1,
- sizeof(osmocom_magic)) == 0) {
- return OML_MSG_TYPE_OSMO;
- } else {
- LOGP(DL1C, LOGL_ERROR,
- "Manuf Label Unknown\n");
- return -1;
- }
-}
-
-/**
- * \brief Check that the data in \param msg is a proper OML message
- *
- * This function verifies that the data in \param in msg is a proper
- * OML message and can be handled by later functions. In the successful
- * case the msg->l2h will now point to the OML header and the msg->l3h
- * will point to the FOM header. The value of l2h/l3h is undefined in
- * case the verification of the \param msg is failing.
- *
- * \param msg The message to analyze. msg->len starting from msg->data
- * will be analyzed.
- * \return This function returns the msg with the l2h/l3h pointers in the right
- * direction on success and on failure, in the case that the msg doesn't contain
- * the OML header or the OML header values aren't the expect, the function
- * doesn't set the l2h and l3h. In the case that the msg don't contains the FOM
- * header or the FOM header values aren't the expect, the function set the l2h
- * but doesn't set the l3h.
- */
-
-int check_oml_msg(struct msgb *msg)
-{
- struct abis_om_hdr *omh;
- int ret = OML_MSG_TYPE_ETSI;
-
- if (msg->len < sizeof(*omh)) {
- LOGP(DL1C, LOGL_ERROR, "Om header insufficient space %d %d\n",
- msg->len, sizeof(*omh));
- return -1;
- }
-
- msg->l2h = msg->data;
-
- omh = (struct abis_om_hdr *) msg->l2h;
-
- if (omh->mdisc != ABIS_OM_MDISC_FOM &&
- omh->mdisc != ABIS_OM_MDISC_MANUF) {
- LOGP(DL1C, LOGL_ERROR, "Incorrect om mdisc value %x\n",
- omh->mdisc);
- return -1;
- }
-
- if (omh->placement != ABIS_OM_PLACEMENT_ONLY) {
- LOGP(DL1C, LOGL_ERROR, "Incorrect om placement value %x %x\n",
- omh->placement, ABIS_OM_PLACEMENT_ONLY);
- return -1;
- }
-
- if (omh->sequence != 0) {
- LOGP(DL1C, LOGL_ERROR, "Incorrect om sequence value %d\n",
- omh->sequence);
- return -1;
- }
-
- if (omh->mdisc == ABIS_OM_MDISC_MANUF)
- ret = check_oml_manuf(omh, msgb_l2len(msg) - sizeof(*omh));
-
- if (ret == OML_MSG_TYPE_OSMO)
- msg->l3h = omh->data + sizeof(osmocom_magic) + 1;
- else if (ret == OML_MSG_TYPE_IPA)
- msg->l3h = omh->data + sizeof(ipaccess_magic) + 1;
- else if (ret == OML_MSG_TYPE_ETSI)
- msg->l3h = omh->data;
- else
- msg->l3h = NULL;
-
- if (ret < 0)
- return -1;
-
- check_oml_fom(omh, msgb_l3len(msg));
-
- return ret;
-}
-
int check_ipa_header(struct msgb *msg)
{
struct ipaccess_head *hh;
diff --git a/src/osmo-bts-sysmo/utils.h b/src/osmo-bts-sysmo/utils.h
index c38757e3..3038d22a 100644
--- a/src/osmo-bts-sysmo/utils.h
+++ b/src/osmo-bts-sysmo/utils.h
@@ -21,12 +21,6 @@ enum manuf_type_id {
MANUF_ID_OSMO,
};
-enum oml_message_type {
- OML_MSG_TYPE_ETSI,
- OML_MSG_TYPE_IPA,
- OML_MSG_TYPE_OSMO,
-};
-
static const char osmocom_magic[] = "org.osmocom";
static const char ipaccess_magic[] = "com.ipaccess";
@@ -34,6 +28,5 @@ int add_manufacturer_id_label(struct msgb *msg, enum manuf_type_id type_id);
void prepend_oml_ipa_header(struct msgb *msg);
-int check_oml_msg(struct msgb *msg);
int check_ipa_header(struct msgb *msg);
#endif
generated by cgit v1.2.3 (git 2.25.1) at 2024-06-03 18:07:33 +0000