blob: d9463ed423c33a15d051ffaad0ec48f9c6517190 (
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
|
// $Id$
#include "orbsvcs/Notify/Method_Request.h"
#include "orbsvcs/Time_Utilities.h"
#include "ace/OS_NS_sys_time.h"
ACE_RCSID(Notify, TAO_Notify_Method_Request_Queueable, "$Id$")
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO_Notify_Method_Request::~TAO_Notify_Method_Request (void)
{
}
TAO_Notify_Method_Request_Queueable *
TAO_Notify_Method_Request_Queueable::copy (void)
{
return this;
}
TAO_Notify_Method_Request_Queueable::TAO_Notify_Method_Request_Queueable()
{
}
TAO_Notify_Method_Request_Queueable::TAO_Notify_Method_Request_Queueable(const TAO_Notify_Event * event)
{
this->init (event);
}
void
TAO_Notify_Method_Request_Queueable::init (const TAO_Notify_Event* event)
{
ACE_ASSERT( event != 0 );
// Set the parameters that affect queuing in the message queue.
// The ACE_Message_Block priorities go from 0 (lowest) to ULONG_MAX
// (highest), while the Notification Events go from -32767 (lowest,
// even though CORBA::Short goes to -32768) to 32767 (highest).
// Convert to CORBA::Long to preserve the sign. Conversion to
// unsigned long will happen automatically and we do not have to worry
// about losing the number in the addition since priority () returns a
// CORBA::Short.
this->msg_priority ((CORBA::Long)event->priority ().value () + PRIORITY_BASE);
// The deadline time for the message block is absolute, while the
// timeout for the event is relative to the time it was received.
// So, we do a little conversion and set it on the message block (us)
const TAO_Notify_Property_Time& timeout = event->timeout ();
if (timeout.is_valid () && timeout != 0)
{
ACE_Time_Value deadline;
ORBSVCS_Time::TimeT_to_Time_Value(deadline, timeout.value());
deadline += ACE_OS::gettimeofday ();
this->msg_deadline_time (deadline);
}
}
TAO_END_VERSIONED_NAMESPACE_DECL
|
