summaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorschmidt <douglascraigschmidt@users.noreply.github.com>1998-01-01 20:06:59 +0000
committerschmidt <douglascraigschmidt@users.noreply.github.com>1998-01-01 20:06:59 +0000
commitadb4f8afefdf035f3043342a501607866aa9f503 (patch)
tree951f2fd922ffd86344087fd58a9f00f74b7c6481 /examples
parentb1eae04c2cf146bf65603df555cfd83aefa83897 (diff)
downloadATCD-adb4f8afefdf035f3043342a501607866aa9f503.tar.gz
*** empty log message ***
Diffstat (limited to 'examples')
-rw-r--r--examples/ASX/Event_Server/Transceiver/transceiver.cpp10
-rw-r--r--examples/Reactor/Misc/notification.cpp15
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