summaryrefslogtreecommitdiff
path: root/examples/Connection/misc/test_upipe.h
diff options
context:
space:
mode:
Diffstat (limited to 'examples/Connection/misc/test_upipe.h')
-rw-r--r--examples/Connection/misc/test_upipe.h75
1 files changed, 0 insertions, 75 deletions
diff --git a/examples/Connection/misc/test_upipe.h b/examples/Connection/misc/test_upipe.h
deleted file mode 100644
index edc502a7a43..00000000000
--- a/examples/Connection/misc/test_upipe.h
+++ /dev/null
@@ -1,75 +0,0 @@
-/* -*- C++ -*- */
-
-// $Id$
-
-#ifndef ACE_TEST_UPIPE_H
-#define ACE_TEST_UPIPE_H
-
-#include "ace/Svc_Handler.h"
-#include "ace/Synch.h"
-#include "ace/UPIPE_Stream.h"
-
-typedef ACE_Svc_Handler <ACE_UPIPE_STREAM, ACE_NULL_SYNCH> SVC_HANDLER;
-
-class Server_Service : public SVC_HANDLER
- // = TITLE
- // Defines the interface for a service that recvs data from its
- // client and writes the data to its stdout.
-{
-public:
- Server_Service (ACE_Thread_Manager * = 0) {}
-
- virtual int open (void *)
- {
- ACE_TRACE ("Server_Service::open");
- return 0;
- }
-
- virtual int svc (void)
- {
- ACE_TRACE ("Server_Service::svc");
-
- char buf[BUFSIZ];
- ssize_t n;
-
- while ((n = this->peer ().recv (buf, sizeof buf)) > 0)
- ::write (1, buf, n);
-
- return 0;
- }
-};
-
-
-class Client_Service : public SVC_HANDLER
- // = TITLE
- // Defines the interface for a service that recvs data from its
- // stdin and forward the data to its server.
-{
-public:
- Client_Service (ACE_Thread_Manager *thr_mgr = 0)
- : SVC_HANDLER (thr_mgr)
- {
- ACE_TRACE ("Client_Service::Client_Service");
- }
-
- virtual int open (void *)
- {
- ACE_TRACE ("Client_Service::open");
- return this->activate (THR_DETACHED | THR_NEW_LWP);
- }
-
- virtual int svc (void)
- {
- ACE_TRACE ("Client_Service::svc");
- char buf[BUFSIZ];
- ssize_t n;
-
- while ((n = ACE_OS::read (ACE_STDIN, buf, sizeof buf)) > 0)
- this->peer ().send (buf, n);
-
- this->peer ().close ();
- return 0;
- }
-};
-
-#endif /* ACE_TEST_UPIPE_H */