diff options
author | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-08-23 02:24:45 +0000 |
---|---|---|
committer | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-08-23 02:24:45 +0000 |
commit | 6aa7bdfafd1c79b6483bfba8542bf129d584f326 (patch) | |
tree | 972d9936ad2c54e7623942a11f2e4e940dd96fb5 /examples/IPC_SAP | |
parent | d09cf84888b967791f20b6e7c65188ae6a15381c (diff) | |
download | ATCD-6aa7bdfafd1c79b6483bfba8542bf129d584f326.tar.gz |
untabified
Diffstat (limited to 'examples/IPC_SAP')
-rw-r--r-- | examples/IPC_SAP/UPIPE_SAP/ex2.cpp | 15 | ||||
-rw-r--r-- | examples/IPC_SAP/UPIPE_SAP/ex3.cpp | 14 |
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 (); |