summaryrefslogtreecommitdiff
path: root/examples/IPC_SAP
diff options
context:
space:
mode:
authorlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1998-08-23 02:24:45 +0000
committerlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1998-08-23 02:24:45 +0000
commit6aa7bdfafd1c79b6483bfba8542bf129d584f326 (patch)
tree972d9936ad2c54e7623942a11f2e4e940dd96fb5 /examples/IPC_SAP
parentd09cf84888b967791f20b6e7c65188ae6a15381c (diff)
downloadATCD-6aa7bdfafd1c79b6483bfba8542bf129d584f326.tar.gz
untabified
Diffstat (limited to 'examples/IPC_SAP')
-rw-r--r--examples/IPC_SAP/UPIPE_SAP/ex2.cpp15
-rw-r--r--examples/IPC_SAP/UPIPE_SAP/ex3.cpp14
2 files changed, 14 insertions, 15 deletions
diff --git a/examples/IPC_SAP/UPIPE_SAP/ex2.cpp b/examples/IPC_SAP/UPIPE_SAP/ex2.cpp
index a2c0c5fbc4d..636ef382e05 100644
--- a/examples/IPC_SAP/UPIPE_SAP/ex2.cpp
+++ b/examples/IPC_SAP/UPIPE_SAP/ex2.cpp
@@ -10,7 +10,7 @@
//
// = DESCRIPTION
// Example for using <ACE_UPIPE_SAP> and <ACE_Thread> for
-// intra-process communication.
+// intra-process communication.
//
// = AUTHOR
// Gerhard Lenzer and Douglas C. Schmidt
@@ -50,7 +50,7 @@ supplier (void *)
if (con.connect (s_stream, c_addr) == -1)
ACE_ERROR ((LM_ERROR,
"(%t) %p\n",
- "ACE_UPIPE_Acceptor.connect failed"));
+ "ACE_UPIPE_Acceptor.connect failed"));
// Test asynchronicity (the "acausal principle" ;-)).
s_stream.enable (ACE_SIGIO);
@@ -104,7 +104,7 @@ consumer (void *)
ACE_UPIPE_Addr serv_addr ("pattern");
// accept will wait up to 4 seconds
- ACE_UPIPE_Acceptor acc (serv_addr);
+ ACE_UPIPE_Acceptor acc (serv_addr);
ACE_DEBUG ((LM_DEBUG,
"(%t) consumer spawning the supplier thread\n"));
@@ -124,7 +124,7 @@ consumer (void *)
if (acc.accept (c_stream) == -1)
ACE_ERROR ((LM_ERROR,
"(%t) %p\n",
- "ACE_UPIPE_Acceptor.accept failed"));
+ "ACE_UPIPE_Acceptor.accept failed"));
// Time measurement.
time_t currsec;
@@ -142,9 +142,9 @@ consumer (void *)
time_t secs = (time_t) currsec - start;
ACE_DEBUG ((LM_DEBUG,
- "(%t) Transferred %d blocks of size %d\n"
- "The program ran %d seconds\n",
- received_messages, size, secs));
+ "(%t) Transferred %d blocks of size %d\n"
+ "The program ran %d seconds\n",
+ received_messages, size, secs));
c_stream.close ();
return 0;
}
@@ -182,4 +182,3 @@ template class ACE_Auto_Basic_Ptr <char>;
#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
#pragma instantiate ACE_Auto_Basic_Ptr <char>
#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
-
diff --git a/examples/IPC_SAP/UPIPE_SAP/ex3.cpp b/examples/IPC_SAP/UPIPE_SAP/ex3.cpp
index eb0a63b1f69..f9806da03e7 100644
--- a/examples/IPC_SAP/UPIPE_SAP/ex3.cpp
+++ b/examples/IPC_SAP/UPIPE_SAP/ex3.cpp
@@ -9,7 +9,7 @@
// ex3.cpp
//
// = DESCRIPTION
-// Example for using <ACE_UPIPE_SAP> and <ACE_Thread> for intra-process
+// Example for using <ACE_UPIPE_SAP> and <ACE_Thread> for intra-process
// communication. This example uses char buffers as input/output
// interface to the <ACE_UPIPE_Stream>.
//
@@ -45,7 +45,7 @@ supplier (void *)
if (con.connect (s_stream, c_addr) == -1)
ACE_ERROR ((LM_ERROR,
"(%t) %p\n",
- "ACE_UPIPE_Acceptor.connect failed"));
+ "ACE_UPIPE_Acceptor.connect failed"));
ACE_Auto_Basic_Ptr <char> mybuf = new char[size];
@@ -93,7 +93,7 @@ consumer (void *)
if (acc.accept (c_stream) == -1)
ACE_ERROR ((LM_ERROR, "(%t) %p\n",
- "ACE_UPIPE_Acceptor.accept failed"));
+ "ACE_UPIPE_Acceptor.accept failed"));
// Ensure deletion upon exit.
ACE_Auto_Basic_Ptr <char> mybuf = new char[size];
@@ -109,7 +109,7 @@ consumer (void *)
{
result = c_stream.recv (mybuf, size);
if (result <= 0)
- break;
+ break;
}
if (result == -1)
@@ -120,9 +120,9 @@ consumer (void *)
time_t secs = (time_t) currsec - start;
ACE_DEBUG ((LM_DEBUG,
- "(%t) Transferred %d blocks of size %d\n"
- "The program ran %d seconds\n",
- blocks,
+ "(%t) Transferred %d blocks of size %d\n"
+ "The program ran %d seconds\n",
+ blocks,
size,
secs));
c_stream.close ();