blob: edc502a7a438a8117d1eb360b7f4c634aee60600 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
/* -*- 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 */
|
