IMR Activator Interface. More...

#include <ImR_Activator_i.h>

Inheritance diagram for ImR_Activator_i:

[legend]

Collaboration diagram for ImR_Activator_i:

[legend]

Public Member Functions
	ImR_Activator_i ()

void	start_server (const char name, const char cmdline, const char *dir, const ImplementationRepository::EnvironmentList &env)

CORBA::Boolean	kill_server (const char *name, CORBA::Long pid, CORBA::Short signum)

CORBA::Boolean	still_alive (CORBA::Long pid)

void	shutdown ()

int	init (Activator_Options &opts)
	Initialize the Server state - parsing arguments and waiting.

int	fini ()
	Cleans up any state created by init*.

int	handle_timeout (const ACE_Time_Value &, const void *tok)

int	run ()
	Runs the orb.

void	shutdown (bool signaled)
	Shutdown the orb.

Public Member Functions inherited from ACE_Event_Handler
virtual	~ACE_Event_Handler ()=default

virtual ACE_HANDLE	get_handle () const

virtual void	set_handle (ACE_HANDLE)

virtual int	priority () const

virtual void	priority (int priority)

virtual int	handle_input (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_exception (ACE_HANDLE fd=ACE_INVALID_HANDLE)

virtual int	handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask)

virtual int	handle_signal (int signum, siginfo_t =0, ucontext_t =0)

virtual int	resume_handler ()

virtual int	handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE)

virtual int	handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE)

virtual void	reactor (ACE_Reactor *reactor)

virtual ACE_Reactor *	reactor () const

virtual ACE_Reactor_Timer_Interface *	reactor_timer_interface () const

virtual Reference_Count	add_reference ()

virtual Reference_Count	remove_reference ()

Reference_Counting_Policy &	reference_counting_policy ()

Private Types
typedef ACE_Unbounded_Set< ACE_CString >	UniqueServerList

typedef ACE_Hash_Map_Manager_Ex< pid_t, ACE_CString, ACE_Hash_pid_t, ACE_Equal_To_pid_t, ACE_Null_Mutex >	ProcessMap

Private Member Functions
int	init_with_orb (CORBA::ORB_ptr orb, const Activator_Options &opts)

void	register_with_imr (ImplementationRepository::Activator_ptr activator)

int	handle_exit (ACE_Process *process)

int	handle_exit_i (pid_t pid)

bool	still_running_i (const char *name, pid_t &pid)

bool	in_upcall ()

Private Attributes
ACE_Process_Manager	process_mgr_

PortableServer::POA_var	root_poa_

PortableServer::POA_var	imr_poa_

PortableServer::Current_var	current_

ImplementationRepository::Locator_var	locator_

CORBA::Long	registration_token_

CORBA::ORB_var	orb_

unsigned int	debug_

bool	notify_imr_

unsigned int	induce_delay_

ACE_CString	name_

ProcessMap	process_map_

UniqueServerList	running_server_list_

UniqueServerList	dying_server_list_

int	env_buf_len_
	The default environment buffer length.

int	max_env_vars_
	Maximum number of environment variables.

bool	detach_child_

pid_t	active_check_pid_

Friends
class	Active_Pid_Setter

Additional Inherited Members
Public Types inherited from ACE_Event_Handler
typedef long	Reference_Count

Static Public Member Functions inherited from ACE_Event_Handler
static ACE_THR_FUNC_RETURN	read_adapter (void *event_handler)

static int	register_stdin_handler (ACE_Event_Handler eh, ACE_Reactor reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED)

static int	remove_stdin_handler (ACE_Reactor reactor, ACE_Thread_Manager thr_mgr)

Public Attributes inherited from ACE_Event_Handler
	LO_PRIORITY

	HI_PRIORITY

	NULL_MASK

	READ_MASK

	WRITE_MASK

	EXCEPT_MASK

	ACCEPT_MASK

	CONNECT_MASK

	TIMER_MASK

	QOS_MASK

	GROUP_QOS_MASK

	SIGNAL_MASK

	ALL_EVENTS_MASK

	RWE_MASK

	DONT_CALL

	ACE_EVENT_HANDLER_NOT_RESUMED

	ACE_REACTOR_RESUMES_HANDLER

	ACE_APPLICATION_RESUMES_HANDLER

Protected Types inherited from ACE_Event_Handler
typedef std::atomic< Reference_Count >	Atomic_Reference_Count

Protected Member Functions inherited from ACE_Event_Handler
	ACE_Event_Handler (ACE_Reactor *=nullptr, int priority=ACE_Event_Handler::LO_PRIORITY)

Protected Attributes inherited from ACE_Event_Handler
Atomic_Reference_Count	reference_count_

Detailed Description

IMR Activator Interface.

This class provides the interface for the various activities that can be done by the ImR_Activator.

Member Typedef Documentation

◆ ProcessMap

typedef ACE_Hash_Map_Manager_Ex<pid_t, ACE_CString, ACE_Hash_pid_t, ACE_Equal_To_pid_t, ACE_Null_Mutex> ImR_Activator_i::ProcessMap

private

◆ UniqueServerList

typedef ACE_Unbounded_Set<ACE_CString> ImR_Activator_i::UniqueServerList

private

Constructor & Destructor Documentation

◆ ImR_Activator_i()

ImR_Activator_i::ImR_Activator_i ( )

Member Function Documentation

◆ fini()

int ImR_Activator_i::fini ( )

Cleans up any state created by init*.

◆ handle_exit()

int ImR_Activator_i::handle_exit ( ACE_Process * process )

privatevirtual

Reimplemented from ACE_Event_Handler.

◆ handle_exit_i()

int ImR_Activator_i::handle_exit_i ( pid_t pid )

private

◆ handle_timeout()

int ImR_Activator_i::handle_timeout	(	const ACE_Time_Value &	,
		const void *	tok )

virtual

Reimplemented from ACE_Event_Handler.

◆ in_upcall()

bool ImR_Activator_i::in_upcall ( )

private

◆ init()

int ImR_Activator_i::init ( Activator_Options & opts )

Initialize the Server state - parsing arguments and waiting.

◆ init_with_orb()

int ImR_Activator_i::init_with_orb	(	CORBA::ORB_ptr	orb,
		const Activator_Options &	opts )

private

◆ kill_server()

CORBA::Boolean ImR_Activator_i::kill_server	(	const char *	name,
		CORBA::Long	pid,
		CORBA::Short	signum )

◆ register_with_imr()

void ImR_Activator_i::register_with_imr ( ImplementationRepository::Activator_ptr activator )

private

◆ run()

int ImR_Activator_i::run ( )

Runs the orb.

◆ shutdown() [1/2]

void ImR_Activator_i::shutdown ( )

◆ shutdown() [2/2]

void ImR_Activator_i::shutdown ( bool signaled )

Shutdown the orb.

◆ start_server()

void ImR_Activator_i::start_server	(	const char *	name,
		const char *	cmdline,
		const char *	dir,
		const ImplementationRepository::EnvironmentList &	env )

◆ still_alive()

CORBA::Boolean ImR_Activator_i::still_alive ( CORBA::Long pid )

◆ still_running_i()

bool ImR_Activator_i::still_running_i	(	const char *	name,
		pid_t &	pid )

private

Friends And Related Symbol Documentation

◆ Active_Pid_Setter

friend class Active_Pid_Setter

friend

Member Data Documentation

◆ active_check_pid_

pid_t ImR_Activator_i::active_check_pid_

private

◆ current_

PortableServer::Current_var ImR_Activator_i::current_

private

◆ debug_

unsigned int ImR_Activator_i::debug_

private

◆ detach_child_

bool ImR_Activator_i::detach_child_

private

◆ dying_server_list_

UniqueServerList ImR_Activator_i::dying_server_list_

private

◆ env_buf_len_

int ImR_Activator_i::env_buf_len_

private

The default environment buffer length.

◆ imr_poa_

PortableServer::POA_var ImR_Activator_i::imr_poa_

private

◆ induce_delay_

unsigned int ImR_Activator_i::induce_delay_

private

◆ locator_

ImplementationRepository::Locator_var ImR_Activator_i::locator_

private

◆ max_env_vars_

int ImR_Activator_i::max_env_vars_

private

Maximum number of environment variables.

◆ name_

ACE_CString ImR_Activator_i::name_

private

◆ notify_imr_

bool ImR_Activator_i::notify_imr_

private

◆ orb_

CORBA::ORB_var ImR_Activator_i::orb_

private

◆ process_map_

ProcessMap ImR_Activator_i::process_map_

private

◆ process_mgr_

ACE_Process_Manager ImR_Activator_i::process_mgr_

private

◆ registration_token_

CORBA::Long ImR_Activator_i::registration_token_

private

We're given a token when registering with the locator, which we must use when unregistering.

◆ root_poa_

PortableServer::POA_var ImR_Activator_i::root_poa_

private

◆ running_server_list_

UniqueServerList ImR_Activator_i::running_server_list_

private

The documentation for this class was generated from the following files:

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ProcessMap

◆ UniqueServerList

Constructor & Destructor Documentation

◆ ImR_Activator_i()

Member Function Documentation

◆ fini()

◆ handle_exit()

◆ handle_exit_i()

◆ handle_timeout()

◆ in_upcall()

◆ init()

◆ init_with_orb()

◆ kill_server()

◆ register_with_imr()

◆ run()

◆ shutdown() [1/2]

◆ shutdown() [2/2]

◆ start_server()

◆ still_alive()

◆ still_running_i()

Friends And Related Symbol Documentation

◆ Active_Pid_Setter

Member Data Documentation

◆ active_check_pid_

◆ current_

◆ debug_

◆ detach_child_

◆ dying_server_list_

◆ env_buf_len_

◆ imr_poa_

◆ induce_delay_

◆ locator_

◆ max_env_vars_

◆ name_

◆ notify_imr_

◆ orb_

◆ process_map_

◆ process_mgr_

◆ registration_token_

◆ root_poa_

◆ running_server_list_