00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031 #ifndef _TAO_IDL__HOME_KALTAN_SRC_WWW_OROCOS_1_0_EXPORT_BUILD_OROCOS_RTT_1_12_1_BUILD_SRC_CORBA_DATAFLOWS_H_
00032 #define _TAO_IDL__HOME_KALTAN_SRC_WWW_OROCOS_1_0_EXPORT_BUILD_OROCOS_RTT_1_12_1_BUILD_SRC_CORBA_DATAFLOWS_H_
00033
00034
00035 #include "DataFlowC.h"
00036 #include "tao/BooleanSeqS.h"
00037 #include "tao/CharSeqS.h"
00038 #include "tao/DoubleSeqS.h"
00039 #include "tao/FloatSeqS.h"
00040 #include "tao/LongDoubleSeqS.h"
00041 #include "tao/LongSeqS.h"
00042 #include "tao/OctetSeqS.h"
00043 #include "tao/ShortSeqS.h"
00044 #include "tao/StringSeqS.h"
00045 #include "tao/ULongSeqS.h"
00046 #include "tao/UShortSeqS.h"
00047 #include "tao/WCharSeqS.h"
00048 #include "tao/WStringSeqS.h"
00049 #include "tao/LongLongSeqS.h"
00050 #include "tao/ULongLongSeqS.h"
00051 #include "tao/PolicyS.h"
00052 #include "tao/Policy_ManagerS.h"
00053 #include "tao/Policy_CurrentS.h"
00054 #include "tao/ServicesS.h"
00055 #include "tao/ParameterModeS.h"
00056 #include "tao/orb_typesS.h"
00057 #include "tao/Typecode_typesS.h"
00058 #include "tao/WrongTransactionS.h"
00059 #include "OperationsS.h"
00060
00061 #if !defined (ACE_LACKS_PRAGMA_ONCE)
00062 # pragma once
00063 #endif
00064
00065 #include "tao/Collocation_Proxy_Broker.h"
00066 #include "tao/PortableServer/PortableServer.h"
00067 #include "tao/PortableServer/Servant_Base.h"
00068
00069
00070
00071
00072 namespace POA_RTT
00073 {
00074
00075
00076
00077
00078
00079 namespace Corba
00080 {
00081
00082
00083
00084
00085
00086 class BufferChannel;
00087 typedef BufferChannel *BufferChannel_ptr;
00088
00089 class RTT_CORBA_API BufferChannel
00090 : public virtual PortableServer::ServantBase
00091 {
00092 protected:
00093 BufferChannel (void);
00094
00095 public:
00096
00097 typedef ::RTT::Corba::BufferChannel _stub_type;
00098 typedef ::RTT::Corba::BufferChannel_ptr _stub_ptr_type;
00099 typedef ::RTT::Corba::BufferChannel_var _stub_var_type;
00100
00101 BufferChannel (const BufferChannel& rhs);
00102 virtual ~BufferChannel (void);
00103
00104 virtual ::CORBA::Boolean _is_a (const char* logical_type_id);
00105
00106 static void _is_a_skel (
00107 TAO_ServerRequest & req,
00108 void * servant_upcall,
00109 void * servant
00110 );
00111
00112 static void _non_existent_skel (
00113 TAO_ServerRequest & req,
00114 void * servant_upcall,
00115 void * servant
00116 );
00117
00118 static void _interface_skel (
00119 TAO_ServerRequest & req,
00120 void * servant_upcall,
00121 void * servant
00122 );
00123
00124 static void _component_skel (
00125 TAO_ServerRequest & req,
00126 void * servant_upcall,
00127 void * servant
00128 );
00129
00130 static void _repository_id_skel (
00131 TAO_ServerRequest & req,
00132 void * servant_upcall,
00133 void * servant);
00134
00135 virtual void _dispatch (
00136 TAO_ServerRequest & req,
00137 void * servant_upcall);
00138
00139 ::RTT::Corba::BufferChannel *_this (void);
00140
00141 virtual const char* _interface_repository_id (void) const;
00142
00143
00144
00145
00146 virtual ::CORBA::Boolean push (
00147 const ::CORBA::Any & value) = 0;
00148
00149 static void push_skel (
00150 TAO_ServerRequest & server_request,
00151 void * servant_upcall,
00152 void * servant
00153 );
00154
00155
00156
00157
00158 virtual ::CORBA::Boolean pull (
00159 ::CORBA::Any_out value) = 0;
00160
00161 static void pull_skel (
00162 TAO_ServerRequest & server_request,
00163 void * servant_upcall,
00164 void * servant
00165 );
00166
00167
00168
00169
00170 virtual ::CORBA::Any * front (
00171 void) = 0;
00172
00173 static void front_skel (
00174 TAO_ServerRequest & server_request,
00175 void * servant_upcall,
00176 void * servant
00177 );
00178
00179
00180
00181
00182 virtual ::CORBA::Boolean full (
00183 void) = 0;
00184
00185 static void full_skel (
00186 TAO_ServerRequest & server_request,
00187 void * servant_upcall,
00188 void * servant
00189 );
00190
00191
00192
00193
00194 virtual ::CORBA::Boolean empty (
00195 void) = 0;
00196
00197 static void empty_skel (
00198 TAO_ServerRequest & server_request,
00199 void * servant_upcall,
00200 void * servant
00201 );
00202
00203
00204
00205
00206 virtual ::CORBA::Long capacity (
00207 void) = 0;
00208
00209 static void capacity_skel (
00210 TAO_ServerRequest & server_request,
00211 void * servant_upcall,
00212 void * servant
00213 );
00214
00215
00216
00217
00218 virtual ::CORBA::Long size (
00219 void) = 0;
00220
00221 static void size_skel (
00222 TAO_ServerRequest & server_request,
00223 void * servant_upcall,
00224 void * servant
00225 );
00226
00227
00228
00229
00230 virtual void clear (
00231 void) = 0;
00232
00233 static void clear_skel (
00234 TAO_ServerRequest & server_request,
00235 void * servant_upcall,
00236 void * servant
00237 );
00238 };
00239
00240
00241
00242
00243 class DataFlowInterface;
00244 typedef DataFlowInterface *DataFlowInterface_ptr;
00245
00246 class RTT_CORBA_API DataFlowInterface
00247 : public virtual PortableServer::ServantBase
00248 {
00249 protected:
00250 DataFlowInterface (void);
00251
00252 public:
00253
00254 typedef ::RTT::Corba::DataFlowInterface _stub_type;
00255 typedef ::RTT::Corba::DataFlowInterface_ptr _stub_ptr_type;
00256 typedef ::RTT::Corba::DataFlowInterface_var _stub_var_type;
00257
00258 DataFlowInterface (const DataFlowInterface& rhs);
00259 virtual ~DataFlowInterface (void);
00260
00261 virtual ::CORBA::Boolean _is_a (const char* logical_type_id);
00262
00263 static void _is_a_skel (
00264 TAO_ServerRequest & req,
00265 void * servant_upcall,
00266 void * servant
00267 );
00268
00269 static void _non_existent_skel (
00270 TAO_ServerRequest & req,
00271 void * servant_upcall,
00272 void * servant
00273 );
00274
00275 static void _interface_skel (
00276 TAO_ServerRequest & req,
00277 void * servant_upcall,
00278 void * servant
00279 );
00280
00281 static void _component_skel (
00282 TAO_ServerRequest & req,
00283 void * servant_upcall,
00284 void * servant
00285 );
00286
00287 static void _repository_id_skel (
00288 TAO_ServerRequest & req,
00289 void * servant_upcall,
00290 void * servant);
00291
00292 virtual void _dispatch (
00293 TAO_ServerRequest & req,
00294 void * servant_upcall);
00295
00296 ::RTT::Corba::DataFlowInterface *_this (void);
00297
00298 virtual const char* _interface_repository_id (void) const;
00299
00300
00301
00302
00303 virtual ::RTT::Corba::DataFlowInterface::PortNames * getPorts (
00304 void) = 0;
00305
00306 static void getPorts_skel (
00307 TAO_ServerRequest & server_request,
00308 void * servant_upcall,
00309 void * servant
00310 );
00311
00312
00313
00314
00315 virtual ::RTT::Corba::AssignableExpression_ptr createDataChannel (
00316 const char * port_name) = 0;
00317
00318 static void createDataChannel_skel (
00319 TAO_ServerRequest & server_request,
00320 void * servant_upcall,
00321 void * servant
00322 );
00323
00324
00325
00326
00327 virtual ::RTT::Corba::BufferChannel_ptr createBufferChannel (
00328 const char * port_name) = 0;
00329
00330 static void createBufferChannel_skel (
00331 TAO_ServerRequest & server_request,
00332 void * servant_upcall,
00333 void * servant
00334 );
00335
00336
00337
00338
00339 virtual ::RTT::Corba::Expression_ptr createDataObject (
00340 const char * port_name) = 0;
00341
00342 static void createDataObject_skel (
00343 TAO_ServerRequest & server_request,
00344 void * servant_upcall,
00345 void * servant
00346 );
00347
00348
00349
00350
00351 virtual ::RTT::Corba::DataFlowInterface::ConnectionModel getConnectionModel (
00352 const char * port_name) = 0;
00353
00354 static void getConnectionModel_skel (
00355 TAO_ServerRequest & server_request,
00356 void * servant_upcall,
00357 void * servant
00358 );
00359
00360
00361
00362
00363 virtual ::RTT::Corba::DataFlowInterface::PortType getPortType (
00364 const char * port_name) = 0;
00365
00366 static void getPortType_skel (
00367 TAO_ServerRequest & server_request,
00368 void * servant_upcall,
00369 void * servant
00370 );
00371
00372
00373
00374
00375 virtual char * getDataType (
00376 const char * port_name) = 0;
00377
00378 static void getDataType_skel (
00379 TAO_ServerRequest & server_request,
00380 void * servant_upcall,
00381 void * servant
00382 );
00383
00384
00385
00386
00387 virtual ::CORBA::Boolean isConnected (
00388 const char * port_name) = 0;
00389
00390 static void isConnected_skel (
00391 TAO_ServerRequest & server_request,
00392 void * servant_upcall,
00393 void * servant
00394 );
00395
00396
00397
00398
00399 virtual void disconnect (
00400 const char * port_name) = 0;
00401
00402 static void disconnect_skel (
00403 TAO_ServerRequest & server_request,
00404 void * servant_upcall,
00405 void * servant
00406 );
00407
00408
00409
00410
00411 virtual ::CORBA::Boolean connectDataPort (
00412 const char * port_name,
00413 ::RTT::Corba::AssignableExpression_ptr data) = 0;
00414
00415 static void connectDataPort_skel (
00416 TAO_ServerRequest & server_request,
00417 void * servant_upcall,
00418 void * servant
00419 );
00420
00421
00422
00423
00424 virtual ::CORBA::Boolean connectBufferPort (
00425 const char * port_name,
00426 ::RTT::Corba::BufferChannel_ptr buffer) = 0;
00427
00428 static void connectBufferPort_skel (
00429 TAO_ServerRequest & server_request,
00430 void * servant_upcall,
00431 void * servant
00432 );
00433
00434
00435
00436
00437 virtual ::CORBA::Boolean connectPorts (
00438 const char * local_port,
00439 ::RTT::Corba::DataFlowInterface_ptr remote_ports,
00440 const char * remote_port) = 0;
00441
00442 static void connectPorts_skel (
00443 TAO_ServerRequest & server_request,
00444 void * servant_upcall,
00445 void * servant
00446 );
00447 };
00448
00449
00450
00451
00452 }
00453
00454
00455
00456
00457 }
00458
00459
00460
00461
00462
00463 #if defined (__ACE_INLINE__)
00464 #include "DataFlowS.inl"
00465 #endif
00466
00467 #endif
00468