blob: 345c9da754eaf6a86c97a55b56ad09d7ec04f5ab (
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
|
// $Id$
#include "Method_Request.h"
#if ! defined (__ACE_INLINE__)
#include "Method_Request.inl"
#endif /* __ACE_INLINE__ */
ACE_RCSID(RT_Notify, TAO_NS_Method_Request, "$Id$")
TAO_NS_Method_Request_Event::TAO_NS_Method_Request_Event (const TAO_NS_Event_var& event)
:event_ (event)
{
// 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)this->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)
TAO_NS_Property_Time& timeout = this->event_->timeout ();
if (timeout.is_valid () && timeout != 0)
{
// I am multiplying timeout () by 1 because it returns a
// CORBA::ULongLong, which on some platforms doesn't automatically
// convert to the long that the ACE_Time_Value expects. The /
// operator returns a 32-bit integer.
ACE_Time_Value current = ACE_OS::gettimeofday () +
# if defined (ACE_CONFIG_WIN32_H)
ACE_Time_Value (
ACE_static_cast (long,
timeout.value ()));
# else
ACE_Time_Value (timeout.value () / 1);
# endif /* ACE_CONFIG_WIN32_H */
this->msg_deadline_time (current);
}
}
TAO_NS_Method_Request_Event::~TAO_NS_Method_Request_Event ()
{
}
int
TAO_NS_Method_Request_Event::execute (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
{
return -1;
}
TAO_NS_Method_Request*
TAO_NS_Method_Request_Event::copy (void)
{
return new TAO_NS_Method_Request_Event (this->event_);
}
const TAO_NS_Event_var&
TAO_NS_Method_Request_Event::event (void)
{
return this->event_;
}
|
