blob: 0559dce422070ceeb2326b0c511934f4ce0b7ba4 (
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
|
// -*- C++ -*-
//=============================================================================
/**
* @file QoS_Session_Factory.h
*
* $Id$
*
* @author Vishal Kachroo <vishal@cs.wustl.edu>
*/
//=============================================================================
#ifndef ACE_QOS_SESSION_FACTORY_H
#define ACE_QOS_SESSION_FACTORY_H
#include /**/ "ace/pre.h"
#include "ace/QoS/QoS_Session.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Containers_T.h"
#include "ACE_QoS_Export.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
// Forward declare this, so the factory uses only references to this.
class ACE_QoS_Session;
/**
* @class ACE_QoS_Session_Factory
*
* @brief Concrete factory for the QoS Session objects.
*
* This class manages the life cycle of QoS Session objects. These
* objects are currently either RAPI session objects or GQoS session
* objects. It stores the sessions in an unbounded set.
*/
class ACE_QoS_Export ACE_QoS_Session_Factory
{
public :
// = Initialization and termination methods.
/// Default constructor.
ACE_QoS_Session_Factory (void);
/// Default destructor.
~ACE_QoS_Session_Factory (void);
/// Types of sessions for this factory to manage.
enum ACE_QoS_Session_Type
{
/// ACE_RAPI_SESSION on Unix platforms with RAPI support
ACE_RAPI_SESSION,
/// ACE_GQOS_SESSION on Windows platforms with GQOS support
ACE_GQOS_SESSION
};
/** The default QoS type supported on this platform.
*
* ACE_DEFAULT_QOS_SESSION = ACE_RAPI_SESSION on Unix platforms with RAPI support
* = ACE_GQOS_SESSION on Windows platforms with GQOS support
*/
static const enum ACE_QoS_Session_Type ACE_DEFAULT_QOS_SESSION;
/// Create a QoS session of the given type (RAPI or GQoS).
ACE_QoS_Session * create_session (ACE_QoS_Session_Type qos_session_type = ACE_DEFAULT_QOS_SESSION );
/// Destroy the QoS Session.
int destroy_session (ACE_QoS_Session *qos_session);
private:
/// Used by the create_session () to add new sessions to the
/// set of sessions created by this factory.
int add_session (ACE_QoS_Session *qos_session);
/// Used by the destroy_session () to remove a session from the set
/// of sessions created by this factory.
int remove_session (ACE_QoS_Session *qos_session);
/// Unordered set of QoS Sessions.
typedef ACE_Unbounded_Set <ACE_QoS_Session *> QOS_SESSION_SET;
QOS_SESSION_SET qos_session_set_;
};
ACE_END_VERSIONED_NAMESPACE_DECL
#include /**/ "ace/post.h"
#endif /* ACE_QOS_SESSION_FACTORY_H */
|
