1 files changed, 86 insertions, 0 deletions
diff --git a/src/gprs_ms_storage.cpp b/src/gprs_ms_storage.cpp
new file mode 100644
index 00000000..7260f1bb
--- /dev/null
+++ b/src/gprs_ms_storage.cpp
@@ -0,0 +1,86 @@
+/* gprs_ms_storage.cpp
+ *
+ * Copyright (C) 2015 by Sysmocom s.f.m.c. GmbH
+ * Author: Jacob Erlbeck <jerlbeck@sysmocom.de>
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU General Public License
+ * as published by the Free Software Foundation; either version 2
+ * of the License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+ */
+
+
+#include "gprs_ms_storage.h"
+
+#include "tbf.h"
+#include "gprs_debug.h"
+
+GprsMsStorage::GprsMsStorage()
+{
+}
+
+GprsMsStorage::~GprsMsStorage()
+{
+	LListHead<GprsMs> *pos, *tmp;
+
+	llist_for_each_safe(pos, tmp, &m_list) {
+		GprsMs *ms = pos->entry();
+		ms->set_callback(NULL);
+		ms_idle(ms);
+	}
+}
+
+void GprsMsStorage::ms_idle(class GprsMs *ms)
+{
+	llist_del(&ms->list());
+	if (ms->is_idle())
+		delete ms;
+}
+
+void GprsMsStorage::ms_active(class GprsMs *ms)
+{
+	/* Nothing to do */
+}
+
+GprsMs *GprsMsStorage::get_ms(uint32_t tlli, uint32_t old_tlli, const char *imsi) const
+{
+	GprsMs *ms = NULL;
+	LListHead<GprsMs> *pos;
+
+	llist_for_each(pos, &m_list) {
+		ms = pos->entry();
+		if (tlli && ms->tlli() == tlli)
+			break;
+		if (old_tlli && ms->tlli() == old_tlli)
+			break;
+		/* TODO: Check for IMSI */
+
+		/* not found */
+		ms = NULL;
+	}
+
+	return ms;
+}
+
+GprsMs *GprsMsStorage::get_or_create_ms(uint32_t tlli, uint32_t old_tlli, const char *imsi)
+{
+	GprsMs *ms = get_ms(tlli, old_tlli, imsi);
+
+	if (ms)
+		return ms;
+
+	ms = new GprsMs(tlli);
+	ms->set_callback(this);
+	llist_add(&ms->list(), &m_list);
+
+	return ms;
+}