--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/servlib/session/SessionTable.cc Thu Apr 21 14:57:45 2011 +0100
@@ -0,0 +1,92 @@
+/*
+ * Copyright 2007 Intel Corporation
+ *
+ * Licensed 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.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include <dtn-config.h>
+#endif
+
+#include <oasys/util/StringBuffer.h>
+
+#include "SessionTable.h"
+#include "Session.h"
+#include "naming/EndpointID.h"
+
+namespace dtn {
+
+//----------------------------------------------------------------------
+SessionTable::SessionTable()
+{
+}
+
+//----------------------------------------------------------------------
+Session*
+SessionTable::lookup_session(const EndpointID& eid) const
+{
+ SessionMap::const_iterator iter = table_.find(eid);
+ if (iter == table_.end())
+ return NULL;
+
+ return iter->second;
+}
+
+//----------------------------------------------------------------------
+void
+SessionTable::add_session(Session* s)
+{
+ ASSERT(lookup_session(s->eid()) == NULL);
+
+ table_[s->eid()] = s;
+}
+
+//----------------------------------------------------------------------
+Session*
+SessionTable::get_session(const EndpointID& eid)
+{
+ Session* session = lookup_session(eid);
+ if (! session) {
+ session = new Session(eid);
+ add_session(session);
+ }
+ return session;
+}
+
+//----------------------------------------------------------------------
+void
+SessionTable::dump(oasys::StringBuffer* buf) const
+{
+ SessionMap::const_iterator i;
+ SubscriberList::const_iterator j;
+ for (i = table_.begin(); i != table_.end(); ++i) {
+
+ Session* session = i->second;
+ buf->appendf(" %s upstream=*%p subscribers=",
+ session->eid().c_str(), &session->upstream());
+
+ for (j = session->subscribers().begin();
+ j != session->subscribers().end(); ++j) {
+
+ const Subscriber& sub = *j;
+ if (sub == session->upstream()) {
+ continue;
+ }
+ buf->appendf("*%p ", &sub);
+ }
+ buf->appendf("\n");
+ }
+}
+
+} // namespace dtn
+