diff options
Diffstat (limited to 'examples/ASX/Message_Queue/priority_buffer.cpp')
| -rw-r--r-- | examples/ASX/Message_Queue/priority_buffer.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/examples/ASX/Message_Queue/priority_buffer.cpp b/examples/ASX/Message_Queue/priority_buffer.cpp index 26603c7dc64..db60a33bcae 100644 --- a/examples/ASX/Message_Queue/priority_buffer.cpp +++ b/examples/ASX/Message_Queue/priority_buffer.cpp @@ -67,7 +67,7 @@ producer (ACE_Message_Queue<ACE_MT_SYNCH> *msg_queue) { ACE_Read_Buffer rb (ACE_STDIN); - // Keep reading stdin, until we reach EOF. + // Keep reading stdin, until we reach EOF. for (;;) { @@ -102,7 +102,7 @@ producer (ACE_Message_Queue<ACE_MT_SYNCH> *msg_queue) mb->wr_ptr (rb.size ()); ACE_DEBUG ((LM_DEBUG, - "enqueueing message of size %d\n", + "enqueueing message of size %d\n", mb->msg_priority ())); // Enqueue in priority order. @@ -115,14 +115,14 @@ producer (ACE_Message_Queue<ACE_MT_SYNCH> *msg_queue) // the size of the lines!). consumer (msg_queue); - return 0; + return 0; } // Spawn off one thread that copies stdin to stdout in order of the // size of each line. -int -main (int, char *[]) +int +ACE_TMAIN (int, ACE_TCHAR *[]) { // Message queue. ACE_Message_Queue<ACE_MT_SYNCH> msg_queue (max_queue); @@ -136,8 +136,8 @@ main (int, char *[]) return 0; } #else -int -main (int, char *[]) +int +ACE_TMAIN (int, ACE_TCHAR *[]) { ACE_ERROR ((LM_ERROR, "threads not supported on this platform\n")); return 0; |