blob: 14a13a9939fb1fd4183955374b6d2b0ef019a53c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
// System_Time.cpp
// $Id$
#define ACE_BUILD_DLL
#include "ace/Time_Value.h"
#include "ace/System_Time.h"
ACE_System_Time::ACE_System_Time (const char *poolname)
: delta_time_ (0)
{
ACE_TRACE ("ACE_System_Time::ACE_System_Time");
ACE_NEW (this->shmem_, ALLOCATOR (poolname));
}
ACE_System_Time::~ACE_System_Time (void)
{
delete this->shmem_;
ACE_TRACE ("ACE_System_Time::~ACE_System_Time");
}
// Get the local system time.
int
ACE_System_Time::get_local_system_time (ACE_UINT32 &time_out)
{
ACE_TRACE ("ACE_System_Time::get_local_system_time");
time_t t = ACE_OS::time (0);
time_out = t;
return 0;
}
// Get the system time of the central time server.
int
ACE_System_Time::get_master_system_time (ACE_UINT32 &time_out)
{
ACE_TRACE ("ACE_System_Time::get_master_system_time");
if (this->delta_time_ == 0)
{
// Try to find it
void * temp;
if (this->shmem_->find (ACE_DEFAULT_TIME_SERVER_STR, temp) == -1)
{
// No time entry in shared memory (meaning no Clerk exists)
// so return the local time of the host.
return this->get_local_system_time (time_out);
}
else
{
// Extract the delta time
this->delta_time_ = (long *) temp;
}
}
ACE_UINT32 local_time;
// If delta_time is positive, it means that the system clock is
// ahead of our local clock so add delta to the local time to get an
// approximation of the system time. Else if delta time is negative,
// it means that our local clock is ahead of the system clock, so
// return the last local time stored (to avoid time conflicts).
if (*this->delta_time_ >=0 )
{
this->get_local_system_time (local_time);
time_out = local_time + (ACE_UINT32) *this->delta_time_;
}
else
// Return the last local time. Note that this is stored as the
// second field in shared memory.
time_out = *(this->delta_time_ + 1);
return 0;
}
// Synchronize local system time with the central time server using
// specified mode.
int
ACE_System_Time::sync_local_system_time (ACE_System_Time::Sync_Mode mode)
{
ACE_TRACE ("ACE_System_Time::sync_local_system_time");
return 0;
}
#if defined (ACE_TEMPLATES_REQUIRE_SPECIALIZATION)
template class ACE_Malloc<ACE_MMAP_Memory_Pool, ACE_Null_Mutex>;
template class ACE_Allocator_Adapter<ACE_Malloc<ACE_MMAP_Memory_Pool, ACE_Null_Mutex> >;
#endif /* ACE_TEMPLATES_REQUIRE_SPECIALIZATION */
|
