#include <RT_ORB.h>
Public Member Functions | |
TAO_RT_ORB (TAO_ORB_Core *orb_core, TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan lifespan, ACE_Time_Value const &dynamic_thread_time) | |
Constructor. | |
virtual RTCORBA::Mutex_ptr | create_mutex (void) |
virtual void | destroy_mutex (RTCORBA::Mutex_ptr the_mutex) |
virtual RTCORBA::Mutex_ptr | create_named_mutex (const char *name, CORBA::Boolean_out created_flag) |
virtual RTCORBA::Mutex_ptr | open_named_mutex (const char *name) |
Retrieve a previously created mutex. | |
RTCORBA::TCPProtocolProperties_ptr | create_tcp_protocol_properties (CORBA::Long send_buffer_size, CORBA::Long recv_buffer_size, CORBA::Boolean keep_alive, CORBA::Boolean dont_route, CORBA::Boolean no_delay, CORBA::Boolean enable_network_priority) |
RTCORBA::UnixDomainProtocolProperties_ptr | create_unix_domain_protocol_properties (CORBA::Long send_buffer_size, CORBA::Long recv_buffer_size) |
RTCORBA::SharedMemoryProtocolProperties_ptr | create_shared_memory_protocol_properties (CORBA::Long send_buffer_size, CORBA::Long recv_buffer_size, CORBA::Boolean keep_alive, CORBA::Boolean dont_route, CORBA::Boolean no_delay, CORBA::Long preallocate_buffer_size, const char *mmap_filename, const char *mmap_lockname) |
RTCORBA::UserDatagramProtocolProperties_ptr | create_user_datagram_protocol_properties (CORBA::Long send_buffer_size, CORBA::Long recv_buffer_size, CORBA::Boolean enable_network_priority) |
RTCORBA::StreamControlProtocolProperties_ptr | create_stream_control_protocol_properties (CORBA::Long send_buffer_size, CORBA::Long recv_buffer_size, CORBA::Boolean keep_alive, CORBA::Boolean dont_route, CORBA::Boolean no_delay, CORBA::Boolean enable_network_priority) |
virtual RTCORBA::ThreadpoolId | create_threadpool (CORBA::ULong stacksize, CORBA::ULong static_threads, CORBA::ULong dynamic_threads, RTCORBA::Priority default_priority, CORBA::Boolean allow_request_buffering, CORBA::ULong max_buffered_requests, CORBA::ULong max_request_buffer_size) |
Create a RTCORBA threadpool to manage a set of threads without lanes. | |
virtual RTCORBA::ThreadpoolId | create_threadpool_with_lanes (CORBA::ULong stacksize, const RTCORBA::ThreadpoolLanes &lanes, CORBA::Boolean allow_borrowing, CORBA::Boolean allow_request_buffering, CORBA::ULong max_buffered_requests, CORBA::ULong max_request_buffer_size) |
virtual void | destroy_threadpool (RTCORBA::ThreadpoolId threadpool) |
Free the resources associated with the specified threadpool. | |
virtual RTCORBA::PriorityModelPolicy_ptr | create_priority_model_policy (RTCORBA::PriorityModel priority_model, RTCORBA::Priority server_priority) |
Create a priority model policy for use when configuring a POA. | |
virtual RTCORBA::ThreadpoolPolicy_ptr | create_threadpool_policy (RTCORBA::ThreadpoolId threadpool) |
Create a ThreadpoolPolicy instance for POA creation. | |
virtual RTCORBA::PriorityBandedConnectionPolicy_ptr | create_priority_banded_connection_policy (const RTCORBA::PriorityBands &priority_bands) |
virtual RTCORBA::PrivateConnectionPolicy_ptr | create_private_connection_policy (void) |
virtual RTCORBA::ServerProtocolPolicy_ptr | create_server_protocol_policy (const RTCORBA::ProtocolList &protocols) |
virtual RTCORBA::ClientProtocolPolicy_ptr | create_client_protocol_policy (const RTCORBA::ProtocolList &protocols) |
TAO_ORB_Core * | orb_core (void) const |
Reference to our creating ORB Core. | |
TAO_Thread_Pool_Manager & | tp_manager (void) const |
Get the Thread Pool Manager. | |
Static Public Member Functions | |
static int | modify_thread_scheduling_policy (CORBA::ORB_ptr orb) |
Protected Member Functions | |
virtual | ~TAO_RT_ORB (void) |
Protected Attributes | |
TAO_ORB_Core *const | orb_core_ |
Reference to our creating ORB Core. | |
TAO_Named_RT_Mutex_Manager | mutex_mgr_ |
mutex_mgr_ manages the names associated with named mutexes. | |
TAO_Thread_Pool_Manager * | tp_manager_ |
Thread Pool Manager. | |
TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan | lifespan_ |
Dynamic thread lifespan policy. | |
ACE_Time_Value const | dynamic_thread_time_ |
Dynamic thread run time. |
Creates and destroys RT CORBA objects, i.e., policies, threadpools, mutexes.
TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_RT_ORB::TAO_RT_ORB | ( | TAO_ORB_Core * | orb_core, | |
TAO_RT_ORBInitializer::TAO_RTCORBA_DT_LifeSpan | lifespan, | |||
ACE_Time_Value const & | dynamic_thread_time | |||
) |
Constructor.
TAO_RT_ORB::~TAO_RT_ORB | ( | void | ) | [protected, virtual] |
Protected destructor to enforce proper memory management of this reference counted object.
RTCORBA::Mutex_ptr TAO_RT_ORB::create_mutex | ( | void | ) | [virtual] |
Create a new mutex. Mutexes returned by this method are the same as those used internally by the ORB, so that consistant priority inheritance/piority ceiling semantics can be guaranteed.
void TAO_RT_ORB::destroy_mutex | ( | RTCORBA::Mutex_ptr | the_mutex | ) | [virtual] |
Destroy a mutex. Currently this is a no-op since RTCORBA::Mutex instances are destroyed as soon as their reference counts go to 0.
RTCORBA::Mutex_ptr TAO_RT_ORB::create_named_mutex | ( | const char * | name, | |
CORBA::Boolean_out | created_flag | |||
) | [virtual] |
Create a mutex and assign a name to it. If the mutex already exists, it is returned and the created_flag is set to 0.
RTCORBA::Mutex_ptr TAO_RT_ORB::open_named_mutex | ( | const char * | name | ) | [virtual] |
Retrieve a previously created mutex.
RTCORBA::TCPProtocolProperties_ptr TAO_RT_ORB::create_tcp_protocol_properties | ( | CORBA::Long | send_buffer_size, | |
CORBA::Long | recv_buffer_size, | |||
CORBA::Boolean | keep_alive, | |||
CORBA::Boolean | dont_route, | |||
CORBA::Boolean | no_delay, | |||
CORBA::Boolean | enable_network_priority | |||
) |
Create and return a TCPProtocolProperties instance with the specified parameters.
RTCORBA::UnixDomainProtocolProperties_ptr TAO_RT_ORB::create_unix_domain_protocol_properties | ( | CORBA::Long | send_buffer_size, | |
CORBA::Long | recv_buffer_size | |||
) |
RTCORBA::SharedMemoryProtocolProperties_ptr TAO_RT_ORB::create_shared_memory_protocol_properties | ( | CORBA::Long | send_buffer_size, | |
CORBA::Long | recv_buffer_size, | |||
CORBA::Boolean | keep_alive, | |||
CORBA::Boolean | dont_route, | |||
CORBA::Boolean | no_delay, | |||
CORBA::Long | preallocate_buffer_size, | |||
const char * | mmap_filename, | |||
const char * | mmap_lockname | |||
) |
RTCORBA::UserDatagramProtocolProperties_ptr TAO_RT_ORB::create_user_datagram_protocol_properties | ( | CORBA::Long | send_buffer_size, | |
CORBA::Long | recv_buffer_size, | |||
CORBA::Boolean | enable_network_priority | |||
) |
RTCORBA::StreamControlProtocolProperties_ptr TAO_RT_ORB::create_stream_control_protocol_properties | ( | CORBA::Long | send_buffer_size, | |
CORBA::Long | recv_buffer_size, | |||
CORBA::Boolean | keep_alive, | |||
CORBA::Boolean | dont_route, | |||
CORBA::Boolean | no_delay, | |||
CORBA::Boolean | enable_network_priority | |||
) |
RTCORBA::ThreadpoolId TAO_RT_ORB::create_threadpool | ( | CORBA::ULong | stacksize, | |
CORBA::ULong | static_threads, | |||
CORBA::ULong | dynamic_threads, | |||
RTCORBA::Priority | default_priority, | |||
CORBA::Boolean | allow_request_buffering, | |||
CORBA::ULong | max_buffered_requests, | |||
CORBA::ULong | max_request_buffer_size | |||
) | [virtual] |
Create a RTCORBA threadpool to manage a set of threads without lanes.
RTCORBA::ThreadpoolId TAO_RT_ORB::create_threadpool_with_lanes | ( | CORBA::ULong | stacksize, | |
const RTCORBA::ThreadpoolLanes & | lanes, | |||
CORBA::Boolean | allow_borrowing, | |||
CORBA::Boolean | allow_request_buffering, | |||
CORBA::ULong | max_buffered_requests, | |||
CORBA::ULong | max_request_buffer_size | |||
) | [virtual] |
Create a threadpool and separate it into subsets based on priorities.
void TAO_RT_ORB::destroy_threadpool | ( | RTCORBA::ThreadpoolId | threadpool | ) | [virtual] |
Free the resources associated with the specified threadpool.
RTCORBA::PriorityModelPolicy_ptr TAO_RT_ORB::create_priority_model_policy | ( | RTCORBA::PriorityModel | priority_model, | |
RTCORBA::Priority | server_priority | |||
) | [virtual] |
Create a priority model policy for use when configuring a POA.
RTCORBA::ThreadpoolPolicy_ptr TAO_RT_ORB::create_threadpool_policy | ( | RTCORBA::ThreadpoolId | threadpool | ) | [virtual] |
Create a ThreadpoolPolicy instance for POA creation.
RTCORBA::PriorityBandedConnectionPolicy_ptr TAO_RT_ORB::create_priority_banded_connection_policy | ( | const RTCORBA::PriorityBands & | priority_bands | ) | [virtual] |
Create a PriorityBandedConnectionPolicy instance for use on either the client or server side
RTCORBA::PrivateConnectionPolicy_ptr TAO_RT_ORB::create_private_connection_policy | ( | void | ) | [virtual] |
Create a PrivateConnectionPolicy instance to use on client to request a private (non-multiplexed) transport connection to the server.
RTCORBA::ServerProtocolPolicy_ptr TAO_RT_ORB::create_server_protocol_policy | ( | const RTCORBA::ProtocolList & | protocols | ) | [virtual] |
Create a ServerProtocolPolicy instance to select and configure communication protocols on the server side.
RTCORBA::ClientProtocolPolicy_ptr TAO_RT_ORB::create_client_protocol_policy | ( | const RTCORBA::ProtocolList & | protocols | ) | [virtual] |
Create a ClientProtocolPolicy instance to select and configure communication protocols on the client side.
TAO_ORB_Core * TAO_RT_ORB::orb_core | ( | void | ) | const |
TAO_Thread_Pool_Manager & TAO_RT_ORB::tp_manager | ( | void | ) | const |
Get the Thread Pool Manager.
int TAO_RT_ORB::modify_thread_scheduling_policy | ( | CORBA::ORB_ptr | orb | ) | [static] |
This method changes the scheduling policy of the calling thread to match the scheduling policy specified in the svc.conf file. The priority of the calling thread will be set to the minimum priority supported by that scheduling policy.
This method make sense on those platform (e.g., Linux) where PTHREAD_SCOPE_SYSTEM is the only scheduling scope supported. On other platforms, this method is a no-op since the only way to get the real-time threading behavior is to setup the PTHREAD_SCOPE_SYSTEM scheduling scope when a thread is being created. On such platforms, one can set the correct scheduling scope and policy when creating the thread, thus not needing to use this method.
TAO_ORB_Core* const TAO_RT_ORB::orb_core_ [protected] |
TAO_Named_RT_Mutex_Manager TAO_RT_ORB::mutex_mgr_ [protected] |
mutex_mgr_ manages the names associated with named mutexes.
TAO_Thread_Pool_Manager* TAO_RT_ORB::tp_manager_ [protected] |
Thread Pool Manager.
Dynamic thread lifespan policy.
ACE_Time_Value const TAO_RT_ORB::dynamic_thread_time_ [protected] |
Dynamic thread run time.