#include "tao/Transport.h"#include "tao/LF_Follower.h"#include "tao/Leader_Follower.h"#include "tao/Client_Strategy_Factory.h"#include "tao/Wait_Strategy.h"#include "tao/Transport_Mux_Strategy.h"#include "tao/Stub.h"#include "tao/Transport_Queueing_Strategies.h"#include "tao/Connection_Handler.h"#include "tao/GIOP_Message_Base.h"#include "tao/Synch_Queued_Message.h"#include "tao/Asynch_Queued_Message.h"#include "tao/Flushing_Strategy.h"#include "tao/Thread_Lane_Resources.h"#include "tao/Resume_Handle.h"#include "tao/Codeset_Manager.h"#include "tao/Codeset_Translator_Base.h"#include "tao/debug.h"#include "tao/CDR.h"#include "tao/ORB_Core.h"#include "tao/MMAP_Allocator.h"#include "tao/SystemException.h"#include "tao/operation_details.h"#include "tao/Transport_Descriptor_Interface.h"#include "ace/OS_NS_sys_time.h"#include "ace/OS_NS_stdio.h"#include "ace/Reactor.h"#include "ace/os_include/sys/os_uio.h"#include "ace/High_Res_Timer.h"#include "ace/Countdown_Time.h"#include "ace/CORBA_macros.h"
Go to the source code of this file.
Functions | |
| ACE_RCSID (tao, Transport,"$Id: Transport.cpp 86578 2009-08-31 09:50:31Z vzykov $") static void dump_iov(iovec *iov | |
| orb_core_ (orb_core) | |
| cache_map_entry_ (0) | |
| tms_ (0) | |
| ws_ (0) | |
| bidirectional_flag_ (-1) | |
| opening_connection_role_ (TAO::TAO_UNSPECIFIED_ROLE) | |
| head_ (0) | |
| tail_ (0) | |
| incoming_message_queue_ (orb_core) | |
| current_deadline_ (ACE_Time_Value::zero) | |
| flush_timer_id_ (-1) | |
| transport_timer_ (this) | |
| handler_lock_ (orb_core->resource_factory()->create_cached_connection_lock()) | |
| id_ ((size_t) this) | |
| purging_order_ (0) | |
| recv_buffer_size_ (0) | |
| sent_byte_count_ (0) | |
| is_connected_ (false) | |
| messaging_object_ (0) | |
| char_translator_ (0) | |
| wchar_translator_ (0) | |
| tcs_set_ (0) | |
| first_request_ (true) | |
| partial_message_ (0) | |
| stats_ (0) | |
| flush_in_post_open_ (0) | |
Variables | |
| int | iovcnt |
| int size_t | id |
| int size_t size_t | current_transfer |
| ACE_RCSID | ( | tao | , | |
| Transport | , | |||
| "$Id: Transport.cpp 86578 2009-08-31 09:50:31Z vzykov $" | ||||
| ) |
| bidirectional_flag_ | ( | - | 1 | ) |
| cache_map_entry_ | ( | 0 | ) |
| char_translator_ | ( | 0 | ) |
| current_deadline_ | ( | ACE_Time_Value::zero | ) |
| first_request_ | ( | true | ) |
| flush_in_post_open_ | ( | 0 | ) |
Definition at line 170 of file Transport.cpp.
00171 { 00172 ACE_NEW (this->messaging_object_, 00173 TAO_GIOP_Message_Base (orb_core, 00174 this, 00175 input_cdr_size)); 00176 00177 TAO_Client_Strategy_Factory *cf = 00178 this->orb_core_->client_factory (); 00179 00180 // Create WS now. 00181 this->ws_ = cf->create_wait_strategy (this); 00182 00183 // Create TMS now. 00184 this->tms_ = cf->create_transport_mux_strategy (this); 00185 00186 #if TAO_HAS_TRANSPORT_CURRENT == 1 00187 // Allocate stats 00188 ACE_NEW_THROW_EX (this->stats_, 00189 TAO::Transport::Stats, 00190 CORBA::NO_MEMORY ()); 00191 #endif /* TAO_HAS_TRANSPORT_CURRENT == 1 */ 00192 00193 /* 00194 * Hook to add code that initializes components that 00195 * belong to the concrete protocol implementation. 00196 * Further additions to this Transport class will 00197 * need to add code *before* this hook. 00198 */ 00199 //@@ TAO_TRANSPORT_SPL_CONSTRUCTOR_ADD_HOOK 00200 }
| flush_timer_id_ | ( | - | 1 | ) |
| handler_lock_ | ( | orb_core-> | resource_factory)->create_cached_connection_lock( | ) |
| head_ | ( | 0 | ) |
| id_ | ( | (size_t) | this | ) |
| incoming_message_queue_ | ( | orb_core | ) |
| is_connected_ | ( | false | ) |
| messaging_object_ | ( | 0 | ) |
| opening_connection_role_ | ( | TAO::TAO_UNSPECIFIED_ROLE | ) |
| orb_core_ | ( | orb_core | ) |
| partial_message_ | ( | 0 | ) |
| purging_order_ | ( | 0 | ) |
| recv_buffer_size_ | ( | 0 | ) |
| sent_byte_count_ | ( | 0 | ) |
| stats_ | ( | 0 | ) |
| tail_ | ( | 0 | ) |
| tcs_set_ | ( | 0 | ) |
| tms_ | ( | 0 | ) |
| transport_timer_ | ( | this | ) |
| wchar_translator_ | ( | 0 | ) |
| ws_ | ( | 0 | ) |
| int size_t size_t current_transfer |
Definition at line 56 of file Transport.cpp.
| int size_t id |
Definition at line 56 of file Transport.cpp.
| int iovcnt |
Definition at line 56 of file Transport.cpp.
1.6.1