00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016 #ifndef TAO_ACCEPTOR_REGISTRY_H
00017 #define TAO_ACCEPTOR_REGISTRY_H
00018
00019 #include "ace/pre.h"
00020 #include "ace/Unbounded_Set.h"
00021
00022 #if !defined (ACE_LACKS_PRAGMA_ONCE)
00023 # pragma once
00024 #endif
00025
00026 #include "tao/TAO_Export.h"
00027 #include "tao/Exception.h"
00028 #include "tao/params.h"
00029
00030 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
00031 class ACE_Addr;
00032 class ACE_Reactor;
00033 ACE_END_VERSIONED_NAMESPACE_DECL
00034
00035 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
00036
00037 class TAO_ORB_Core;
00038 class TAO_Acceptor;
00039 class TAO_Acceptor_Filter;
00040 class TAO_Stub;
00041 class TAO_Profile;
00042 class TAO_MProfile;
00043 class TAO_Protocol_Factory;
00044 class TAO_Protocol_Item;
00045
00046 typedef ACE_Unbounded_Set_Iterator<TAO_Protocol_Item *>
00047 TAO_ProtocolFactorySetItor;
00048
00049 typedef TAO_Acceptor** TAO_AcceptorSetIterator;
00050
00051
00052
00053
00054
00055
00056
00057
00058
00059
00060
00061
00062 class TAO_Export TAO_Acceptor_Registry
00063 {
00064 public:
00065
00066
00067 TAO_Acceptor_Registry (void);
00068
00069
00070 ~TAO_Acceptor_Registry (void);
00071
00072
00073 int open (TAO_ORB_Core *orb_core,
00074 ACE_Reactor *reactor,
00075 const TAO_EndpointSet &endpoint_set,
00076 bool ignore_address
00077 ACE_ENV_ARG_DECL);
00078
00079
00080 int close_all (void);
00081
00082
00083 size_t endpoint_count (void);
00084
00085
00086
00087 int is_collocated (const TAO_MProfile& mprofile);
00088
00089
00090 TAO_Acceptor *get_acceptor (CORBA::ULong tag);
00091
00092
00093 TAO_AcceptorSetIterator begin (void);
00094 TAO_AcceptorSetIterator end (void);
00095
00096 private:
00097
00098
00099 int open_default (TAO_ORB_Core *orb_core,
00100 ACE_Reactor *reactor,
00101 const char *options);
00102
00103
00104 int open_default (TAO_ORB_Core *orb_core,
00105 ACE_Reactor *reactor,
00106 int major,
00107 int minor,
00108 TAO_ProtocolFactorySetItor &factory,
00109 const char *options);
00110
00111
00112 int open_default_i (TAO_ORB_Core *orb_core,
00113 ACE_Reactor *reactor,
00114 int major,
00115 int minor,
00116 TAO_ProtocolFactorySetItor &factory,
00117 TAO_Acceptor* acceptor,
00118 const char *options);
00119
00120
00121 void extract_endpoint_options (ACE_CString &addrs,
00122 ACE_CString &options,
00123 TAO_Protocol_Factory *factory);
00124
00125
00126
00127 void extract_endpoint_version (ACE_CString &address,
00128 int &major,
00129 int &minor);
00130
00131
00132
00133 int open_i (TAO_ORB_Core *orb_core,
00134 ACE_Reactor *reactor,
00135 ACE_CString &address,
00136 TAO_ProtocolFactorySetItor &factory,
00137 bool ignore_address
00138 ACE_ENV_ARG_DECL);
00139
00140 private:
00141
00142
00143 TAO_Acceptor_Registry (const TAO_Acceptor_Registry&);
00144 void operator= (const TAO_Acceptor_Registry&);
00145
00146 private:
00147
00148 TAO_Acceptor **acceptors_;
00149
00150
00151 size_t size_;
00152 };
00153
00154 TAO_END_VERSIONED_NAMESPACE_DECL
00155
00156 #if defined(__ACE_INLINE__)
00157 #include "tao/Acceptor_Registry.i"
00158 #endif
00159
00160 #include "ace/post.h"
00161
00162 #endif