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
|
// -*- C++ -*-
#include "ace/SV_Message_Queue.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
template <class T> ACE_INLINE int
ACE_Typed_SV_Message_Queue<T>::open (key_t external_id,
int create,
int perms)
{
ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::open");
return this->message_queue_.open (external_id, create, perms);
}
// What does it mean to close a message queue?!
template <class T> ACE_INLINE int
ACE_Typed_SV_Message_Queue<T>::close (void)
{
ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::close");
return 1;
}
template <class T> ACE_INLINE int
ACE_Typed_SV_Message_Queue<T>::recv (ACE_Typed_SV_Message<T> &mb,
int mflags)
{
ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::recv");
int length =
this->message_queue_.recv (reinterpret_cast<ACE_SV_Message &> (mb),
mb.max_size (),
mb.type (),
mflags);
if (length != -1)
mb.length (length);
return length;
}
template <class T> ACE_INLINE int
ACE_Typed_SV_Message_Queue<T>::send (const ACE_Typed_SV_Message<T> &mb,
int mflags)
{
ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::send");
return
this->message_queue_.send (
reinterpret_cast<ACE_SV_Message &> (
const_cast<ACE_Typed_SV_Message<T> &> (mb)),
mb.length (),
mflags);
}
template <class T> ACE_INLINE int
ACE_Typed_SV_Message_Queue<T>::remove (void)
{
ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::remove");
return this->message_queue_.remove ();
}
template <class T> ACE_INLINE int
ACE_Typed_SV_Message_Queue<T>::control (int option,
void *arg)
{
ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::control");
return this->message_queue_.control (option, arg);
}
template <class T> ACE_INLINE int
ACE_Typed_SV_Message_Queue<T>::get_id () const
{
return this->message_queue_.get_id ();
}
ACE_END_VERSIONED_NAMESPACE_DECL
|
