blob: 261808afe8c5e5358ff482fb480f25be2abb887c (
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
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
|
// $Id$
// author : Boris Kolpackov <boris@kolpackov.net>
#ifndef ACE_RMCAST_SOCKET_H
#define ACE_RMCAST_SOCKET_H
#include "ace/config-lite.h" // ACE_HANDLE
#include "ace/Auto_Ptr.h"
#include "ace/INET_Addr.h"
#include "ace/Time_Value.h"
#include "RMCast_Export.h"
#include "Parameters.h"
namespace ACE_RMCast
{
class Socket_Impl;
class ACE_RMCast_Export Socket
{
public:
virtual
~Socket ();
// If 'simulator' is 'true' then internal message loss and
// reordering simulator (on IPv4 level) is turned on.
//
Socket (ACE_INET_Addr const& a,
bool loop = true,
Parameters const& params = Parameters ());
public:
virtual void
send (void const* buf, size_t s);
// Block if message is not available. Upon successful completion
// return the next message. Otherwise return -1 and errno set to
// indicate the error. ENOENT indicates that the sender does not
// retain the data for this message anymore.
//
virtual ssize_t
recv (void* buf, size_t s);
virtual ssize_t
recv (void* buf, size_t s, ACE_INET_Addr& from);
// Block for up to <timeout> until message is available. Upon
// successful completion return the next message. Otherwise
// return -1 and errno set to indicate the error. ETIME indicates
// that the operation timed out. ENOENT indicates that the sender
// does not retain the data for this message anymore.
//
virtual ssize_t
recv (void* buf, size_t s, ACE_Time_Value const& timeout);
virtual ssize_t
recv (void* buf,
size_t s,
ACE_Time_Value const& timeout,
ACE_INET_Addr& from);
// Block if message is not available. Upon successful completion
// return the size of the next message. Otherwise return -1 and
// errno set to indicate the error. ENOENT indicates that the
// sender does not retain the data for this message anymore.
//
virtual ssize_t
size ();
// Block for up to <timeout> until message is available. Upon
// successful completion return the size of the next message.
// Otherwise return -1 and errno set to indicate the error.
// ETIME indicates that the operation timed out. ENOENT indicates
// that the sender does not retain the data for this message anymore.
//
virtual ssize_t
size (ACE_Time_Value const& timeout);
public:
// Reactor interface. Note that the handle returned by get_handle()
// is for signalling purposes only.
//
ACE_HANDLE
get_handle ();
private:
ACE_Auto_Ptr<Socket_Impl> impl_;
};
}
#endif // ACE_RMCAST_SOCKET_H
|
