ACE/apps/drwho/PM_Client.cpp

   1 #include "Options.h"
   2 #include "PM_Server.h"
   3 #include "PM_Client.h"
   4 #include "ace/ACE.h"
   5 #include "ace/Log_Msg.h"
   6 #include "ace/OS_NS_string.h"
   7 #include "ace/OS_NS_stdlib.h"
   8
   9 // This function is used to merge the LOGIN_NAME from server HOST_NAME
  10 // into the userids kept on the client's side.  Note that we must
  11 // allocate memory for HOST_NAME...
  12
  13 Protocol_Record *
  14 PM_Client::insert_protocol_info (Protocol_Record &protocol_record)
  15 {
  16   Protocol_Record *prp = this->ss->insert (protocol_record.get_login ());
  17   Drwho_Node *current_node = protocol_record.get_drwho_list ();
  18   Drwho_Node *np = this->get_drwho_node (ACE::strnew (current_node->get_host_name ()),
  19                                          prp->drwho_list_);
  20
  21   // Update the active and inactive counts.
  22
  23   if (np->get_active_count () < current_node->get_active_count ())
  24     {
  25       np->set_active_count (current_node->get_active_count ());
  26       prp->is_active_ = 1;
  27     }
  28
  29   if (np->get_inactive_count () < current_node->get_inactive_count())
  30     np->set_inactive_count (current_node->get_inactive_count ());
  31
  32   return prp;
  33 }
  34
  35 // This routine does all the dirty work, and actually prints out the
  36 // friends info in a nicely formatted manner.
  37
  38 void
  39 PM_Client::process ()
  40 {
  41   const char *(Protocol_Record::*get_name)();
  42
  43   if (Options::get_opt (Options::PRINT_LOGIN_NAME))
  44     get_name = &Protocol_Record::get_login;
  45   else
  46     get_name = &Protocol_Record::get_real;
  47
  48   int active_friends = 0;
  49   int users = this->Protocol_Manager::get_total_users ();
  50
  51   ACE_DEBUG ((LM_DEBUG,
  52               "------------------------\n"));
  53
  54   if (Options::get_opt (Options::PRINT_LOGIN_NAME))
  55     this->max_key_length = MAXUSERIDNAMELEN;
  56
  57   // Goes through the queue of all the logged in friends and prints
  58   // out the associated information.
  59
  60   for (Protocol_Record *prp = this->Protocol_Manager::get_each_friend ();
  61        prp != 0;
  62        prp = this->Protocol_Manager::get_each_friend ())
  63     {
  64       ACE_DEBUG ((LM_DEBUG,
  65                   "%c%-*s [", (prp->is_active_ != 0 ? '*' : ' '),
  66                   this->max_key_length,
  67                   (prp->*get_name) ()));
  68
  69       for (Drwho_Node *np = prp->get_drwho_list (); ;)
  70         {
  71           ACE_DEBUG ((LM_DEBUG,
  72                       np->get_host_name (),
  73                       stdout));
  74
  75           active_friends += np->get_active_count ();
  76
  77           if (np->get_inactive_count () != 0)
  78             {
  79               if (np->get_active_count () != 0)
  80                 ACE_DEBUG ((LM_DEBUG,
  81                             "*(%d)",
  82                             np->get_active_count ()));
  83             }
  84           else if (np->get_active_count () > 1)
  85             ACE_DEBUG ((LM_DEBUG,
  86                         "*(%d)",
  87                         np->get_active_count ()));
  88           else if (np->get_active_count () == 1)
  89             ACE_DEBUG ((LM_DEBUG,
  90                         "*"));
  91
  92           np = np->next_;
  93           if (np == 0)
  94             break;
  95           else
  96             ACE_DEBUG ((LM_DEBUG,
  97                         " "));
  98         }
  99
 100       ACE_DEBUG ((LM_DEBUG,
 101                   "]\n"));
 102     }
 103
 104   ACE_DEBUG ((LM_DEBUG,
 105               "------------------------\n"));
 106   ACE_DEBUG ((LM_DEBUG,
 107               "friends: %d\tusers: %d\n",
 108               active_friends,
 109               users));
 110 }
 111
 112 char *
 113 PM_Client::handle_protocol_entries (const char *cp,
 114                                     const char *login_name,
 115                                     const char *real_name)
 116 {
 117   static Protocol_Record protocol_record (1);
 118   Drwho_Node *current_node = protocol_record.get_drwho_list ();
 119
 120   protocol_record.set_login (login_name);
 121   protocol_record.set_real (real_name);
 122   current_node->set_inactive_count (ACE_OS::atoi (cp));
 123   current_node->set_active_count (ACE_OS::atoi (cp = ACE_OS::strchr (cp, ' ') + 1));
 124   current_node->set_host_name (cp = ACE_OS::strchr (cp, ' ') + 1);
 125
 126   this->insert_protocol_info (protocol_record);
 127
 128   return (char *) ACE::strend (cp);
 129 }
 130
 131 PM_Client::PM_Client ()
 132   : max_key_length (0)
 133 {
 134 }
 135
 136 PM_Client::~PM_Client ()
 137 {
 138 }