1 files changed, 84 insertions, 0 deletions
diff --git a/ACE/apps/drwho/PM_Server.cpp b/ACE/apps/drwho/PM_Server.cpp
new file mode 100644
index 00000000000..f3068fa45df
--- /dev/null
+++ b/ACE/apps/drwho/PM_Server.cpp
@@ -0,0 +1,84 @@
+// $Id$
+
+#include "Options.h"
+#include "Rwho_DB_Manager.h"
+#include "PM_Server.h"
+#include "ace/ACE.h"
+#include "ace/OS_NS_string.h"
+#include "ace/OS_NS_stdio.h"
+
+// This is the main method for the server side of things.  It reads
+// the RWHO file on the local machine and inserts HOST_NAME
+// information for each LOGIN_NAME that is a friend into the
+// DRWHO_LIST.  This function is also responsible for determining
+// whether a given LOGIN_NAME is currently idle or not.
+
+int
+PM_Server::process (void)
+{
+  RWho_DB_Manager ru;
+  Protocol_Record protocol_record (1);
+
+  while (ru.get_next_user (protocol_record) > 0)
+    this->insert_protocol_info (protocol_record);
+
+  return 1;
+}
+
+// Insert the HOST_NAME into the server's lookup table on behalf of
+// user LOGIN_NAME.  Note that we need to allocate memory for
+// HOST_NAME...
+
+Protocol_Record *
+PM_Server::insert_protocol_info (Protocol_Record &protocol_record)
+{
+  Protocol_Record *prp = this->ss->insert (protocol_record.get_login ());
+
+  Drwho_Node *current_node = protocol_record.get_drwho_list ();
+
+  if (current_node->get_idle_time () < MAX_USER_TIMEOUT)
+        this->increment_total_users ();
+
+  if (prp)
+    {
+      Drwho_Node *np =
+        this->get_drwho_node (ACE::strnew (current_node->get_host_name ()),
+                              prp->drwho_list_);
+
+      if (current_node->get_idle_time () >= MAX_USER_TIMEOUT)
+        np->inactive_count_++;
+      else
+        np->active_count_++;
+    }
+
+  return prp;
+}
+
+// Put the inactive and active counts, plus the hostname into the
+// packet.
+
+char *
+PM_Server::handle_protocol_entries (char *buf_ptr,
+                                    Drwho_Node *np)
+{
+
+  for (; np != 0; np = np->next_)
+    {
+      ACE_OS::sprintf (buf_ptr,
+                       "%d %d %s",
+                       np->get_inactive_count (),
+                       np->get_active_count (),
+                       np->get_host_name ());
+      buf_ptr += ACE_OS::strlen (buf_ptr) + 1;
+    }
+
+  return buf_ptr;
+}
+
+PM_Server::PM_Server (void)
+{
+}
+
+PM_Server::~PM_Server (void)
+{
+}