summaryrefslogtreecommitdiff
path: root/ACE/examples/APG/Reactor/Client.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/examples/APG/Reactor/Client.cpp')
-rw-r--r--ACE/examples/APG/Reactor/Client.cpp118
1 files changed, 118 insertions, 0 deletions
diff --git a/ACE/examples/APG/Reactor/Client.cpp b/ACE/examples/APG/Reactor/Client.cpp
new file mode 100644
index 00000000000..b2773bbf7f3
--- /dev/null
+++ b/ACE/examples/APG/Reactor/Client.cpp
@@ -0,0 +1,118 @@
+/**
+ * $Id$
+ *
+ * A simple client program using ACE_Svc_Handler and ACE_Connector.
+ */
+
+#include "ace/OS_NS_stdio.h"
+#include "ace/OS_NS_errno.h"
+#include "ace/OS_NS_string.h"
+#include "ace/OS_NS_sys_time.h"
+#include "Client.h"
+
+// Listing 2 code/ch07
+int Client::open (void *p)
+{
+ ACE_Time_Value iter_delay (2); // Two seconds
+ if (super::open (p) == -1)
+ return -1;
+ this->notifier_.reactor (this->reactor ());
+ this->msg_queue ()->notification_strategy (&this->notifier_);
+ this->iterations_ = 0;
+ return this->reactor ()->schedule_timer
+ (this, 0, ACE_Time_Value::zero, iter_delay);
+}
+// Listing 2
+
+// Listing 3 code/ch07
+int Client::handle_input (ACE_HANDLE)
+{
+ char buf[64];
+ ssize_t recv_cnt = this->peer ().recv (buf, sizeof (buf) - 1);
+ if (recv_cnt > 0)
+ {
+ ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("%.*C"),
+ static_cast<int> (recv_cnt),
+ buf));
+ return 0;
+ }
+
+ if (recv_cnt == 0 || ACE_OS::last_error () != EWOULDBLOCK)
+ {
+ this->reactor ()->end_reactor_event_loop ();
+ return -1;
+ }
+ return 0;
+}
+// Listing 3
+
+// Listing 4 code/ch07
+int Client::handle_timeout(const ACE_Time_Value &, const void *)
+{
+ if (++this->iterations_ >= ITERATIONS)
+ {
+ this->peer ().close_writer ();
+ return 0;
+ }
+
+ ACE_Message_Block *mb;
+ ACE_NEW_RETURN (mb, ACE_Message_Block (128), -1);
+ int nbytes = ACE_OS::sprintf
+ (mb->wr_ptr (), "Iteration %d\n", this->iterations_);
+ ACE_ASSERT (nbytes > 0);
+ mb->wr_ptr (static_cast<size_t> (nbytes));
+ this->putq (mb);
+ return 0;
+}
+// Listing 4
+
+// Listing 5 code/ch07
+int Client::handle_output (ACE_HANDLE)
+{
+ ACE_Message_Block *mb;
+ ACE_Time_Value nowait (ACE_OS::gettimeofday ());
+ while (-1 != this->getq (mb, &nowait))
+ {
+ ssize_t send_cnt =
+ this->peer ().send (mb->rd_ptr (), mb->length ());
+ if (send_cnt == -1)
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("(%P|%t) %p\n"),
+ ACE_TEXT ("send")));
+ else
+ mb->rd_ptr (static_cast<size_t> (send_cnt));
+ if (mb->length () > 0)
+ {
+ this->ungetq (mb);
+ break;
+ }
+ mb->release ();
+ }
+ if (this->msg_queue ()->is_empty ())
+ this->reactor ()->cancel_wakeup
+ (this, ACE_Event_Handler::WRITE_MASK);
+ else
+ this->reactor ()->schedule_wakeup
+ (this, ACE_Event_Handler::WRITE_MASK);
+ return 0;
+}
+// Listing 5
+
+// Listing 6 code/ch07
+int ACE_TMAIN (int, ACE_TCHAR *[])
+{
+ ACE_INET_Addr port_to_connect (ACE_TEXT ("HAStatus"), ACE_LOCALHOST);
+ ACE_Connector<Client, ACE_SOCK_CONNECTOR> connector;
+ Client client;
+ Client *pc = &client;
+ if (connector.connect (pc, port_to_connect) == -1)
+ ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"),
+ ACE_TEXT ("connect")), 1);
+
+ ACE_Reactor::instance ()->run_reactor_event_loop ();
+ return (0);
+}
+// Listing 6
+
+// Listing 7 code/ch07
+// Listing 7