// notifier.cpp,v 1.8 1999/06/30 01:58:02 coryan Exp

#include "Notifier_Server.h"
#include "notifier.h"
ACE_RCSID(Notifier, notifier, "notifier.cpp,v 1.8 1999/06/30 01:58:02 coryan Exp")


int
Notifier::handle_signal (int signum, siginfo_t *, ucontext_t *)
{
  ACE_DEBUG ((LM_DEBUG,
              "%S\n",
              signum));

   // Tell the <Notifier_Server> to shut down the ORB.
  ns_.close ();
  return 0;
}

void
Notifier::run (void)
{
  ACE_TRY_NEW_ENV
    {
      ns_.run (ACE_TRY_ENV);
      ACE_TRY_CHECK;
    }
  ACE_CATCH (CORBA::SystemException, sysex)
    {
      ACE_PRINT_EXCEPTION (sysex, "Notifier System Exception");
    }
  ACE_CATCH (CORBA::UserException, userex)
    {
      ACE_PRINT_EXCEPTION (userex, "Notifier User Exception");
    }
  ACE_CATCHANY
  {
  }
  ACE_ENDTRY;
}

Notifier::Notifier (int argc, char *argv[])
{
  ACE_TRY_NEW_ENV
    {
      ns_.init (argc, argv, ACE_TRY_ENV);
      ACE_TRY_CHECK;
    }
  ACE_CATCHANY
    {
      ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
                           "Notifier_Server.init failed\n ");
    }
  ACE_ENDTRY;

  // Register with the ORB's Reactor to receive a signal to shut us
  // down.
  if (ns_.reactor ()->register_handler (SIGINT, this) == -1)
    ACE_ERROR ((LM_ERROR,
                "%p\n",
                "register_handler"));
}

Notifier::~Notifier (void)
{
  ACE_DEBUG ((LM_DEBUG,"Notifier::~Notifier\n"));

  // Cleanup.
  this->ns_.close ();
}

int
main (int argc, char *argv[])
{
  // Initialize server daemon.
  Notifier notifier (argc, argv);

  // Loop forever handling events.
  notifier.run ();

  return 0;
}
