// $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;
}