summaryrefslogtreecommitdiff
path: root/TAO/tao/Blocked_Connect_Strategy.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/Blocked_Connect_Strategy.cpp')
-rw-r--r--TAO/tao/Blocked_Connect_Strategy.cpp45
1 files changed, 45 insertions, 0 deletions
diff --git a/TAO/tao/Blocked_Connect_Strategy.cpp b/TAO/tao/Blocked_Connect_Strategy.cpp
new file mode 100644
index 00000000000..6cd123fcf49
--- /dev/null
+++ b/TAO/tao/Blocked_Connect_Strategy.cpp
@@ -0,0 +1,45 @@
+#include "tao/Blocked_Connect_Strategy.h"
+#include "tao/Connection_Handler.h"
+
+#include "ace/Synch_Options.h"
+
+ACE_RCSID(tao,
+ Blocked_Connect_Strategy,
+ "$Id$")
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+TAO_Blocked_Connect_Strategy::TAO_Blocked_Connect_Strategy (
+ TAO_ORB_Core *orb_core)
+ : TAO_Connect_Strategy (orb_core)
+{
+}
+
+void
+TAO_Blocked_Connect_Strategy::synch_options (ACE_Time_Value *timeout,
+ ACE_Synch_Options &options)
+{
+ if (timeout != 0)
+ {
+ // Blocking with a timeout
+ options.set (ACE_Synch_Options::USE_TIMEOUT,
+ *timeout);
+ }
+ else
+ {
+ // Making it sure it is blocking.
+ options.set (0,
+ ACE_Time_Value::zero);
+ }
+}
+
+int
+TAO_Blocked_Connect_Strategy::wait_i (TAO_LF_Event *,
+ TAO_Transport *,
+ ACE_Time_Value * )
+{
+ // We cannot wait for connection completion
+ return -1;
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL