summaryrefslogtreecommitdiff
path: root/examples/ASX
diff options
context:
space:
mode:
authorlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1998-12-19 05:15:32 +0000
committerlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1998-12-19 05:15:32 +0000
commitd027b42e6e9d8849a99f347a7f5525fc4b69a02b (patch)
treeaaefa20387f8c937f888c93efa577782d7a9f8a7 /examples/ASX
parentdab2b9e10f31df4c75ba7b4a2ea463455860c6ee (diff)
downloadATCD-d027b42e6e9d8849a99f347a7f5525fc4b69a02b.tar.gz
(handle_signal): added ACE_UNUSED_ARG (signum).
Diffstat (limited to 'examples/ASX')
-rw-r--r--examples/ASX/Event_Server/Transceiver/transceiver.cpp52
1 files changed, 27 insertions, 25 deletions
diff --git a/examples/ASX/Event_Server/Transceiver/transceiver.cpp b/examples/ASX/Event_Server/Transceiver/transceiver.cpp
index abbd1b410a8..9076713c187 100644
--- a/examples/ASX/Event_Server/Transceiver/transceiver.cpp
+++ b/examples/ASX/Event_Server/Transceiver/transceiver.cpp
@@ -76,23 +76,23 @@ Event_Transceiver::parse_args (int argc, char *argv[])
switch (c)
{
case 'C':
- this->role_ = "Consumer";
- break;
+ this->role_ = "Consumer";
+ break;
case 'h':
- this->host_name_ = get_opt.optarg;
- break;
+ this->host_name_ = get_opt.optarg;
+ break;
case 'p':
- this->port_number_ = ACE_OS::atoi (get_opt.optarg);
- break;
+ this->port_number_ = ACE_OS::atoi (get_opt.optarg);
+ break;
case 'S':
- this->role_ = "Supplier";
- break;
+ this->role_ = "Supplier";
+ break;
default:
- ACE_ERROR_RETURN ((LM_ERROR,
+ ACE_ERROR_RETURN ((LM_ERROR,
"usage: %n [-CS] [-h host_name] [-p portnum] \n"),
-1);
- /* NOTREACHED */
- break;
+ /* NOTREACHED */
+ break;
}
// Increment by 1 if we're the supplier to mirror the default
@@ -108,7 +108,7 @@ Event_Transceiver::parse_args (int argc, char *argv[])
int
Event_Transceiver::handle_close (ACE_HANDLE,
- ACE_Reactor_Mask)
+ ACE_Reactor_Mask)
{
ACE_Reactor::end_event_loop ();
return 0;
@@ -118,9 +118,11 @@ Event_Transceiver::handle_close (ACE_HANDLE,
int
Event_Transceiver::handle_signal (int signum,
- siginfo_t *,
- ucontext_t *)
+ siginfo_t *,
+ ucontext_t *)
{
+ ACE_UNUSED_ARG (signum);
+
ACE_Reactor::end_event_loop ();
return 0;
}
@@ -154,8 +156,8 @@ Event_Transceiver::Event_Transceiver (int argc, char *argv[])
// otherwise <get_handle> will return the connection socket
// handle for the peer.
else if (ACE_Event_Handler::register_stdin_handler (this,
- ACE_Reactor::instance (),
- ACE_Thread_Manager::instance ()) == -1)
+ ACE_Reactor::instance (),
+ ACE_Thread_Manager::instance ()) == -1)
ACE_ERROR ((LM_ERROR,
"%p\n",
"register_stdin_handler"));
@@ -188,9 +190,9 @@ Event_Transceiver::open (void *)
(this,
ACE_Event_Handler::READ_MASK) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "register_handler"),
- -1);
+ "%p\n",
+ "register_handler"),
+ -1);
return 0;
}
@@ -209,7 +211,7 @@ Event_Transceiver::transmitter (void)
{
ACE_DEBUG ((LM_DEBUG,
"(%P|%t) entering %s transmitter\n",
- this->role_));
+ this->role_));
char buf[BUFSIZ];
ssize_t n = ACE_OS::read (ACE_STDIN, buf, sizeof buf);
@@ -220,7 +222,7 @@ Event_Transceiver::transmitter (void)
ACE_DEBUG ((LM_DEBUG,
"(%P|%t) leaving %s transmitter\n",
- this->role_));
+ this->role_));
return result;
}
@@ -229,20 +231,20 @@ Event_Transceiver::receiver (void)
{
ACE_DEBUG ((LM_DEBUG,
"(%P|%t) entering %s receiver\n",
- this->role_));
+ this->role_));
char buf[BUFSIZ];
ssize_t n = this->peer ().recv (buf, sizeof buf);
int result = 0;
- if (n <= 0
+ if (n <= 0
|| ACE_OS::write (ACE_STDOUT, buf, n) != n)
result = -1;
ACE_DEBUG ((LM_DEBUG,
"(%P|%t) leaving %s receiver\n",
- this->role_));
+ this->role_));
return result;
}
@@ -252,7 +254,7 @@ main (int argc, char *argv[])
if (ACE_Service_Config::open (argv[0]) == -1
&& errno != ENOENT)
ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
+ "%p\n",
"open"),
-1);