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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
|
// -*- C++ -*-
//=============================================================================
/**
* @file MEM_Stream.h
*
* $Id$
*
* @author Nanbor Wang <nanbor@cs.wustl.edu>
*/
//=============================================================================
#ifndef ACE_MEM_STREAM_H
#define ACE_MEM_STREAM_H
#include /**/ "ace/pre.h"
#include "ace/MEM_IO.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#if (ACE_HAS_POSITION_INDEPENDENT_POINTERS == 1)
#include "ace/INET_Addr.h"
#if !defined (ACE_MEM_STREAM_MIN_BUFFER)
# define ACE_MEM_STREAM_MIN_BUFFER 4096
#endif /* ACE_MEM_STREAM_MIN_BUFFER */
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
class ACE_MEM_Acceptor;
class ACE_MEM_Connector;
/**
* @class ACE_MEM_Stream
*
* @brief Defines the methods in the ACE_MEM_Stream abstraction.
*
* This adds additional wrapper methods atop the ACE_MEM_IO
* class. Notice that ACE_MEM_Stream can only send messages no bigger
* than the underlying MMAP file size minus sizeof (ACE_MEM_SAP_Node).
* The size of the MMAP file is default to ACE_MEM_STREAM_MIN_BUFFER.
* (Define above in this file, to 4096 bytes.)
* If you need to increase the size of allowable message
* ACE_MEM_Stream can handle, you can set it to either
* @c ACE_MEM_Acceptor::malloc_options(). minimal_bytes_
* @c ACE_MEM_Acceptor::init_buffer_size (size_t size);
* before establishing a connection.
*/
class ACE_Export ACE_MEM_Stream : public ACE_MEM_IO
{
public:
friend class ACE_MEM_Acceptor;
friend class ACE_MEM_Connector;
// Initialization and termination methods.
/// Constructor.
ACE_MEM_Stream (void);
/// Constructor (sets the underlying ACE_HANDLE with <h>).
ACE_MEM_Stream (ACE_HANDLE h);
/// Destructor.
~ACE_MEM_Stream (void);
//= The following two methods use write and read system calls.
/// Send n bytes, keep trying until n are sent.
/// Recv n bytes, keep trying until n are received.
ssize_t send_n (const void *buf, size_t n);
ssize_t recv_n (void *buf, size_t n);
// = The following two methods use the send and recv system calls.
/// Send n bytes, keep trying until n are sent.
/// Recv n bytes, keep trying until n are received.
ssize_t send_n (const void *buf, size_t n, int flags);
ssize_t recv_n (void *buf, size_t n, int flags);
#if 0
/**
* Try to send exactly <len> bytes into <buf> from <handle> (uses
* the <send> call). If <send> blocks for longer than <timeout> the
* number of bytes actually sent is returned with <errno == ETIME>.
* If a timeout does not occur, <send_n> return <len> (i.e., the
* number of bytes requested to be sent).
*/
ssize_t send_n (const void *buf,
size_t len,
int flags,
const ACE_Time_Value *timeout);
/**
* Try to recv exactly <len> bytes into <buf> from <handle> (uses
* the <ACE::recv_n> call). The <ACE_Time_Value> indicates how long
* to blocking trying to receive. If <timeout> == 0, the caller
* will block until action is possible, else will wait until the
* relative time specified in *<timeout> elapses). If <recv> blocks
* for longer than <timeout> the number of bytes actually read is
* returned with <errno == ETIME>. If a timeout does not occur,
* <recv_n> return <len> (i.e., the number of bytes requested to be
* read).
*/
ssize_t recv_n (void *buf,
size_t len,
int flags,
const ACE_Time_Value *timeout);
/**
* Send an <iovec> of size <n> to the connected socket (uses
* <ACE::sendv_n>). Will block until all bytes are sent or an error
* occurs.
*/
ssize_t sendv_n (const iovec iov[],
size_t n) const;
/// Receive an <iovec> of size <n> to the connected socket.
ssize_t recvv_n (iovec iov[],
size_t n) const;
#endif /* 0 */
// = Selectively close endpoints.
/// Close down the reader.
int close_reader (void);
/// Close down the writer.
int close_writer (void);
/**
* Close down the socket (we need this to make things work correctly
* on Win32, which requires use to do a <close_writer> before doing
* the close to avoid losing data).
*/
int close (void);
// = Meta-type info
typedef ACE_Addr PEER_ADDR;
/// Dump the state of an object.
void dump (void) const;
/// Declare the dynamic allocation hooks.
ACE_ALLOC_HOOK_DECLARE;
};
ACE_END_VERSIONED_NAMESPACE_DECL
#if defined (__ACE_INLINE__)
#include "ace/MEM_Stream.inl"
#endif /* __ACE_INLINE__ */
#endif /* ACE_HAS_POSITION_INDEPENDENT_POINTERS == 1 */
#include /**/ "ace/post.h"
#endif /* ACE_MEM_STREAM_H */
|
