diff options
author | bala <balanatarajan@users.noreply.github.com> | 2003-12-14 16:03:49 +0000 |
---|---|---|
committer | bala <balanatarajan@users.noreply.github.com> | 2003-12-14 16:03:49 +0000 |
commit | a7e10f0b431dc0e2006196751782cd8fa40b16c7 (patch) | |
tree | 7422441092fdcc31025f06c8f064c7209747eb21 /TAO/tao/GIOP_Message_Lite.h | |
parent | 20ded8e045eb9993cfc20bf788d70329c11feb62 (diff) | |
download | ATCD-a7e10f0b431dc0e2006196751782cd8fa40b16c7.tar.gz |
ChangeLogTag:Sun Dec 14 09:56:37 2003 Balachandran Natarajan <bala@dre.vanderbilt.edu>
Diffstat (limited to 'TAO/tao/GIOP_Message_Lite.h')
-rw-r--r-- | TAO/tao/GIOP_Message_Lite.h | 45 |
1 files changed, 25 insertions, 20 deletions
diff --git a/TAO/tao/GIOP_Message_Lite.h b/TAO/tao/GIOP_Message_Lite.h index bfc7f5f01ad..b10ef17982c 100644 --- a/TAO/tao/GIOP_Message_Lite.h +++ b/TAO/tao/GIOP_Message_Lite.h @@ -88,11 +88,8 @@ public: /// the message. virtual int format_message (TAO_OutputCDR &cdr); - /// Process the request message that we have received on the - /// connection - virtual int process_request_message (TAO_Transport *transport, - TAO_Queued_Data *qd); - + /// Parse the incoming messages.. + virtual int parse_incoming_messages (ACE_Message_Block &message_block); /// Get the message type. The return value would be one of the /// following: @@ -102,25 +99,33 @@ public: /// TAO_PLUGGABLE_MESSAGE_MESSAGE_ERROR. TAO_Pluggable_Message_Type message_type (void); - /*! - \brief Inspects the bytes in \param mb to see if they "look like" the beginning of a message. - Inspects the bytes in \param mb, beginning at \code mb.rd_ptr, to - see if they look like the beginning of a message. Does + /// Calculate the amount of data that is missing in the <incoming> + /// message block. + virtual ssize_t missing_data (ACE_Message_Block &message_block); + + /* Extract the details of the next message from the <incoming> + * through <qd>. Returns 1 if there are more messages and returns a + * 0 if there are no more messages in <incoming>. */ - virtual int check_for_valid_header (const ACE_Message_Block &mb) const; + virtual int extract_next_message (ACE_Message_Block &incoming, + TAO_Queued_Data *&qd); - /*! - \brief Set fields in \param qd based on values derived from \param mb. + /// Check whether the node <qd> needs consolidation from <incoming> + virtual int consolidate_node (TAO_Queued_Data *qd, + ACE_Message_Block &incoming); - This function sets fields in \param qd based on values derived - from \param mb. It assumes that if the length of \param mb is - enough to hold a header, then the data in there can be trusted to - make sense. - */ - virtual void set_queued_data_from_message_header ( - TAO_Queued_Data *, - const ACE_Message_Block &mb) const; + /// Get the details of the message parsed through the <qd>. + virtual void get_message_data (TAO_Queued_Data *qd); + + /// @@Bala: Docu??? + virtual int consolidate_fragments (TAO_Queued_Data *dqd, + const TAO_Queued_Data *sqd); + + /// Process the request message that we have received on the + /// connection + virtual int process_request_message (TAO_Transport *transport, + TAO_Queued_Data *qd); /// Parse the reply message that we received and return the reply /// information though <reply_info> |