Timer_Helper Class Reference

Timer Helper for the clerk. More...

#include <Timer_Helper.h>

Inheritance diagram for Timer_Helper:

[legend]Collaboration diagram for Timer_Helper:

[legend]List of all members.

Public Member Functions
	Timer_Helper (void)
	Constructor.
	~Timer_Helper (void)
	Destructor.
	Timer_Helper (TAO_Time_Service_Clerk *clerk)
	Constructor that sets the clerk.
int	handle_timeout (const ACE_Time_Value &time, const void *arg)
Protected Types
typedef ACE_Array_Base< CosTime::TimeService_var >	IORS
	The set of server IORs.
Protected Attributes
TAO_Time_Service_Clerk *	clerk_
	Clerk's instance that this class helps to update time.

---

Detailed Description

Timer Helper for the clerk.

The handle timeout method of this class is called periodically by the reactor. This method updates the clerk's notion of globally synchronized time by contacting the various Time Servers.

Definition at line 50 of file Timer_Helper.h.

---

Member Typedef Documentation

typedef ACE_Array_Base<CosTime::TimeService_var> Timer_Helper::IORS [protected]

The set of server IORs.

Definition at line 73 of file Timer_Helper.h.

---

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL Timer_Helper::Timer_Helper

(

void

)

Constructor.

Definition at line 16 of file Timer_Helper.cpp.

  : clerk_ (0)
{
}

Timer_Helper::~Timer_Helper

(

void

)

Destructor.

Definition at line 27 of file Timer_Helper.cpp.

{
}

Timer_Helper::Timer_Helper

(

TAO_Time_Service_Clerk *

clerk

)

Constructor that sets the clerk.

Definition at line 21 of file Timer_Helper.cpp.

  : clerk_ (clerk)
{

}

---

Member Function Documentation

int Timer_Helper::handle_timeout	(	const ACE_Time_Value &	time,
		const void *	arg
	)			[virtual]

This method is called periodically by the Reactor to update the clerk's time.

Reimplemented from ACE_Event_Handler.

Definition at line 32 of file Timer_Helper.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, ACE_UINT64_LITERAL, clerk_, ACE_OS::gettimeofday(), TAO_Time_Service_Clerk::inaccuracy(), LM_DEBUG, ACE_Time_Value::sec(), TAO_debug_level, time(), TAO_Time_Service_Clerk::time_, TAO_Time_Service_Clerk::time_displacement_factor(), ACE_OS::timezone(), ACE_OS::tzset(), TAO_Time_Service_Clerk::update_timestamp_, and ACE_Time_Value::usec().

{
  int no_of_servers = 0;
  CORBA::ULongLong sum = 0;

  // The following are used to keep a track of the inaccuracy
  // in synchronization.

#if defined (ACE_LACKS_LONGLONG_T)
  CORBA::ULongLong lowest_time (0xFFFFFFFF, 0xFFFFFFFF);
#else
  CORBA::ULongLong lowest_time = ACE_UINT64_LITERAL (0xFFFFFFFFFFFFFFFF);
#endif

  CORBA::ULongLong highest_time  = 0;

  try
    {
      IORS::TYPE* value;
      for (IORS::ITERATOR server_iterator (this->clerk_->server_);
           server_iterator.next (value) != 0;
           server_iterator.advance ())
        {
          // This is a remote call.
          CosTime::UTO_var UTO_server =
            (*value)->universal_time ();

#if defined (ACE_LACKS_LONGLONG_T)

          if (TAO_debug_level > 0)
            ACE_DEBUG ((LM_DEBUG,
                        "\nTime = %Q\nInaccuracy = %Q\nTimeDiff = %d\nstruct.time = %Q\n"
                        "struct.inacclo = %d\nstruct.inacchi = %d\nstruct.Tdf = %d\n",
                        ACE_U64_TO_U32 (UTO_server->time ()),
                        ACE_U64_TO_U32 (UTO_server->inaccuracy ()),
                        UTO_server->tdf (),
                        ACE_U64_TO_U32 ((UTO_server->utc_time ()).time),
                        (UTO_server->utc_time ()).inacclo,
                        (UTO_server->utc_time ()).inacchi,
                        (UTO_server->utc_time ()).tdf));

#else

          if (TAO_debug_level > 0)
            ACE_DEBUG ((LM_DEBUG,
                        "\nTime = %Q\nInaccuracy = %Q\nTimeDiff = %d\nstruct.time = %Q\n"
                        "struct.inacclo = %d\nstruct.inacchi = %d\nstruct.Tdf = %d\n",
                        UTO_server->time (),
                        UTO_server->inaccuracy (),
                        UTO_server->tdf (),
                        (UTO_server->utc_time ()).time,
                        (UTO_server->utc_time ()).inacclo,
                        (UTO_server->utc_time ()).inacchi,
                        (UTO_server->utc_time ()).tdf));
#endif

          CORBA::ULongLong curr_server_time =
            UTO_server->time ();

          sum += curr_server_time;

          ++no_of_servers;

          // Set the highest time to the largest time seen so far.
          if (curr_server_time > highest_time)
            highest_time = curr_server_time;

          // Set the lowest time to the smallest time seen so far.
          if (curr_server_time < lowest_time)
            lowest_time = curr_server_time;

        }

      if (TAO_debug_level > 0)
        ACE_DEBUG ((LM_DEBUG,
                    "\nUpdated time from %d servers in the network",
                    no_of_servers));

      // Return the average of the times retrieved from the various
      // servers.
      clerk_->time_ = sum / no_of_servers ;

      // Set the Time Displacement Factor. The TZ environment variable is
      // read to set the time zone. We convert the timezone value from seconds
      // to minutes.

      ACE_OS::tzset ();
      long arg = ACE_OS::timezone () / 60;
      CORBA::Short goodarg = static_cast<CORBA::Short> (arg);
      clerk_->time_displacement_factor (goodarg);

      // Set the inaccuracy.
      if (highest_time > lowest_time)
        clerk_->inaccuracy (highest_time - lowest_time);
      else
        clerk_->inaccuracy (0);

      const ACE_Time_Value timeofday = ACE_OS::gettimeofday ();

      // Record the current time in a timestamp to know when global
      // updation of time was done.
      clerk_->update_timestamp_ =
        static_cast<CORBA::ULongLong> (timeofday.sec ()) *
        static_cast<ACE_UINT32> (10000000) +
        static_cast<CORBA::ULongLong> (timeofday.usec () * 10);
    }
  catch (const CORBA::Exception& ex)
    {
      if (TAO_debug_level > 0)
        ex._tao_print_exception ("Exception in handle_timeout()\n");

      return -1;
    }

  return 0;
}

---

Member Data Documentation

TAO_Time_Service_Clerk* Timer_Helper::clerk_ [protected]

Clerk's instance that this class helps to update time.

Definition at line 70 of file Timer_Helper.h.

Referenced by handle_timeout().

---

The documentation for this class was generated from the following files:

• Timer_Helper.h
• Timer_Helper.cpp

---