blob: 8f82b1f8089aa621329b3f5c8ed5c0cf6a8d2570 (
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
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
|
// -*- C++ -*-
//=============================================================================
/**
* @file FT_ClientRequest_Interceptor.h
*
* $Id$
*
* @author Balachandran Natarajan <bala@dre.vanderbilt.edu>
*/
//=============================================================================
#ifndef TAO_FT_CLIENT_REQUEST_INTERCEPTOR_H
#define TAO_FT_CLIENT_REQUEST_INTERCEPTOR_H
#include /**/ "ace/pre.h"
#include "FT_ClientORB_export.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/PI/PI.h"
#include "tao/PortableInterceptorC.h"
#include "tao/LocalObject.h"
#include "tao/TimeBaseC.h"
#include "ace/Singleton.h"
// This is to remove "inherits via dominance" warnings from MSVC.
// MSVC is being a little too paranoid.
#if defined(_MSC_VER)
#pragma warning(push)
#pragma warning(disable:4250)
#endif /* _MSC_VER */
namespace ACE_Utils
{
class UUID;
}
namespace TAO
{
/**
* @class FT_TSS
*
* @brief Request service context generator class for the client.
*
* @@TODO Need to see whether we can have seperate resource factory
* and put this there. Let us get this going first
*/
class FT_TSS
{
public:
CORBA::Long retention_id_;
bool clean_flag_;
};
/**
* @class FT_ClientRequest_Interceptor
*
* @brief Interceptors for the client
*
* @@TODO
*/
class TAO_FT_ClientORB_Export FT_ClientRequest_Interceptor
: public virtual PortableInterceptor::ClientRequestInterceptor,
public virtual TAO_Local_RefCounted_Object
{
public:
FT_ClientRequest_Interceptor (void);
~FT_ClientRequest_Interceptor (void);
/// Canonical name of the interceptor.
virtual char * name (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void destroy (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void send_poll (PortableInterceptor::ClientRequestInfo_ptr
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void send_request (PortableInterceptor::ClientRequestInfo_ptr ri
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::ForwardRequest));
virtual void receive_reply (PortableInterceptor::ClientRequestInfo_ptr ri
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
virtual void receive_other (PortableInterceptor::ClientRequestInfo_ptr
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::ForwardRequest));
virtual void receive_exception (PortableInterceptor::ClientRequestInfo_ptr ri
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException,
PortableInterceptor::ForwardRequest));
private:
void group_version_context (PortableInterceptor::ClientRequestInfo_ptr ri
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
void request_service_context (PortableInterceptor::ClientRequestInfo_ptr ri
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
TimeBase::TimeT request_expiration_time (CORBA::Policy *policy
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException));
FT_TSS *tss_resources (void);
private:
/// Name of the interceptor
const char *name_;
/// UUID for this client
ACE_Utils::UUID *uuid_;
/// TSS data
ACE_TSS_TYPE (FT_TSS) tss_;
/// @@ Need a resource factory for this too
ACE_Lock *lock_;
/// Retention id generated by the client
CORBA::Long retention_id_;
};
}
#if defined(_MSC_VER)
#pragma warning(pop)
#endif /* _MSC_VER */
#include /**/ "ace/post.h"
#endif /*TAO_FT_CLIENT_REQUEST_INTERCEPTOR_H*/
|
