ACE/tests/XtMotifReactor_Test.cpp

   1 /* -*- C++ -*- */
   2
   3 //=============================================================================
   4 /**
   5  *  @file    XtMotifReactor_Test.cpp
   6  *
   7  *    This is a simple test that illustrates the possibility to integrate
   8  *    ACE to the X Main Loop. This program uses ACE_XtReactor class to
   9  *    schedule three additional event sources:
  10  *    1. Events from button "Stop Test" (registed with XtAddCallback)
  11  *    2. Events from button "Press Me" (registed with XtAddCallback)
  12  *    3. Events from X timer (registed with XtAppAddTimeOut)
  13  *    4. Events from ACE timer (registed with ACE_XtReactor::schedule_timer)
  14  *    5. Events from the TCP/IP channel using ACE_Acceptor
  15  *    No command line arguments are needed to run the test.
  16  *    The program needs Motif or lestiff to be compiled and run.
  17  *
  18  *  @author Kirill Rybaltchenko <Kirill.Rybaltchenko@cern.ch>
  19  */
  20 //=============================================================================
  21
  22
  23 #include "test_config.h"
  24
  25 #include "ace/XtReactor/XtReactor.h"
  26 #include "ace/Event_Handler.h"
  27 #include "ace/Acceptor.h"
  28 #include "ace/SOCK_Acceptor.h"
  29 #include "ace/SOCK_Connector.h"
  30 #include "ace/Service_Config.h"
  31 #include "ace/Thread_Manager.h"
  32
  33 #include "ace/OS_NS_unistd.h"
  34
  35 #include /**/ <X11/Intrinsic.h>
  36 #include /**/ <X11/Xatom.h>
  37 #include /**/ <X11/Shell.h>
  38
  39 #include /**/ <Xm/Xm.h>
  40 #include /**/ <Xm/Label.h>
  41 #include /**/ <Xm/PushB.h>
  42 #include /**/ <Xm/RowColumn.h>
  43
  44 static void set_label(Widget w, const char *p)
  45 {
  46   XtVaSetValues (w,
  47                  XmNlabelString,
  48                  XmStringCreateLocalized( (char*) p),
  49                  static_cast<void *>(0));
  50 }
  51 #define LABEL_WIDGET xmLabelWidgetClass
  52 #define BUTTON_WIDGET xmPushButtonWidgetClass
  53 #define PRESS_ME_CALLBACK XmNactivateCallback
  54 static Widget create_box(Widget parent, const char *name)
  55 {
  56   Arg al[10];
  57   int ac = 0;
  58   XtSetArg (al[ac], XmNnumColumns, 3); ac++;
  59   XtSetArg (al[ac], XmNpacking, XmPACK_COLUMN); ac++;
  60   XtSetArg (al[ac], XmNentryAlignment, XmALIGNMENT_CENTER); ac++;
  61   return XmCreateRowColumn (parent, (char *) name, al, ac);
  62 }
  63
  64 // Port we listen on.
  65 static const u_short SERV_TCP_PORT = 6670;
  66
  67 // counter for events from "Press Me" button.
  68 static int count1 = 0;
  69
  70 // counter for events from X Timer.
  71 static int count2 = 0;
  72
  73 // counter for events from ACE Timer.
  74 static int count3 = 0;
  75
  76 // Callback for "Stop Test" buton - quit the program.
  77 void
  78 Quit (Widget, XtPointer, XtPointer)
  79 {
  80   ACE_OS::exit (0);
  81 }
  82
  83 static void *
  84 client (void *)
  85 {
  86   char buf[100];
  87   size_t mes_len;
  88   ACE_OS::sleep (1);
  89
  90   ACE_DEBUG ((LM_DEBUG,
  91               " (%P) Client: Starting...\n"));
  92
  93   ACE_SOCK_Stream stream;
  94   ACE_SOCK_Connector connector;
  95   ACE_OS::snprintf (buf, 100, "Client: the life was good!");
  96
  97   mes_len = (int) htonl (ACE_OS::strlen (buf) + 1);
  98
  99   if (connector.connect (stream,
 100                          ACE_INET_Addr (SERV_TCP_PORT,
 101                                         ACE_DEFAULT_SERVER_HOST)) == -1)
 102     ACE_ERROR ((LM_ERROR,
 103                 "(%P) %p\n",
 104                 "Socket open"));
 105
 106   if (stream.send (4,
 107                    (void *) &mes_len,
 108                    sizeof (size_t),
 109                    (void *)buf,
 110                    ACE_OS::strlen (buf) + 1) == -1)
 111
 112     ACE_ERROR ((LM_ERROR,
 113                 "(%P) %p\n",
 114                 "Socket send"));
 115
 116   if (stream.close () == -1)
 117     ACE_ERROR ((LM_ERROR,
 118                 "(%P) %p\n",
 119                 "Socket close"));
 120
 121   ACE_DEBUG ((LM_DEBUG,
 122               "(%P) Client: Message has been sent, about to exit...\n"));
 123   return 0;
 124 }
 125
 126 // Callback for "Press Me" button.
 127
 128 static void
 129 inc_count (Widget, XtPointer client_data, XtPointer)
 130 {
 131   char new_string[80];
 132
 133   ACE_OS::snprintf (new_string, 80, "Events: [%d] [%d] [%d]",
 134                     count1++, count2, count3);
 135
 136   set_label((Widget) client_data, new_string);
 137 }
 138
 139 // Callback for X Timer.
 140
 141 static void
 142 inc_tmo (void *w, XtIntervalId *)
 143 {
 144   char new_string[80];
 145
 146   if (count2 > 10)
 147     ACE_OS::exit (0);
 148   ACE_OS::snprintf (new_string, 80, "Events: [%d] [%d] [%d]",
 149                     count1, count2++, count3);
 150
 151   set_label((Widget) w, new_string);
 152
 153   (void) XtAppAddTimeOut (XtWidgetToApplicationContext ((Widget) w),
 154                           1000,
 155                           inc_tmo,
 156                           (Widget) w);
 157 }
 158
 159 class EV_handler : public ACE_Event_Handler
 160 {
 161 public:
 162   virtual int handle_timeout (const ACE_Time_Value &,
 163                               const void *arg)
 164   {
 165     char new_string[80];
 166     ACE_OS::snprintf (new_string, 80, "Events: [%d] [%d] [%d]",
 167                       count1, count2, count3++);
 168     set_label((Widget) arg, new_string);
 169     return 0;
 170   }
 171 };
 172
 173 class Connection_Handler : public ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>
 174 {
 175 public:
 176   //FUZZ: disable check_for_lack_ACE_OS
 177   virtual int open (void *)
 178   {
 179   //FUZZ: enable check_for_lack_ACE_OS
 180     char buf[100];
 181     int head;
 182     ssize_t ret = this->peer ().recv_n ((char *) &head,
 183                                         sizeof (int));
 184     if (ret != sizeof (int))
 185       ACE_ERROR_RETURN ((LM_ERROR,
 186                          "(%P) %p\n",
 187                          "read header"),
 188                         -1);
 189
 190     ret = this->peer ().recv_n (buf,
 191                                 (int) ntohl (head));
 192
 193     if (ret != (int) ntohl (head))
 194       ACE_ERROR_RETURN ((LM_ERROR,
 195                          "(%P) %p\n",
 196                          "read message"),
 197                         -1);
 198     ACE_DEBUG ((LM_DEBUG,
 199                 " (%P)Server (ACE_SOCKET channel message): [%s]\n",
 200                 buf));
 201     return 0;
 202   }
 203 };
 204
 205 #if defined (HummingBird_X)
 206 extern "C" void HCLXmInit ();
 207 #endif /* HummingBird_X */
 208
 209 int
 210 run_main (int argc, ACE_TCHAR *argv[])
 211 {
 212   ACE_START_TEST (ACE_TEXT ("XtMotifReactor_Test"));
 213
 214   XtAppContext app_context;
 215   Widget topLevel, goodbye, PressMe, lbl, digits_rc;
 216   Widget children[5];
 217
 218 #if defined (HummingBird_X)
 219   HCLXmInit ();
 220 #endif /* HummingBird_X */
 221   topLevel = XtVaAppInitialize (&app_context,
 222                                 "XTReactor_Test",
 223                                 0,
 224                                 0,
 225                                 &argc,
 226                                 argv,
 227                                 0,
 228                                 static_cast<void *>(0));
 229
 230   digits_rc = create_box(topLevel, "digits_rc");
 231
 232   //"Stop Test" button.
 233   goodbye = XtCreateWidget ( (char *) "goodbye",
 234                              BUTTON_WIDGET,
 235                              digits_rc,
 236                              0,
 237                              0);
 238   set_label(goodbye, "Stop Test");
 239
 240   //"Press Me" button
 241   PressMe = XtCreateWidget ((char *) "PressMe",
 242                             BUTTON_WIDGET,
 243                             digits_rc,
 244                             0,
 245                             0);
 246
 247   //Display for event counter
 248   lbl = XtCreateWidget ((char *) "label_for_event_one",
 249                         LABEL_WIDGET,
 250                         digits_rc,
 251                         0,
 252                         0);
 253   set_label(lbl, "label_for_all_events");
 254   int ac = 0;
 255   children[ac++] = goodbye;
 256   children[ac++] = PressMe;
 257   children[ac++] = lbl;
 258   XtManageChildren (children, ac);
 259   XtManageChild (digits_rc);
 260
 261   //Register callback for "Stop Test" button
 262   XtAddCallback (goodbye, PRESS_ME_CALLBACK, Quit, 0);
 263
 264   //Register callback for "Press Me" button
 265   XtAddCallback (PressMe,
 266                  PRESS_ME_CALLBACK,
 267                  inc_count,
 268                  (XtPointer) lbl);
 269
 270   // Register callback for X Timer
 271   (void) XtAppAddTimeOut (app_context,
 272                           1000,
 273                           inc_tmo,
 274                           (XtPointer) lbl);
 275
 276   XtRealizeWidget (topLevel);
 277
 278   // It will perform X Main Loop
 279   ACE_XtReactor reactor (app_context);
 280
 281   ACE_Reactor r (&reactor);
 282
 283   //Event Handler for ACE Timer.
 284   EV_handler evh;
 285
 286   ACE_Acceptor <Connection_Handler, ACE_SOCK_ACCEPTOR> acceptor;
 287
 288   if (acceptor.open (ACE_INET_Addr ((u_short) SERV_TCP_PORT),
 289                      &r) == -1)
 290     ACE_ERROR_RETURN ((LM_ERROR,
 291                        "%p\n",
 292                        "open"),
 293                       -1);
 294
 295   if (reactor.schedule_timer (&evh,
 296                               (const void *) lbl,
 297                               ACE_Time_Value (2),
 298                               ACE_Time_Value (2))==-1)
 299     ACE_ERROR_RETURN ((LM_ERROR,
 300                        " (%P|%t) can't register with reactor\n"),
 301                       -1);
 302
 303   ACE_Thread_Manager::instance ()->spawn ((ACE_THR_FUNC) client,
 304                                           0,
 305                                           THR_NEW_LWP | THR_DETACHED);
 306
 307   XtAppMainLoop (XtWidgetToApplicationContext (topLevel));
 308
 309   ACE_END_TEST;
 310   return 0;
 311 }
 312