diff options
Diffstat (limited to 'ACE/examples/IPC_SAP/FIFO_SAP/FIFO-Msg-client.cpp')
-rw-r--r-- | ACE/examples/IPC_SAP/FIFO_SAP/FIFO-Msg-client.cpp | 43 |
1 files changed, 43 insertions, 0 deletions
diff --git a/ACE/examples/IPC_SAP/FIFO_SAP/FIFO-Msg-client.cpp b/ACE/examples/IPC_SAP/FIFO_SAP/FIFO-Msg-client.cpp new file mode 100644 index 00000000000..3f267ba66ce --- /dev/null +++ b/ACE/examples/IPC_SAP/FIFO_SAP/FIFO-Msg-client.cpp @@ -0,0 +1,43 @@ +// $Id$ + +#include "ace/FIFO_Send_Msg.h" +#include "ace/OS_NS_stdio.h" +#include "ace/OS_main.h" +#include "ace/OS_NS_stdlib.h" +#include "ace/OS_NS_time.h" +#include "ace/OS_NS_string.h" + +ACE_RCSID(FIFO_SAP, FIFO_Msg_client, "$Id$") + +#if defined (ACE_HAS_STREAM_PIPES) + +int +ACE_TMAIN (int, ACE_TCHAR *[]) +{ + ACE_FIFO_Send_Msg client (ACE_DEFAULT_RENDEZVOUS); + + char buf[BUFSIZ]; + ACE_Str_Buf msg (buf); + + ACE_OS::srand (unsigned (ACE_OS::time (0))); + + while (ACE_OS::fgets (buf, sizeof buf, stdin) != 0) + { + msg.len = ACE_OS::strlen (buf) + 1; + if (client.send (ACE_OS::rand () % 11, &msg) == -1) + ::perror ("send"); + } + + if (client.close () == -1) + ACE_OS::perror ("close"), ACE_OS::exit (1); + + return 0; +} +#else +#include "ace/os_include/os_stdio.h" +int ACE_TMAIN (int, ACE_TCHAR *[]) +{ + ACE_OS::fprintf (stderr, "This feature is not supported\n"); + return 0; +} +#endif /* ACE_HAS_STREAM_PIPES */ |