blob: fb7dd8e30646004fded3ae5865887d202b5e8d82 (
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
|
/**
* @file PIP_Connection_Manager.h
*
* // $Id$
*
* @author John Moore <ljohn7@gmail.com>
*
*/
#ifndef PIP_CONNECTION_MANAGER_H
#define PIP_CONNECTION_MANAGER_H
#include <ace/Connector.h>
#include <ace/PIP_Active_IO_Handler.h>
#include <ace/PIP_Reactive_IO_Handler.h>
#include <ace/Reactor.h>
#include <ace/SOCK_Connector.h>
#include <ace/Vector_T.h>
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include <fstream>
#include <iostream>
class ACE_Export ACE_PIP_Connection_Manager
{
public:
/// Informationa associated with a connection
struct Connection_Definition
{
enum Handler_Type {ACTIVE, REACTIVE};
ACE_UINT32 source_site_id;
ACE_UINT32 destination_site_id;
ACE_TCHAR* address;
u_short port;
ACE_UINT32 priority;
Handler_Type type;
};
/// Default Constructor
ACE_PIP_Connection_Manager();
/// Destructor
virtual ~ACE_PIP_Connection_Manager();
/// obtain the single instance of the manager
static ACE_PIP_Connection_Manager* instance();
/// Extract all connection information from a file
virtual int process_connection_file(char* filename);
/// Establish all connection for which source_site_id is the source
virtual int establish_connections(ACE_UINT32 source_site_id);
const ACE_Vector<Connection_Definition*>* get_connections() const;
private:
ACE_Vector<Connection_Definition*>* connection_definitions_;
// The connector used to actively connect to a remote site
ACE_Connector<
ACE_PIP_Active_IO_Handler,
ACE_SOCK_Connector> active_connector_;
ACE_Connector<
ACE_PIP_Reactive_IO_Handler,
ACE_SOCK_Connector> reactive_connector_;
static ACE_PIP_Connection_Manager* connection_manager_;
static ACE_Mutex instance_lock_;
static bool delete_manager_;
ACE_Vector<ACE_PIP_IO_Handler*> handlers_;
};
#endif
|
