summaryrefslogtreecommitdiff
path: root/examples/IPC_SAP/SPIPE_SAP/server.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/IPC_SAP/SPIPE_SAP/server.cpp')
-rw-r--r--examples/IPC_SAP/SPIPE_SAP/server.cpp116
1 files changed, 0 insertions, 116 deletions
diff --git a/examples/IPC_SAP/SPIPE_SAP/server.cpp b/examples/IPC_SAP/SPIPE_SAP/server.cpp
deleted file mode 100644
index 2d46a882f8a..00000000000
--- a/examples/IPC_SAP/SPIPE_SAP/server.cpp
+++ /dev/null
@@ -1,116 +0,0 @@
-#include "ace/SPIPE_Addr.h"
-// $Id$
-
-#include "ace/SPIPE_Acceptor.h"
-#include "shared.h"
-
-#if defined (ACE_HAS_STREAM_PIPES)
-
-/* Maximum per-process open I/O descriptors */
-const int MAX_FDS = 200;
-const int PERMS = 0666;
-
-int
-main (int argc, char *argv[])
-{
- ACE_SPIPE_Acceptor peer_acceptor;
- ACE_SPIPE_Stream new_stream;
- int s_handle;
- struct pollfd poll_array[MAX_FDS];
-
- if (argc > 1)
- rendezvous = argv[1];
-
- ACE_OS::fdetach (rendezvous);
-
- ACE_SPIPE_Addr addr (rendezvous);
-
- if ((s_handle = peer_acceptor.open (addr)) == -1)
- ACE_OS::perror ("peer_acceptor.open"), ACE_OS::exit (1);
-
- for (int fd = 0; fd < MAX_FDS; fd++)
- {
- poll_array[fd].fd = -1;
- poll_array[fd].events = POLLIN;
- }
-
- poll_array[0].fd = s_handle;
-
- for (int width = 1;;)
- {
- // Block waiting for client I/O events (handle interrupts).
- while (ACE_OS::poll (poll_array, width) == -1 && errno == EINTR)
- continue;
-
- /* Handle pending logging messages first (s_handle + 1
- is guaranteed to be lowest client descriptor) */
-
- for (int fd = s_handle + 1; fd < width; fd++)
- if ((poll_array[fd].revents & POLLIN)
- || (poll_array[fd].revents & POLLHUP))
- {
- char buf[BUFSIZ];
- int n;
-
- /* recv will not block in this case! */
- if ((n = ACE_OS::read (fd, buf, sizeof buf)) == -1)
- ACE_OS::perror ("read failed");
- else if (n == 0)
- {
- /* Handle client connection shutdown */
- if (ACE_OS::close (poll_array[fd].fd) == -1)
- ACE_OS::perror ("close");
- poll_array[fd].fd = -1;
-
- if (fd + 1 == width)
- {
- while (poll_array[fd].fd == -1)
- fd--;
- width = fd + 1;
- }
- }
- else
- {
- ::printf ("%*s\n", n, buf);
- fflush (stdout);
- }
- }
-
- if (poll_array[0].revents & POLLIN)
- {
- int arg;
- int n_handle;
- ACE_SPIPE_Addr client;
-
- if (peer_acceptor.accept (new_stream) == -1)
- ACE_OS::perror ("local_accept");
-
- n_handle = new_stream.get_handle ();
-
- if (new_stream.get_remote_addr (client) == -1)
- ACE_OS::perror ("get_remote_addr");
-
- ACE_OS::printf ("n_handle = %d, uid = %d, gid = %d\n",
- n_handle, client.user_id (), client.group_id ());
-
- arg = RMSGN | RPROTDAT;
-
- if (ACE_OS::ioctl (n_handle, I_SRDOPT, (void *) arg) == -1)
- ACE_OS::perror ("I_RRDOPT");
-
- poll_array[n_handle].fd = n_handle;
- if (n_handle >= width)
- width = n_handle + 1;
- }
- }
-
- return 0;
-}
-#else
-#include <stdio.h>
-int main (void)
-{
- ACE_OS::fprintf (stderr, "This feature is not supported\n");
- return 0;
-}
-#endif /* ACE_HAS_STREAM_PIPES */