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
|
// This may look like C, but it's really -*- C++ -*-
// $Id$
// ============================================================================
//
// = LIBRARY
// TAO
//
// = FILENAME
// Asynch_Invocation.h
//
// = DESCRIPTION
// Encapsulate the logic for remote Asynchronous Invocations.
//
// = AUTHOR
// Carlos O'Ryan <coryan@cs.wustl.edu> and Alexander Babu Arulanthu
// <alex@cs.wustl.edu>
//
// ============================================================================
#ifndef TAO_ASYNCH_INVOCATION_H
#define TAO_ASYNCH_INVOCATION_H
#include "tao/Invocation.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/MessagingC.h"
#if (TAO_HAS_CORBA_MESSAGING == 1)
# if (TAO_HAS_AMI_CALLBACK == 1) || (TAO_HAS_AMI_POLLER == 1)
class TAO_Export TAO_GIOP_Twoway_Asynch_Invocation : public TAO_GIOP_Invocation
{
// = TITLE
// Sends a two-way request does not expect the reply.
//
// = DESCRIPTION
// This class connects (or lookups a connection from the cache) to
// the remote server, builds the CDR stream for the Request, send
// the CDR stream and returns.
//
public:
TAO_GIOP_Twoway_Asynch_Invocation (TAO_Stub *data,
const char *operation,
TAO_ORB_Core* orb_core,
const TAO_Reply_Handler_Skeleton &reply_handler_skel,
Messaging::ReplyHandler_ptr reply_handler_ptr);
// Constructor.
void start (CORBA_Environment &TAO_IN_ENV =
TAO_default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException));
// Calls TAO_GIOP_Asynch_Invocation::start.
int invoke (CORBA_Environment &TAO_IN_ENV =
TAO_default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException));
// Send request, block until any reply comes back, and unmarshal
// reply parameters as appropriate.
// TAO_InputCDR &inp_stream (void);
// // Return the underlying input stream.
//
const IOP::ServiceContextList& reply_service_info (void) const;
// Accessor to the reply ServiceContextList.
private:
int invoke_i (CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException));
// Implementation of the invoke() methods, handles the basic
// send/reply code and the system exceptions.
private:
TAO_Asynch_Reply_Dispatcher *rd_;
// Reply dispatcher for the current synchronous Asynch_Invocation.
};
# endif /* TAO_HAS_AMI_CALLBACK == 1 || TAO_HAS_AMI_POLLER == 1 */
#endif /* TAO_HAS_CORBA_MESSAGING == 1 */
//***********************************************************************
#if !defined (TAO_HAS_MINIMUM_CORBA)
class TAO_Export TAO_GIOP_DII_Deferred_Invocation : public TAO_GIOP_Invocation
{
// = TITLE
// Sends a two-way request does not expect the reply.
//
// = DESCRIPTION
// This class connects (or lookups a connection from the cache) to
// the remote server, builds the CDR stream for the Request, send
// the CDR stream and returns.
//
public:
TAO_GIOP_DII_Deferred_Invocation (TAO_Stub *data,
TAO_ORB_Core* orb_core,
const CORBA::Request_ptr req);
// Constructor.
void start (CORBA_Environment &TAO_IN_ENV =
TAO_default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException));
// Calls TAO_GIOP_Asynch_Invocation::start.
int invoke (CORBA_Environment &TAO_IN_ENV =
TAO_default_environment ())
ACE_THROW_SPEC ((CORBA::SystemException));
// Send request, block until any reply comes back, and unmarshal
// reply parameters as appropriate.
// TAO_InputCDR &inp_stream (void);
// // Return the underlying input stream.
//
const IOP::ServiceContextList& reply_service_info (void) const;
// Accessor to the reply ServiceContextList.
private:
int invoke_i (CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException));
// Implementation of the invoke() methods, handles the basic
// send/reply code and the system exceptions.
private:
TAO_DII_Deferred_Reply_Dispatcher *rd_;
// Reply dispatcher for the current synchronous Asynch_Invocation.
};
#endif /* TAO_HAS_MINIMUM_CORBA */
#if defined (__ACE_INLINE__)
# include "tao/Asynch_Invocation.i"
#endif /* __ACE_INLINE__ */
#endif /* TAO_ASYNCH_INVOCATION_H */
|
