ACE/apps/drwho/PM_Server.cpp

   1 #include "Options.h"
   2 #include "Rwho_DB_Manager.h"
   3 #include "PM_Server.h"
   4 #include "ace/ACE.h"
   5 #include "ace/OS_NS_string.h"
   6 #include "ace/OS_NS_stdio.h"
   7
   8 // This is the main method for the server side of things.  It reads
   9 // the RWHO file on the local machine and inserts HOST_NAME
  10 // information for each LOGIN_NAME that is a friend into the
  11 // DRWHO_LIST.  This function is also responsible for determining
  12 // whether a given LOGIN_NAME is currently idle or not.
  13
  14 int
  15 PM_Server::process ()
  16 {
  17   RWho_DB_Manager ru;
  18   Protocol_Record protocol_record (1);
  19
  20   while (ru.get_next_user (protocol_record) > 0)
  21     this->insert_protocol_info (protocol_record);
  22
  23   return 1;
  24 }
  25
  26 // Insert the HOST_NAME into the server's lookup table on behalf of
  27 // user LOGIN_NAME.  Note that we need to allocate memory for
  28 // HOST_NAME...
  29
  30 Protocol_Record *
  31 PM_Server::insert_protocol_info (Protocol_Record &protocol_record)
  32 {
  33   Protocol_Record *prp = this->ss->insert (protocol_record.get_login ());
  34
  35   Drwho_Node *current_node = protocol_record.get_drwho_list ();
  36
  37   if (current_node->get_idle_time () < MAX_USER_TIMEOUT)
  38         this->increment_total_users ();
  39
  40   if (prp)
  41     {
  42       Drwho_Node *np =
  43         this->get_drwho_node (ACE::strnew (current_node->get_host_name ()),
  44                               prp->drwho_list_);
  45
  46       if (current_node->get_idle_time () >= MAX_USER_TIMEOUT)
  47         np->inactive_count_++;
  48       else
  49         np->active_count_++;
  50     }
  51
  52   return prp;
  53 }
  54
  55 // Put the inactive and active counts, plus the hostname into the
  56 // packet.
  57
  58 char *
  59 PM_Server::handle_protocol_entries (char *buf_ptr,
  60                                     Drwho_Node *np)
  61 {
  62   for (; np != 0; np = np->next_)
  63     {
  64       ACE_OS::sprintf (buf_ptr,
  65                        "%d %d %s",
  66                        np->get_inactive_count (),
  67                        np->get_active_count (),
  68                        np->get_host_name ());
  69       buf_ptr += ACE_OS::strlen (buf_ptr) + 1;
  70     }
  71
  72   return buf_ptr;
  73 }
  74
  75 PM_Server::PM_Server ()
  76 {
  77 }
  78
  79 PM_Server::~PM_Server ()
  80 {
  81 }