ACE/apps/JAWS/clients/Caching/ID_Generator.cpp

   1 #if !defined (ACE_ID_GENERATOR_C)
   2 #define ACE_ID_GENERATOR_C
   3
   4 #include "ace/Object_Manager.h"
   5 #include "ID_Generator.h"
   6
   7 time_t ACE_ID_Generator::last_time_ = 0;
   8
   9 size_t ACE_ID_Generator::last_number_ = 0;
  10
  11 ACE_SYNCH_MUTEX *ACE_ID_Generator::lock_ = 0;
  12
  13 char *
  14 ACE_ID_Generator::get_new_id (char *id)
  15 {
  16   time_t t;
  17   size_t sn;
  18
  19   ACE_ID_Generator::get_serial_id (t, sn);
  20   ACE_NEW_RETURN (id, char [ACE_OFFER_ID_LENGTH], 0);
  21
  22   ACE_OS::sprintf (id, "%014d%06d", t, sn);
  23   return id;
  24 }
  25
  26 void
  27 ACE_ID_Generator::get_serial_id (time_t &t, size_t &s)
  28 {
  29   ACE_MT (ACE_GUARD (ACE_SYNCH_MUTEX, ace_mon, *ACE_ID_Generator::get_lock ()));
  30   ACE_OS::time (&t);
  31
  32   if (t != ACE_ID_Generator::last_time_)
  33     {
  34       ACE_ID_Generator::last_time_ = t;
  35       s = ACE_ID_Generator::last_number_ = 0;
  36     }
  37   else
  38       s = ACE_ID_Generator::last_number_++;
  39 }
  40
  41 ACE_SYNCH_MUTEX *
  42 ACE_ID_Generator::get_lock ()
  43 {
  44 #if defined (ACE_HAS_THREADS)
  45   if (ACE_ID_Generator::lock_ == 0)
  46     {
  47       ACE_MT (ACE_GUARD_RETURN (ACE_Recursive_Thread_Mutex, ace_mon, *ACE_Static_Object_Lock::instance (), 0));
  48
  49       // Double-checked Locking Optimization.
  50       if (ACE_ID_Generator::lock_ == 0)
  51         ACE_NEW_RETURN (ACE_ID_Generator::lock_, ACE_SYNCH_MUTEX, 0);
  52     }
  53 #endif /* ACE_HAS_THREADS */
  54   return ACE_ID_Generator::lock_;
  55 }
  56
  57 #endif /* ACE_ID_GENERATOR_C */