TAO_GIOP_Message_Base Class Reference

Definitions of the GIOP specific stuff. More...

#include <GIOP_Message_Base.h>

Inheritance diagram for TAO_GIOP_Message_Base:

[legend]Collaboration diagram for TAO_GIOP_Message_Base:

[legend]List of all members.

Public Member Functions
	TAO_GIOP_Message_Base (TAO_ORB_Core *orb_core, size_t input_cdr_size=ACE_CDR::DEFAULT_BUFSIZE)
	Constructor.
virtual	~TAO_GIOP_Message_Base (void)
	Dtor.
virtual void	init (CORBA::Octet major, CORBA::Octet minor)
virtual void	reset (void)
	Reset the messaging the object.
virtual int	generate_request_header (TAO_Operation_Details &op, TAO_Target_Specification &spec, TAO_OutputCDR &cdr)
virtual int	generate_locate_request_header (TAO_Operation_Details &op, TAO_Target_Specification &spec, TAO_OutputCDR &cdr)
	Write the RequestHeader in to the cdr stream.
virtual int	generate_reply_header (TAO_OutputCDR &cdr, TAO_Pluggable_Reply_Params_Base &params)
	Write the reply header.
virtual int	format_message (TAO_OutputCDR &cdr)
virtual int	parse_next_message (ACE_Message_Block &incoming, TAO_Queued_Data &qd, size_t &mesg_length)
virtual int	extract_next_message (ACE_Message_Block &incoming, TAO_Queued_Data *&qd)
virtual int	consolidate_node (TAO_Queued_Data *qd, ACE_Message_Block &incoming)
	Check whether the node qd needs consolidation from incoming.
virtual int	process_request_message (TAO_Transport *transport, TAO_Queued_Data *qd)
virtual int	process_reply_message (TAO_Pluggable_Reply_Params &reply_info, TAO_Queued_Data *qd)
virtual int	generate_exception_reply (TAO_OutputCDR &cdr, TAO_Pluggable_Reply_Params_Base &params, CORBA::Exception &x)
	Generate a reply message with the exception ex.
virtual size_t	header_length (void) const
	Header length.
virtual size_t	fragment_header_length (CORBA::Octet major, CORBA::Octet minor) const
	The header length of a fragment.
virtual TAO_OutputCDR &	out_stream (void)
	Accessor for the output CDR stream.
virtual int	consolidate_fragmented_message (TAO_Queued_Data *qd, TAO_Queued_Data *&msg)
virtual int	discard_fragmented_message (const TAO_Queued_Data *cancel_request)
Protected Member Functions
virtual int	process_request (TAO_Transport *transport, TAO_InputCDR &input, TAO_OutputCDR &output, TAO_GIOP_Message_Generator_Parser *)
	Processes the GIOP_REQUEST messages.
virtual int	process_locate_request (TAO_Transport *transport, TAO_InputCDR &input, TAO_OutputCDR &output, TAO_GIOP_Message_Generator_Parser *)
	Processes the GIOP_LOCATE_REQUEST messages.
void	set_state (CORBA::Octet major, CORBA::Octet minor, TAO_GIOP_Message_Generator_Parser *&) const
	Set the state.
void	dump_msg (const char *label, const u_char *ptr, size_t len)
	Print out a debug messages..
TAO_Pluggable_Message_Type	message_type (const TAO_GIOP_Message_State &state) const
int	write_protocol_header (TAO_GIOP_Message_Type t, TAO_OutputCDR &msg)
int	make_send_locate_reply (TAO_Transport *transport, TAO_GIOP_Locate_Request_Header &request, TAO_GIOP_Locate_Status_Msg &status, TAO_OutputCDR &output, TAO_GIOP_Message_Generator_Parser *)
int	send_error (TAO_Transport *transport)
	Send error messages.
void	send_close_connection (const TAO_GIOP_Message_Version &version, TAO_Transport *transport, void *ctx)
	Close a connection, first sending GIOP::CloseConnection.
int	send_reply_exception (TAO_Transport *transport, TAO_OutputCDR &cdr, CORBA::ULong request_id, IOP::ServiceContextList *svc_info, CORBA::Exception *x)
virtual int	generate_locate_reply_header (TAO_OutputCDR &, TAO_Pluggable_Reply_Params_Base &)
	Write the locate reply header.
virtual int	is_ready_for_bidirectional (TAO_OutputCDR &msg)
TAO_Queued_Data *	make_queued_data (size_t sz)
void	init_queued_data (TAO_Queued_Data *qd, const TAO_GIOP_Message_State &state) const
Protected Attributes
char	buffer_ [ACE_CDR::DEFAULT_BUFSIZE]
TAO_OutputCDR	out_stream_
	Buffer where the request is placed.
Private Member Functions
int	parse_incoming_messages (ACE_Message_Block &incoming)
int	parse_request_id (const TAO_Queued_Data *qd, CORBA::ULong &request_id) const
int	parse_request_id (const TAO_InputCDR &cdr, CORBA::ULong &request_id) const
Private Attributes
TAO_ORB_Core *	orb_core_
	Cached ORB_Core pointer...
TAO_GIOP_Message_State	message_state_
TAO_GIOP_Message_Generator_Parser_Impl	tao_giop_impl_
	All the implementations of GIOP message generator and parsers.
TAO::Incoming_Message_Stack	fragment_stack_

---

Detailed Description

Definitions of the GIOP specific stuff.

This class will hold the specific details common to all the GIOP versions. Some of them which are here may be shifted if things start changing between versions. This class uses the TAO_GIOP_Message_Reactive_Handler to read and parse messages.

---

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_GIOP_Message_Base::TAO_GIOP_Message_Base (  TAO_ORB_Core *  orb_core, size_t  input_cdr_size = ACE_CDR::DEFAULT_BUFSIZE )

Constructor.

TAO_GIOP_Message_Base::~TAO_GIOP_Message_Base (  void   )  [virtual]

Dtor.

---

Member Function Documentation

int TAO_GIOP_Message_Base::consolidate_fragmented_message (  TAO_Queued_Data *  qd, TAO_Queued_Data *&  msg )  [virtual]

Consolidate fragmented message with associated fragments, being stored withi this class. If reliable transport is used (like TCP) fragments are partialy ordered on stack, last fragment on top. Otherwise If un-reliable transport is used (like UDP) fragments may be dis-ordered, and must be ordered before consolidation. Returns: 0 on success and msg points to consolidated message, 1 if there are still fragmens outstanding, in case of error -1 is being returned. In any case qd must be released by method implementation. Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::consolidate_node (  TAO_Queued_Data *  qd, ACE_Message_Block &  incoming )  [virtual]

Check whether the node qd needs consolidation from incoming. Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::discard_fragmented_message (  const TAO_Queued_Data *  cancel_request  )  [virtual]

Discard all fragments associated to request-id encoded in cancel_request. This operation will never be called concurrently by multiplpe threads nor concurrently to consolidate_fragmented_message Returns: -1 on failure, 0 on success, 1 no fragment on stack relating to CancelRequest. Implements TAO_Pluggable_Messaging.

void TAO_GIOP_Message_Base::dump_msg (  const char *  label, const u_char *  ptr, size_t  len )  [protected]

Print out a debug messages..

int TAO_GIOP_Message_Base::extract_next_message (  ACE_Message_Block &  incoming, TAO_Queued_Data *&  qd )  [virtual]

Extract the details of the next message from the incoming through qd. Returns 0 if the message header could not be parsed completely, returns a 1 if the message header could be parsed completely and returns -1 on error. Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::format_message (  TAO_OutputCDR &  cdr  )  [virtual]

Format the message. As we have not written the message length in the header, we make use of this oppurtunity to insert and format the message. Implements TAO_Pluggable_Messaging.

size_t TAO_GIOP_Message_Base::fragment_header_length (  CORBA::Octet  major, CORBA::Octet  minor )  const [virtual]

The header length of a fragment. Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::generate_exception_reply (  TAO_OutputCDR &  cdr, TAO_Pluggable_Reply_Params_Base &  params, CORBA::Exception &  x )  [virtual]

Generate a reply message with the exception ex. Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::generate_locate_reply_header (  TAO_OutputCDR &  , TAO_Pluggable_Reply_Params_Base &  )  [protected, virtual]

Write the locate reply header. Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::generate_locate_request_header (  TAO_Operation_Details &  op, TAO_Target_Specification &  spec, TAO_OutputCDR &  cdr )  [virtual]

Write the RequestHeader in to the cdr stream. Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::generate_reply_header (  TAO_OutputCDR &  cdr, TAO_Pluggable_Reply_Params_Base &  params )  [virtual]

Write the reply header. Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::generate_request_header (  TAO_Operation_Details &  op, TAO_Target_Specification &  spec, TAO_OutputCDR &  cdr )  [virtual]

Write the RequestHeader in to the cdr stream. The underlying implementation of the mesaging should do the right thing. Implements TAO_Pluggable_Messaging.

size_t TAO_GIOP_Message_Base::header_length (  void   )  const [virtual]

Header length. Implements TAO_Pluggable_Messaging.

void TAO_GIOP_Message_Base::init (  CORBA::Octet  major, CORBA::Octet  minor )  [virtual]

Initialize the underlying state object based on the major and minor revision numbers Implements TAO_Pluggable_Messaging.

void TAO_GIOP_Message_Base::init_queued_data (  TAO_Queued_Data *  qd, const TAO_GIOP_Message_State &  state )  const [protected]

Initialize the TAO_Queued_Data from the relevant portions of a GIOP_Message_State.

int TAO_GIOP_Message_Base::is_ready_for_bidirectional (  TAO_OutputCDR &  msg  )  [protected, virtual]

Is the messaging object ready for processing BiDirectional request/response? Implements TAO_Pluggable_Messaging.

TAO_Queued_Data * TAO_GIOP_Message_Base::make_queued_data (  size_t  sz  )  [protected]

Creates a new node for the queue with a message block in the node of size sz.

int TAO_GIOP_Message_Base::make_send_locate_reply (  TAO_Transport *  transport, TAO_GIOP_Locate_Request_Header &  request, TAO_GIOP_Locate_Status_Msg &  status, TAO_OutputCDR &  output, TAO_GIOP_Message_Generator_Parser *  )  [protected]

Make a GIOP_LOCATEREPLY and hand that over to the transport so that it can be sent over the connection. Note: As on date 1.1 & 1.2 seem to have similar headers. Till an unmanageable difference comes let them be implemented here.

TAO_Pluggable_Message_Type TAO_GIOP_Message_Base::message_type (  const TAO_GIOP_Message_State &  state  )  const [protected]

Get the message type. The return value would be one of the following: TAO_PLUGGABLE_MESSAGE_REQUEST, TAO_PLUGGABLE_MESSAGE_REPLY, TAO_PLUGGABLE_MESSAGE_CLOSECONNECTION, TAO_PLUGGABLE_MESSAGE_MESSAGE_ERROR.

TAO_OutputCDR & TAO_GIOP_Message_Base::out_stream (  void   )  [virtual]

Accessor for the output CDR stream. Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::parse_incoming_messages (  ACE_Message_Block &  incoming  )  [private]

int TAO_GIOP_Message_Base::parse_next_message (  ACE_Message_Block &  incoming, TAO_Queued_Data &  qd, size_t &  mesg_length )  [virtual]

Parse the details of the next message from the incoming and initializes attributes of qd. Returns 0 if the message header could not be parsed completely, returns a 1 if the message header could be parsed completely and returns -1 on error. Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::parse_request_id (  const TAO_InputCDR &  cdr, CORBA::ULong &  request_id )  const [private]

Parse GIOP request-id of TAO_InputCDR cdr. Returns: 0 on success, otherwise -1

int TAO_GIOP_Message_Base::parse_request_id (  const TAO_Queued_Data *  qd, CORBA::ULong &  request_id )  const [private]

Parse GIOP request-id of TAO_Queued_Data qd Returns: 0 on success, otherwise -1

int TAO_GIOP_Message_Base::process_locate_request (  TAO_Transport *  transport, TAO_InputCDR &  input, TAO_OutputCDR &  output, TAO_GIOP_Message_Generator_Parser *  )  [protected, virtual]

Processes the GIOP_LOCATE_REQUEST messages.

int TAO_GIOP_Message_Base::process_reply_message (  TAO_Pluggable_Reply_Params &  reply_info, TAO_Queued_Data *  qd )  [virtual]

Parse the reply message that we received and return the reply information through reply_info Implements TAO_Pluggable_Messaging.

int TAO_GIOP_Message_Base::process_request (  TAO_Transport *  transport, TAO_InputCDR &  input, TAO_OutputCDR &  output, TAO_GIOP_Message_Generator_Parser *  )  [protected, virtual]

Processes the GIOP_REQUEST messages.

int TAO_GIOP_Message_Base::process_request_message (  TAO_Transport *  transport, TAO_Queued_Data *  qd )  [virtual]

Process the request message that we have received on the connection Implements TAO_Pluggable_Messaging.

void TAO_GIOP_Message_Base::reset (  void   )  [virtual]

Reset the messaging the object. Implements TAO_Pluggable_Messaging.

void TAO_GIOP_Message_Base::send_close_connection (  const TAO_GIOP_Message_Version &  version, TAO_Transport *  transport, void *  ctx )  [protected]

Close a connection, first sending GIOP::CloseConnection.

int TAO_GIOP_Message_Base::send_error (  TAO_Transport *  transport  )  [protected]

Send error messages.

int TAO_GIOP_Message_Base::send_reply_exception (  TAO_Transport *  transport, TAO_OutputCDR &  cdr, CORBA::ULong  request_id, IOP::ServiceContextList *  svc_info, CORBA::Exception *  x )  [protected]

We must send a LocateReply through transport, this request resulted in some kind of exception.

void TAO_GIOP_Message_Base::set_state (  CORBA::Octet  major, CORBA::Octet  minor, TAO_GIOP_Message_Generator_Parser *&  )  const [protected]

Set the state.

int TAO_GIOP_Message_Base::write_protocol_header (  TAO_GIOP_Message_Type  t, TAO_OutputCDR &  msg )  [protected]

Writes the GIOP header in to msg Note: If the GIOP header happens to change in the future, we can push this method in to the generator_parser classes.

---

Member Data Documentation

char TAO_GIOP_Message_Base::buffer_[ACE_CDR::DEFAULT_BUFSIZE] [protected]

Buffer used for both the output and input CDR streams, this is "safe" because we only one of the streams at a time.

TAO::Incoming_Message_Stack TAO_GIOP_Message_Base::fragment_stack_ [private]

All Fragments being received are stored on stack in reverse order, last top

TAO_GIOP_Message_State TAO_GIOP_Message_Base::message_state_ [private]

The message handler object that does reading and parsing of the incoming messages

TAO_ORB_Core* TAO_GIOP_Message_Base::orb_core_ [private]

Cached ORB_Core pointer...

TAO_OutputCDR TAO_GIOP_Message_Base::out_stream_ [protected]

Buffer where the request is placed.

TAO_GIOP_Message_Generator_Parser_Impl TAO_GIOP_Message_Base::tao_giop_impl_ [private]

All the implementations of GIOP message generator and parsers.

---

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

• GIOP_Message_Base.h
• GIOP_Message_Base.cpp

---