blob: 446afbc9cc7cbecb8e01c28dd966d7c1d0de503a (
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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// ACE
//
// = FILENAME
// Name_Proxy.h
//
// = DESCRIPTION
// Proxy for dealing with remote server process managing NET_LOCAL
// Name_Bindings.
//
// = AUTHOR
// Gerhard Lenzer, Douglas C. Schmidt, and Prashant Jain
//
// ============================================================================
#ifndef ACE_NAME_PROXY_H
#define ACE_NAME_PROXY_H
#include "ace/INET_Addr.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/SOCK_Connector.h"
#include "ace/SOCK_Stream.h"
#include "ace/Service_Config.h"
#include "ace/Synch_Options.h"
#include "ace/Name_Request_Reply.h"
class ACE_Export ACE_Name_Proxy : public ACE_Event_Handler
{
// = TITLE
// Proxy for dealing with remote server process managing NET_LOCAL
// NameBindings.
//
// = DESCRIPTION
// Shields applications from details of interacting with the
// ACE_Name Server.
public:
ACE_Name_Proxy (void);
// Default constructor.
// = Establish a binding with the ACE_Name Server.
ACE_Name_Proxy (const ACE_INET_Addr &remote_addr, // Address of ACE_Name Server.
ACE_Synch_Options& options =
ACE_Synch_Options::defaults);
int open (const ACE_INET_Addr &remote_addr, // Address of ACE_Name Server.
ACE_Synch_Options& options =
ACE_Synch_Options::defaults);
int request_reply (ACE_Name_Request &request);
// Perform the request and wait for the reply.
int send_request (ACE_Name_Request &request);
// Perform the request.
int recv_reply (ACE_Name_Request &reply);
// Receive the reply.
virtual ACE_HANDLE get_handle (void) const;
// Obtain underlying handle.
virtual ~ACE_Name_Proxy (void);
// Close down the connection to the server.
void dump (void) const;
// Dump the state of the object;
private:
ACE_SOCK_Connector connector_;
// ACE_Connector factory used to establish connections actively.
ACE_SOCK_Stream peer_;
// Connection to ACE_Name Server peer.
ACE_Reactor *reactor_;
// Pointer to ACE_Reactor (used if we are run in "reactive-mode").
};
#endif /* ACE_NAME_PROXY_H */
|