ChangeLogTag: Wed Mar 15 18:22:52 2000 Balachandran Natarajan <bala@cs.wustl.edu>

1 files changed, 44 insertions, 4 deletions

diff --git a/TAO/tao/IIOP_Transport.h b/TAO/tao/IIOP_Transport.h
index e7d402004d4..08a2adf3e0b 100644
--- a/TAO/tao/IIOP_Transport.h
+++ b/TAO/tao/IIOP_Transport.h
@@ -22,11 +22,15 @@
 
 #include "tao/Pluggable.h"
 
+// BALA Temporrary inclusion
+#include "tao/GIOP_Utils.h"
+#include "tao/operation_details.h"
+
+
 #if !defined (ACE_LACKS_PRAGMA_ONCE)
 # pragma once
 #endif /* ACE_LACKS_PRAGMA_ONCE */
 
-#include "tao/GIOP.h"
 
 // Forward decls.
 class TAO_IIOP_Handler_Base;
@@ -79,6 +83,10 @@ public:
                             int twoway,
                             ACE_Time_Value *max_wait_time);
 
+  virtual CORBA::Boolean 
+  send_request_header (TAO_Operation_Details &opdetails,
+                         TAO_Target_Specification &spec,
+                         TAO_OutputCDR &msg);
 protected:
   TAO_IIOP_Handler_Base *handler_;
   // the connection service handler used for accessing lower layer
@@ -111,28 +119,55 @@ public:
   // = The TAO_Transport methods, please check the documentation in
   //   "tao/Pluggable.h" for more details.
   virtual void start_request (TAO_ORB_Core *orb_core,
-                              const TAO_Profile *profile,
+                              TAO_Target_Specification &spec,
                               TAO_OutputCDR &output,
                               CORBA::Environment &ACE_TRY_ENV = TAO_default_environment ())
     ACE_THROW_SPEC ((CORBA::SystemException));
+  
   virtual void start_locate (TAO_ORB_Core *orb_core,
-                             const TAO_Profile *profile,
-                             CORBA::ULong request_id,
+                             TAO_Target_Specification &spec,
+                             TAO_Operation_Details &opdetails,
                              TAO_OutputCDR &output,
                              CORBA::Environment &ACE_TRY_ENV = TAO_default_environment ())
     ACE_THROW_SPEC ((CORBA::SystemException));
+
   virtual int send_request (TAO_Stub *stub,
                             TAO_ORB_Core *orb_core,
                             TAO_OutputCDR &stream,
                             int twoway,
                             ACE_Time_Value *max_wait_time);
+
   virtual int handle_client_input (int block = 0,
                                    ACE_Time_Value *max_time_value = 0);
   virtual int register_handler (void);
 
+  virtual CORBA::Boolean 
+  send_request_header (TAO_Operation_Details &opdetails,
+                       TAO_Target_Specification &spec,
+                       TAO_OutputCDR &msg);  
+
+  int messaging_init (CORBA::Octet major,
+                      CORBA::Octet minor);
+  // Initialising the messaging object
+
+  void use_lite (CORBA::Boolean flag);
+  // Sets the lite flag
 private:
   TAO_IIOP_Client_Connection_Handler *client_handler_;
   // pointer to the corresponding client side connection handler.
+
+  TAO_Pluggable_Messaging_Interface *client_mesg_factory_;
+  // The message_factor instance specific for this particular
+  // transport protocol.
+  
+  TAO_ORB_Core *orb_core_;
+  // Our ORB core
+
+  CORBA::Boolean lite_flag_;
+  // Are we using lite?
+  
+  TAO_Pluggable_Connector_Params params_;
+  // The reply data that is sent back by the server
 };
 
 // ****************************************************************
@@ -162,6 +197,11 @@ public:
   TAO_GIOP_Message_State message_state_;
   // This keep the state of the current message, to enable
   // non-blocking reads, fragment reassembly, etc.
+  // @@Bala. Should not be here like this
 };
 
+#if defined (__ACE_INLINE__)
+#include "tao/IIOP_Transport.i"
+#endif /* __ACE_INLINE__ */
+
 #endif  /* TAO_IIOP_TRANSPORT_H */