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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
// -*- C++ -*-
#include "ace/Min_Max.h"
#include "ace/OS_NS_stropts.h"
#include "ace/Truncate.h"
#if !defined (ACE_HAS_STREAM_PIPES)
#include "ace/OS_NS_unistd.h"
#endif
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
ACE_INLINE ssize_t
ACE_FIFO_Recv_Msg::recv (ACE_Str_Buf &recv_msg)
{
ACE_TRACE ("ACE_FIFO_Recv_Msg::recv");
#if defined (ACE_HAS_STREAM_PIPES)
int i = 0;
if (ACE_OS::getmsg (this->get_handle (),
(strbuf *) 0,
(strbuf *) &recv_msg,
&i) == -1)
{
return -1;
}
else
{
return recv_msg.len;
}
#else /* Do the ol' 2-read trick... */
if (ACE_OS::read (this->get_handle (),
(char *) &recv_msg.len,
sizeof recv_msg.len) != (ssize_t) sizeof recv_msg.len)
{
return -1;
}
else
{
size_t remaining = static_cast<size_t> (recv_msg.len);
size_t requested = static_cast<size_t> (recv_msg.maxlen);
ssize_t recv_len = ACE_OS::read (this->get_handle (),
(char *) recv_msg.buf,
ACE_MIN (remaining, requested));
if (recv_len == -1)
{
return -1;
}
// Tell caller what's really in the buffer.
recv_msg.len = static_cast<int> (recv_len);
// If there are more bytes remaining in the message, read them and
// throw them away. Leaving them in the FIFO would make it difficult
// to find the start of the next message in the fifo.
// Since the ACE_HAS_STREAM_PIPES version of this method doesn't
// return getmsg()'s indication of "data remaining", don't worry about
// saving the indication here either to read the remainder later.
size_t total_msg_size = remaining;
remaining -= recv_len;
while (remaining > 0)
{
const size_t throw_away = 1024;
char dev_null[throw_away];
recv_len = ACE_OS::read (this->get_handle (),
dev_null,
ACE_MIN (remaining, throw_away));
if (recv_len == -1)
{
break;
}
remaining -= recv_len;
}
return ACE_Utils::truncate_cast<ssize_t> (total_msg_size);
}
#endif /* ACE_HAS_STREAM_PIPES */
}
ACE_INLINE ssize_t
ACE_FIFO_Recv_Msg::recv (void *buf, size_t max_len)
{
ACE_TRACE ("ACE_FIFO_Recv_Msg::recv");
ACE_Str_Buf recv_msg ((char *) buf, 0, static_cast<int> (max_len));
return this->recv (recv_msg);
}
#if defined (ACE_HAS_STREAM_PIPES)
ACE_INLINE ssize_t
ACE_FIFO_Recv_Msg::recv (ACE_Str_Buf *data,
ACE_Str_Buf *cntl,
int *flags)
{
ACE_TRACE ("ACE_FIFO_Recv_Msg::recv");
if (ACE_OS::getmsg (this->get_handle (),
(strbuf *) cntl,
(strbuf *) data,
flags) == -1)
{
return -1;
}
else
{
return (cntl == 0 ? 0 : cntl->len) + (data == 0 ? 0 : data->len);
}
}
ACE_INLINE ssize_t
ACE_FIFO_Recv_Msg::recv (int *band,
ACE_Str_Buf *data,
ACE_Str_Buf *cntl,
int *flags)
{
ACE_TRACE ("ACE_FIFO_Recv_Msg::recv");
if (ACE_OS::getpmsg (this->get_handle (),
(strbuf *) cntl,
(strbuf *) data,
band,
flags) == -1)
{
return -1;
}
else
{
return (cntl == 0 ? 0 : cntl->len) + (data == 0 ? 0 : data->len);
}
}
#endif /* ACE_HAS_STREAM_PIPES */
ACE_END_VERSIONED_NAMESPACE_DECL
|
