summaryrefslogtreecommitdiff
path: root/examples/System_V_IPC/SV_Message_Queues/MQ_Server.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/System_V_IPC/SV_Message_Queues/MQ_Server.cpp')
-rw-r--r--examples/System_V_IPC/SV_Message_Queues/MQ_Server.cpp52
1 files changed, 0 insertions, 52 deletions
diff --git a/examples/System_V_IPC/SV_Message_Queues/MQ_Server.cpp b/examples/System_V_IPC/SV_Message_Queues/MQ_Server.cpp
deleted file mode 100644
index ee5f39f7efb..00000000000
--- a/examples/System_V_IPC/SV_Message_Queues/MQ_Server.cpp
+++ /dev/null
@@ -1,52 +0,0 @@
-// $Id$
-
-#include "ace/Signal.h"
-#include "ace/SV_Message_Queue.h"
-#include "test.h"
-
-// Must be global for signal Message...
-static ACE_SV_Message_Queue msgque (SRV_KEY, ACE_SV_Message_Queue::ACE_CREATE);
-
-extern "C" void
-handler (int)
-{
- if (msgque.remove () < 0)
- ACE_OS::perror ("msgque.close"), ACE_OS::exit (1);
- ACE_OS::exit (0);
-}
-
-int
-main (void)
-{
- long pid = long (ACE_OS::getpid ());
- ACE_Message_Block recv_msg (SRV_ID);
- ACE_Message_Block send_msg (0, pid, ACE_OS::cuserid (0),
- "I received your message.");
-
- // Register a signal handler.
- ACE_Sig_Action sa ((ACE_SignalHandler) handler, SIGINT);
-
- for (;;)
- {
- if (msgque.recv (recv_msg, sizeof (Message_Data), recv_msg.type ()) == -1)
- ::perror ("msgque.recv"), ACE_OS::exit (1);
-
- cout << "a msg of length "
- << recv_msg.length ()
- << " sent from client "
- << recv_msg.pid ()
- << " (user "
- << recv_msg.user () << "): "
- << recv_msg.text () << "\n";
- cout.flush ();
-
- send_msg.type (recv_msg.pid ());
-
- if (msgque.send (send_msg, send_msg.length ()) < 0)
- ACE_OS::perror ("msgque.send"), ACE_OS::exit (1);
- }
-
- /* NOTREACHED */
- return 0;
-}
-