diff options
Diffstat (limited to 'TAO/tao')
-rw-r--r-- | TAO/tao/Block_Flushing_Strategy.cpp | 6 | ||||
-rw-r--r-- | TAO/tao/Block_Flushing_Strategy.h | 1 | ||||
-rw-r--r-- | TAO/tao/Flushing_Strategy.cpp | 6 | ||||
-rw-r--r-- | TAO/tao/Flushing_Strategy.h | 2 | ||||
-rw-r--r-- | TAO/tao/Transport.cpp | 10 |
5 files changed, 0 insertions, 25 deletions
diff --git a/TAO/tao/Block_Flushing_Strategy.cpp b/TAO/tao/Block_Flushing_Strategy.cpp index f763f46cc3d..397e4717006 100644 --- a/TAO/tao/Block_Flushing_Strategy.cpp +++ b/TAO/tao/Block_Flushing_Strategy.cpp @@ -49,10 +49,4 @@ TAO_Block_Flushing_Strategy::flush_transport (TAO_Transport *transport, return 0; } -bool TAO_Block_Flushing_Strategy::is_blocking () -{ - return true; -} - - TAO_END_VERSIONED_NAMESPACE_DECL diff --git a/TAO/tao/Block_Flushing_Strategy.h b/TAO/tao/Block_Flushing_Strategy.h index 2f94f4f45b9..b82ec8db0ee 100644 --- a/TAO/tao/Block_Flushing_Strategy.h +++ b/TAO/tao/Block_Flushing_Strategy.h @@ -37,7 +37,6 @@ public: ACE_Time_Value *max_wait_time); virtual int flush_transport (TAO_Transport *transport , ACE_Time_Value *max_wait_time); - virtual bool is_blocking (); }; TAO_END_VERSIONED_NAMESPACE_DECL diff --git a/TAO/tao/Flushing_Strategy.cpp b/TAO/tao/Flushing_Strategy.cpp index 72024d924da..6d66ee99975 100644 --- a/TAO/tao/Flushing_Strategy.cpp +++ b/TAO/tao/Flushing_Strategy.cpp @@ -13,10 +13,4 @@ TAO_Flushing_Strategy::~TAO_Flushing_Strategy (void) { } -bool TAO_Flushing_Strategy::is_blocking () -{ - return false; -} - - TAO_END_VERSIONED_NAMESPACE_DECL diff --git a/TAO/tao/Flushing_Strategy.h b/TAO/tao/Flushing_Strategy.h index 4787c63c51d..4bcab3d5589 100644 --- a/TAO/tao/Flushing_Strategy.h +++ b/TAO/tao/Flushing_Strategy.h @@ -76,8 +76,6 @@ public: /// Wait until the transport has no messages queued. virtual int flush_transport (TAO_Transport *transport, ACE_Time_Value *max_wait_time) = 0; - - virtual bool is_blocking (); }; TAO_END_VERSIONED_NAMESPACE_DECL diff --git a/TAO/tao/Transport.cpp b/TAO/tao/Transport.cpp index ea6e73f1382..9494364a241 100644 --- a/TAO/tao/Transport.cpp +++ b/TAO/tao/Transport.cpp @@ -987,16 +987,6 @@ TAO_Transport::drain_queue_helper (int &iovcnt, iovec iov[], if (errno == EWOULDBLOCK || errno == EAGAIN) { - if (this->orb_core ()->flushing_strategy ()->is_blocking ()) - { - // If the flushing strategy has "blocking" behavior, we can't - // return 0 here because it would loop indefinitely calling - // back into handle_output() and returning EWOULDBLOCK. - // This is an error condition because TAO can't handle an - // EWOULDBLOCK with a blocking flushing strategy. - return -1; - } - return 0; } |