diff options
author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1998-01-01 20:06:59 +0000 |
---|---|---|
committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1998-01-01 20:06:59 +0000 |
commit | adb4f8afefdf035f3043342a501607866aa9f503 (patch) | |
tree | 951f2fd922ffd86344087fd58a9f00f74b7c6481 /examples | |
parent | b1eae04c2cf146bf65603df555cfd83aefa83897 (diff) | |
download | ATCD-adb4f8afefdf035f3043342a501607866aa9f503.tar.gz |
*** empty log message ***
Diffstat (limited to 'examples')
-rw-r--r-- | examples/ASX/Event_Server/Transceiver/transceiver.cpp | 10 | ||||
-rw-r--r-- | examples/Reactor/Misc/notification.cpp | 15 |
2 files changed, 2 insertions, 23 deletions
diff --git a/examples/ASX/Event_Server/Transceiver/transceiver.cpp b/examples/ASX/Event_Server/Transceiver/transceiver.cpp index 0df775fa37d..c7aad1c523c 100644 --- a/examples/ASX/Event_Server/Transceiver/transceiver.cpp +++ b/examples/ASX/Event_Server/Transceiver/transceiver.cpp @@ -120,20 +120,10 @@ Event_Transceiver::Event_Transceiver (void) sig_set.sig_add (SIGINT); sig_set.sig_add (SIGQUIT); -#if !defined (ACE_WIN32) - if (ACE_Reactor::instance ()->register_handler (sig_set, this) == -1) ACE_ERROR ((LM_ERROR, "%p\n", "register_handler")); -#else - - if (ACE_Reactor::instance ()->register_handler - (SIGINT, this) == -1) - ACE_ERROR ((LM_ERROR, "%p\n", "register_handler")); - -#endif /* ACE_WIN32 */ - // We need to register <this> here before we're connected since // otherwise <get_handle> will return the connection socket handle // for the peer. diff --git a/examples/Reactor/Misc/notification.cpp b/examples/Reactor/Misc/notification.cpp index 4aebe1ae7b1..6d0e409c257 100644 --- a/examples/Reactor/Misc/notification.cpp +++ b/examples/Reactor/Misc/notification.cpp @@ -85,28 +85,21 @@ Thread_Handler::Thread_Handler (int delay, size_t n_threads) : iterations_(MAX_ITERATIONS) { - delay_.set (delay); - interval_.set (interval); - -#if !defined(CHORUS) ACE_Sig_Set sig_set; sig_set.sig_add (SIGQUIT); sig_set.sig_add (SIGINT); -#endif /* CHORUS */ + delay_.set (delay); + interval_.set (interval); this->id_ = 0; if (ACE::register_stdin_handler (this, ACE_Reactor::instance (), ACE_Thread_Manager::instance ()) == -1) ACE_ERROR ((LM_ERROR, "%p\n", "register_stdin_handler")); - -#if !defined (CHORUS) else if (ACE_Reactor::instance ()->register_handler (sig_set, this) == -1) ACE_ERROR ((LM_ERROR, "(%t) %p\n", "register_handler")); -#endif /* CHORUS */ - else if (ACE_Reactor::instance ()->schedule_timer (this, 0, Thread_Handler::delay_, Thread_Handler::interval_) == -1) ACE_ERROR ((LM_ERROR, "(%t) %p\n", "schedule_timer")); @@ -114,9 +107,7 @@ Thread_Handler::Thread_Handler (int delay, // Set up this thread's signal mask, which is inherited by the // threads it spawns. -#if !defined (CHORUS) ACE_Thread::sigsetmask (SIG_BLOCK, sig_set); -#endif /* CHORUS */ // Create N new threads of control Thread_Handlers. @@ -127,9 +118,7 @@ Thread_Handler::Thread_Handler (int delay, ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Thread::spawn")); // Unblock signal set so that only this thread receives them! -#if !defined (CHORUS) ACE_Thread::sigsetmask (SIG_UNBLOCK, sig_set); -#endif /* CHORUS */ } int |