diff options
author | bala <balanatarajan@users.noreply.github.com> | 2002-04-17 17:25:37 +0000 |
---|---|---|
committer | bala <balanatarajan@users.noreply.github.com> | 2002-04-17 17:25:37 +0000 |
commit | 8bb125a332a6b0bbcbd341d46113792e70fa60bf (patch) | |
tree | 47c8d82ba4558cfa43eb01d267ef68395bba5e58 /TAO/tao/GIOP_Message_Base.h | |
parent | 0b04ad8569af741c169205ca8743f61ab3bf4f13 (diff) | |
download | ATCD-8bb125a332a6b0bbcbd341d46113792e70fa60bf.tar.gz |
ChangeLogTag: Wed Apr 17 12:25:31 2002 Balachandran Natarajan <bala@cs.wustl.edu>
Diffstat (limited to 'TAO/tao/GIOP_Message_Base.h')
-rw-r--r-- | TAO/tao/GIOP_Message_Base.h | 62 |
1 files changed, 31 insertions, 31 deletions
diff --git a/TAO/tao/GIOP_Message_Base.h b/TAO/tao/GIOP_Message_Base.h index cd5ffc5fe55..44b0feeefba 100644 --- a/TAO/tao/GIOP_Message_Base.h +++ b/TAO/tao/GIOP_Message_Base.h @@ -47,7 +47,7 @@ public: /// Constructor TAO_GIOP_Message_Base (TAO_ORB_Core *orb_core, - size_t input_cdr_size = ACE_CDR::DEFAULT_BUFSIZE); + size_t input_cdr_size = ACE_CDR::DEFAULT_BUFSIZE); /// Dtor virtual ~TAO_GIOP_Message_Base (void); @@ -55,7 +55,7 @@ public: /// Initialize the underlying state object based on the <major> and /// <minor> revision numbers virtual void init (CORBA::Octet major, - CORBA::Octet minor); + CORBA::Octet minor); /// Reset the messaging the object virtual void reset (void); @@ -63,8 +63,8 @@ public: /// Write the RequestHeader in to the <cdr> stream. The underlying /// implementation of the mesaging should do the right thing. virtual int generate_request_header (TAO_Operation_Details &op, - TAO_Target_Specification &spec, - TAO_OutputCDR &cdr); + TAO_Target_Specification &spec, + TAO_OutputCDR &cdr); /// Write the RequestHeader in to the <cdr> stream. virtual int generate_locate_request_header ( @@ -84,8 +84,8 @@ public: /// message is read and handled. Returns -1 on errors. If <block> is /// 1, then reply is read in a blocking manner. virtual int read_message (TAO_Transport *transport, - int block = 0, - ACE_Time_Value *max_wait_time = 0); + int block = 0, + ACE_Time_Value *max_wait_time = 0); /// Format the message. As we have not written the message length in @@ -105,23 +105,23 @@ public: * 0 if there are no more messages in <incoming>. */ virtual int extract_next_message (ACE_Message_Block &incoming, - TAO_Queued_Data *&qd); + TAO_Queued_Data *&qd); /// Check whether the node <qd> needs consolidation from <incoming> virtual int consolidate_node (TAO_Queued_Data *qd, - ACE_Message_Block &incoming); + ACE_Message_Block &incoming); /// 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); + 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); + TAO_Queued_Data *qd); /// Parse the reply message that we received and return the reply @@ -143,25 +143,25 @@ protected: /// Processes the <GIOP_REQUEST> messages int process_request (TAO_Transport *transport, - TAO_InputCDR &input, - TAO_OutputCDR &output, - TAO_GIOP_Message_Generator_Parser *); + TAO_InputCDR &input, + TAO_OutputCDR &output, + TAO_GIOP_Message_Generator_Parser *); /// Processes the <GIOP_LOCATE_REQUEST> messages int process_locate_request (TAO_Transport *transport, - TAO_InputCDR &input, - TAO_OutputCDR &output, - TAO_GIOP_Message_Generator_Parser *); + TAO_InputCDR &input, + TAO_OutputCDR &output, + TAO_GIOP_Message_Generator_Parser *); /// Set the state void set_state (CORBA::Octet major, - CORBA::Octet minor, - TAO_GIOP_Message_Generator_Parser *&); + CORBA::Octet minor, + TAO_GIOP_Message_Generator_Parser *&); /// Print out a debug messages.. void dump_msg (const char *label, - const u_char *ptr, - size_t len); + const u_char *ptr, + size_t len); /// Get the message type. The return value would be one of the /// following: @@ -177,33 +177,33 @@ private: /// NOTE: If the GIOP header happens to change in the future, we can /// push this method in to the generator_parser classes. int write_protocol_header (TAO_GIOP_Message_Type t, - TAO_OutputCDR &msg); + TAO_OutputCDR &msg); /// 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. 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 *); + TAO_GIOP_Locate_Request_Header &request, + TAO_GIOP_Locate_Status_Msg &status, + TAO_OutputCDR &output, + TAO_GIOP_Message_Generator_Parser *); /// Send error messages int send_error (TAO_Transport *transport); /// Close a connection, first sending GIOP::CloseConnection. void send_close_connection (const TAO_GIOP_Message_Version &version, - TAO_Transport *transport, - void *ctx); + TAO_Transport *transport, + void *ctx); /// We must send a LocateReply through <transport>, this request /// resulted in some kind of exception. int send_reply_exception (TAO_Transport *transport, - TAO_ORB_Core* orb_core, - CORBA::ULong request_id, - IOP::ServiceContextList *svc_info, - CORBA::Exception *x); + TAO_OutputCDR &cdr, + CORBA::ULong request_id, + IOP::ServiceContextList *svc_info, + CORBA::Exception *x); /// Write the locate reply header |