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
|
// $Id: Handle_L_Pipe.cpp 91670 2010-09-08 18:02:26Z johnnyw $
#include "Handle_L_Pipe.h"
#include "ace/OS_NS_ctype.h"
#include "ace/OS_NS_unistd.h"
#if !defined (ACE_LACKS_UNIX_DOMAIN_SOCKETS)
// Uppercase N bytes of S.
char *
Handle_L_Pipe::upper_case (char s[], int n)
{
while (--n >= 0)
if (ACE_OS::ace_islower (s[n]))
s[n] = ACE_OS::ace_toupper (s[n]);
return s;
}
int
Handle_L_Pipe::handle_input (ACE_HANDLE)
{
ACE_LSOCK_Stream new_local_stream;
int n;
ACE_HANDLE fd1 = ACE_INVALID_HANDLE;
ACE_HANDLE fd2 = ACE_INVALID_HANDLE;
char buf[BUFSIZ];
if (this->accept (new_local_stream) == -1)
return -1;
if (new_local_stream.recv_handle (fd1) == -1
|| new_local_stream.recv_handle (fd2) == -1)
return -1;
else
ACE_DEBUG ((LM_INFO,
ACE_TEXT ("received file descriptors %d and %d\n"),
fd1,
fd2));
if ((n = ACE_OS::read (fd1, buf, sizeof buf)) == -1)
return -1;
else if (ACE_OS::write (fd2, this->upper_case (buf, n), n) == -1)
return -1;
if (ACE_OS::close (fd1) == -1
|| ACE_OS::close (fd2) == -1)
return -1;
if (new_local_stream.close () == -1)
return -1;
return 0;
}
const ACE_TCHAR *Handle_L_Pipe::DEFAULT_RENDEZVOUS = ACE_TEXT ("/tmp/foo_pipe");
#if !defined (__ACE_INLINE__)
#include "Handle_L_Pipe.inl"
#endif /* __ACE_INLINE__ */
Handle_L_Pipe local_pipe;
ACE_Service_Object_Type lp (&local_pipe, ACE_TEXT ("Local_Pipe"));
#endif /* ACE_LACKS_UNIX_DOMAIN_SOCKETS */
|
