Lookup command object looks up the event type of the given event in the consumer map and send the event to each proxysupplier. More...

#include <Method_Request_Lookup.h>

Inheritance diagram for TAO_Notify_Method_Request_Lookup_Queueable:

[legend]

Collaboration diagram for TAO_Notify_Method_Request_Lookup_Queueable:

[legend]

Public Member Functions
	TAO_Notify_Method_Request_Lookup_Queueable (const TAO_Notify_Event::Ptr &event, TAO_Notify_ProxyConsumer *proxy_consumer)
	Constructor from event.

	TAO_Notify_Method_Request_Lookup_Queueable (TAO_Notify::Delivery_Request_Ptr &request, TAO_Notify_ProxyConsumer *proxy_consumer)
	Constructor from delivery request.

virtual	~TAO_Notify_Method_Request_Lookup_Queueable ()
	Destructor.

virtual int	execute ()
	Execute the Request.

Public Member Functions inherited from TAO_Notify_Method_Request_Lookup
virtual	~TAO_Notify_Method_Request_Lookup ()
	Destructor.

Public Member Functions inherited from TAO_ESF_Worker< TAO_Notify_ProxySupplier >
virtual	~TAO_ESF_Worker ()

virtual void	set_size (size_t size)

virtual void	work (Object *object)=0

Public Member Functions inherited from TAO_Notify_Method_Request_Event
	TAO_Notify_Method_Request_Event (const TAO_Notify_Event *)
	Construct from event.

	TAO_Notify_Method_Request_Event (const TAO_Notify::Delivery_Request_Ptr &delivery_request)
	Construct from a delivery request.

	TAO_Notify_Method_Request_Event (const TAO_Notify_Method_Request_Event &rhs, const TAO_Notify_Event *event)

virtual	~TAO_Notify_Method_Request_Event ()
	Destructor.

const TAO_Notify_Event *	event () const

void	complete ()

unsigned long	sequence ()

bool	should_retry ()

Public Member Functions inherited from TAO_Notify_Method_Request_Queueable
	TAO_Notify_Method_Request_Queueable ()

	TAO_Notify_Method_Request_Queueable (const TAO_Notify_Event *event)

virtual TAO_Notify_Method_Request_Queueable *	copy ()

void	init (const TAO_Notify_Event *event)

const ACE_Time_Value &	creation_time () const
	The creation time of the event to which this request corresponds.

Public Member Functions inherited from ACE_Message_Block
	ACE_Message_Block (ACE_Allocator *message_block_allocator=0)

	ACE_Message_Block (ACE_Data_Block data_block, Message_Flags flags=0, ACE_Allocator message_block_allocator=0)

	ACE_Message_Block (const char *data, size_t size=0, unsigned long priority=ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY)

	ACE_Message_Block (size_t size, ACE_Message_Type type=MB_DATA, ACE_Message_Block cont=nullptr, const char data=nullptr, ACE_Allocator allocator_strategy=nullptr, ACE_Lock locking_strategy=nullptr, unsigned long priority=ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY, const ACE_Time_Value &execution_time=ACE_Time_Value::zero, const ACE_Time_Value &deadline_time=ACE_Time_Value::max_time, ACE_Allocator data_block_allocator=nullptr, ACE_Allocator message_block_allocator=nullptr)

	ACE_Message_Block (const ACE_Message_Block &mb, size_t align)

int	init (const char *data, size_t size=0)

int	init (size_t size, ACE_Message_Type type=MB_DATA, ACE_Message_Block cont=0, const char data=0, ACE_Allocator allocator_strategy=0, ACE_Lock locking_strategy=0, unsigned long priority=ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY, const ACE_Time_Value &execution_time=ACE_Time_Value::zero, const ACE_Time_Value &deadline_time=ACE_Time_Value::max_time, ACE_Allocator data_block_allocator=0, ACE_Allocator message_block_allocator=0)

virtual	~ACE_Message_Block ()

ACE_Message_Type	msg_type () const

void	msg_type (ACE_Message_Type type)

int	is_data_msg () const

ACE_Message_Type	msg_class () const

Message_Flags	set_flags (Message_Flags more_flags)

Message_Flags	clr_flags (Message_Flags less_flags)

Message_Flags	flags () const

Message_Flags	set_self_flags (ACE_Message_Block::Message_Flags more_flags)

Message_Flags	clr_self_flags (ACE_Message_Block::Message_Flags less_flags)

Message_Flags	self_flags () const

unsigned long	msg_priority () const

void	msg_priority (unsigned long priority)

const ACE_Time_Value &	msg_execution_time () const

void	msg_execution_time (const ACE_Time_Value &et)

const ACE_Time_Value &	msg_deadline_time () const

void	msg_deadline_time (const ACE_Time_Value &dt)

virtual ACE_Message_Block *	clone (Message_Flags mask=0) const

virtual ACE_Message_Block *	duplicate () const

virtual ACE_Message_Block *	release ()

int	copy (const char *buf, size_t n)

int	copy (const char *buf)

int	crunch ()

void	reset ()

void	access_allocators (ACE_Allocator &allocator_strategy, ACE_Allocator &data_block_allocator, ACE_Allocator *&message_block_allocator)

void	reset_allocators (ACE_Allocator allocator_strategy=0, ACE_Allocator data_block_allocator=0, ACE_Allocator *message_block_allocator=0)

char *	base () const

void	base (char *data, size_t size, Message_Flags=DONT_DELETE)

char *	end () const

char *	mark () const

char *	rd_ptr () const

void	rd_ptr (char *ptr)

void	rd_ptr (size_t n)

char *	wr_ptr () const

void	wr_ptr (char *ptr)

void	wr_ptr (size_t n)

size_t	length () const

void	length (size_t n)

size_t	total_length () const

size_t	total_size () const

void	total_size_and_length (size_t &mb_size, size_t &mb_length) const

size_t	size () const

int	size (size_t length)

size_t	total_capacity () const

size_t	capacity () const

size_t	space () const

ACE_Data_Block *	data_block () const

void	data_block (ACE_Data_Block *)

ACE_Data_Block *	replace_data_block (ACE_Data_Block *)

ACE_Message_Block *	cont () const

void	cont (ACE_Message_Block *)

ACE_Message_Block *	next () const

void	next (ACE_Message_Block *)

ACE_Message_Block *	prev () const

void	prev (ACE_Message_Block *)

ACE_Lock *	locking_strategy ()

ACE_Lock *	locking_strategy (ACE_Lock *)

int	reference_count () const

void	dump () const

Public Member Functions inherited from TAO_Notify_Method_Request
virtual	~TAO_Notify_Method_Request ()
	Destructor.

Private Attributes
TAO_Notify_Event::Ptr	event_var_

TAO_Notify_ProxyConsumer::Ptr	proxy_guard_

Additional Inherited Members
Public Types inherited from TAO_Notify_Method_Request_Lookup
enum	{ persistence_code = 2 }
	an arbitrary code (Octet) to identify this type of request in persistent storage More...

Public Types inherited from TAO_Notify_Method_Request_Queueable
enum	{ PRIORITY_BASE = 32768 }

Public Types inherited from ACE_Message_Block
typedef int	ACE_Message_Type

typedef unsigned long	Message_Flags

Static Public Member Functions inherited from TAO_Notify_Method_Request_Lookup
static TAO_Notify_Method_Request_Lookup_Queueable *	unmarshal (TAO_Notify::Delivery_Request_Ptr &delivery_request, TAO_Notify_EventChannelFactory &ecf, TAO_InputCDR &cdr)
	Static method used to reconstruct a Method Request Dispatch.

Static Public Member Functions inherited from ACE_Message_Block
static ACE_Message_Block *	duplicate (const ACE_Message_Block *mb)

static ACE_Message_Block *	release (ACE_Message_Block *mb)

Public Attributes inherited from ACE_Message_Block
	MB_DATA

	MB_PROTO

	MB_BREAK

	MB_PASSFP

	MB_EVENT

	MB_SIG

	MB_IOCTL

	MB_SETOPTS

	MB_IOCACK

	MB_IOCNAK

	MB_PCPROTO

	MB_PCSIG

	MB_READ

	MB_FLUSH

	MB_STOP

	MB_START

	MB_HANGUP

	MB_ERROR

	MB_PCEVENT

	MB_NORMAL

	MB_PRIORITY

	MB_USER

	DONT_DELETE

	USER_FLAGS

	ACE_ALLOC_HOOK_DECLARE

Protected Member Functions inherited from TAO_Notify_Method_Request_Lookup
	TAO_Notify_Method_Request_Lookup (const TAO_Notify_Event event, TAO_Notify_ProxyConsumer proxy)
	Constructor.

	TAO_Notify_Method_Request_Lookup (const TAO_Notify::Delivery_Request_Ptr &delivery, TAO_Notify_ProxyConsumer *proxy)
	Constructor.

int	execute_i ()
	Execute the dispatch operation.

virtual void	work (TAO_Notify_ProxySupplier *proxy_supplier)
	= TAO_ESF_Worker method

Protected Member Functions inherited from ACE_Message_Block
	ACE_Message_Block (size_t size, ACE_Message_Type type, ACE_Message_Block cont, const char data, ACE_Allocator allocator_strategy, ACE_Lock locking_strategy, Message_Flags flags, unsigned long priority, const ACE_Time_Value &execution_time, const ACE_Time_Value &deadline_time, ACE_Data_Block db, ACE_Allocator data_block_allocator, ACE_Allocator *message_block_allocator)

int	release_i (ACE_Lock *lock)

int	init_i (size_t size, ACE_Message_Type type, ACE_Message_Block cont, const char data, ACE_Allocator allocator_strategy, ACE_Lock locking_strategy, Message_Flags flags, unsigned long priority, const ACE_Time_Value &execution_time, const ACE_Time_Value &deadline_time, ACE_Data_Block db, ACE_Allocator data_block_allocator, ACE_Allocator *message_block_allocator)

Protected Attributes inherited from TAO_Notify_Method_Request_Lookup
TAO_Notify_ProxyConsumer *	proxy_consumer_
	The Proxy.

Protected Attributes inherited from TAO_Notify_Method_Request_Event
const TAO_Notify_Event *	event_
	The Event.

TAO_Notify::Delivery_Request_Ptr	delivery_request_
	Pointer to the routing slip's delivery request (if any)

Protected Attributes inherited from ACE_Message_Block
size_t	rd_ptr_

size_t	wr_ptr_

unsigned long	priority_

ACE_Message_Block *	cont_

ACE_Message_Block *	next_

ACE_Message_Block *	prev_

ACE_Message_Block::Message_Flags	flags_

ACE_Data_Block *	data_block_

ACE_Allocator *	message_block_allocator_

Detailed Description

Lookup command object looks up the event type of the given event in the consumer map and send the event to each proxysupplier.

Constructor & Destructor Documentation

◆ TAO_Notify_Method_Request_Lookup_Queueable() [1/2]

TAO_Notify_Method_Request_Lookup_Queueable::TAO_Notify_Method_Request_Lookup_Queueable	(	const TAO_Notify_Event::Ptr &	event,
		TAO_Notify_ProxyConsumer *	proxy_consumer )

Constructor from event.

◆ TAO_Notify_Method_Request_Lookup_Queueable() [2/2]

TAO_Notify_Method_Request_Lookup_Queueable::TAO_Notify_Method_Request_Lookup_Queueable	(	TAO_Notify::Delivery_Request_Ptr &	request,
		TAO_Notify_ProxyConsumer *	proxy_consumer )

Constructor from delivery request.

◆ ~TAO_Notify_Method_Request_Lookup_Queueable()

TAO_Notify_Method_Request_Lookup_Queueable::~TAO_Notify_Method_Request_Lookup_Queueable ( )

virtual

Destructor.

Member Function Documentation

◆ execute()

int TAO_Notify_Method_Request_Lookup_Queueable::execute ( )

virtual

Execute the Request.

Implements TAO_Notify_Method_Request.

Member Data Documentation

◆ event_var_

TAO_Notify_Event::Ptr TAO_Notify_Method_Request_Lookup_Queueable::event_var_

private

◆ proxy_guard_

TAO_Notify_ProxyConsumer::Ptr TAO_Notify_Method_Request_Lookup_Queueable::proxy_guard_