Return to Pollster.c++ CVS log

Up to [Development] / fam / fam

Annotation of fam/fam/Pollster.c++, Revision 1.1.1.1

1.1       trev        1: //  Copyright (C) 1999 Silicon Graphics, Inc.  All Rights Reserved.
                      2: //
                      3: //  This program is free software; you can redistribute it and/or modify it
                      4: //  under the terms of version 2 of the GNU General Public License as
                      5: //  published by the Free Software Foundation.
                      6: //
                      7: //  This program is distributed in the hope that it would be useful, but
                      8: //  WITHOUT ANY WARRANTY; without even the implied warranty of
                      9: //  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  Further, any
                     10: //  license provided herein, whether implied or otherwise, is limited to
                     11: //  this program in accordance with the express provisions of the GNU
                     12: //  General Public License.  Patent licenses, if any, provided herein do not
                     13: //  apply to combinations of this program with other product or programs, or
                     14: //  any other product whatsoever.  This program is distributed without any
                     15: //  warranty that the program is delivered free of the rightful claim of any
                     16: //  third person by way of infringement or the like.  See the GNU General
                     17: //  Public License for more details.
                     18: //
                     19: //  You should have received a copy of the GNU General Public License along
                     20: //  with this program; if not, write the Free Software Foundation, Inc., 59
                     21: //  Temple Place - Suite 330, Boston MA 02111-1307, USA.
                     22:
                     23: #include "Pollster.h"
                     24:
                     25: #include "Interest.h"
                     26: #include "Log.h"
                     27: #include "Scheduler.h"
                     28: #include "ServerHost.h"
                     29:
                     30: bool		  Pollster::remote_polling_enabled = true;
                     31: timeval		  Pollster::pintvl;  //  set when main() calls interval()
                     32: Set<Interest *>	  Pollster::polled_interests;
                     33: Set<ServerHost *> Pollster::polled_hosts;
                     34: bool		  Pollster::polling = false;
                     35:
                     36: void
                     37: Pollster::watch(Interest *ip)
                     38: {
                     39:     polled_interests.insert(ip);
                     40:
                     41:     if (!polling)
                     42: 	start_polling();
                     43: }
                     44:
                     45: void
                     46: Pollster::forget(Interest *ip)
                     47: {
                     48:     int old_size = polled_interests.size();
                     49:     (void) polled_interests.remove(ip);
                     50:     int new_size = polled_interests.size();
                     51:
                     52:     if (old_size && !new_size && !polled_hosts.size())
                     53: 	stop_polling();
                     54: }
                     55:
                     56: void
                     57: Pollster::watch(ServerHost *ip)
                     58: {
                     59:     if (remote_polling_enabled)
                     60:     {   polled_hosts.insert(ip);
                     61:
                     62: 	if (!polling)
                     63: 	    start_polling();
                     64:     }
                     65: }
                     66:
                     67: void
                     68: Pollster::forget(ServerHost *ip)
                     69: {
                     70:     int old_size = polled_hosts.size();
                     71:     (void) polled_hosts.remove(ip);
                     72:     int new_size = polled_hosts.size();
                     73:
                     74:     if (old_size && !new_size && !polled_interests.size())
                     75: 	stop_polling();
                     76: }
                     77:
                     78: //////////////////////////////////////////////////////////////////////////////
                     79:
                     80: void
                     81: Pollster::start_polling()
                     82: {
                     83:     assert(!polling);
                     84:     assert(polled_interests.size() || polled_hosts.size());
                     85:     Log::debug("polling every %d seconds", pintvl.tv_sec);
                     86:     (void) Scheduler::install_recurring_task(pintvl, polling_task, NULL);
                     87:     polling = true;
                     88: }
                     89:
                     90: void
                     91: Pollster::stop_polling()
                     92: {
                     93:     assert(polling);
                     94:     assert(!polled_interests.size());
                     95:     assert(!polled_hosts.size());
                     96:     (void) Scheduler::remove_recurring_task(polling_task, NULL);
                     97:     polling = false;
                     98:     Log::debug("will stop polling");
                     99: }
                    100:
                    101: void
                    102: Pollster::polling_task(void *)
                    103: {
                    104:     timeval t0, t1;
                    105:     (void) gettimeofday(&t0, NULL);
                    106:
                    107:     int ni = 0;
                    108:     for (Interest *ip = polled_interests.first();
                    109: 	 ip;
                    110: 	 ip = polled_interests.next(ip))
                    111:     {
                    112: 	ip->poll();
                    113: 	ni++;
                    114:     }
                    115:
                    116:     int nh = 0;
                    117:     if (remote_polling_enabled)
                    118: 	for (ServerHost *hp = polled_hosts.first();
                    119: 	     hp;
                    120: 	     hp = polled_hosts.next(hp))
                    121: 	{
                    122: 	    hp->poll();
                    123: 	    nh++;
                    124: 	}
                    125:
                    126:     if ((ni || nh) && (Log::get_level() == Log::DEBUG))
                    127:     {   (void) gettimeofday(&t1, NULL);
                    128: 	double t = t1.tv_sec - t0.tv_sec + (t1.tv_usec - t0.tv_usec)/1000000.0;
                    129: 	Log::debug("polled %d interest%s and %d host%s in %.3f seconds",
                    130: 		   ni, ni == 1 ? "" : "s",
                    131: 		   nh, nh == 1 ? "" : "s",
                    132: 		   t);
                    133:     }
                    134: }