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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
// -*- C++ -*-
//
// $Id$
#include "ace/SPIPE_Stream.h"
#if defined (ACE_HAS_STREAM_PIPES)
#include "ace/Reactor.h"
#include "ace/Get_Opt.h"
#include "ace/OS_NS_stdio.h"
#include "ace/OS_NS_unistd.h"
#include "ace/OS_NS_string.h"
ACE_INLINE
Handle_L_SPIPE::Handle_L_SPIPE (void)
{
}
ACE_INLINE int
Handle_L_SPIPE::open (const ACE_SPIPE_Addr &rendezvous_spipe)
{
if (this->ACE_SPIPE_Acceptor::open (rendezvous_spipe) == -1)
return -1;
else
return 0;
}
ACE_INLINE int
Handle_L_SPIPE::info (ACE_TCHAR **strp, size_t length) const
{
ACE_TCHAR buf[BUFSIZ];
ACE_SPIPE_Addr sa;
if (ACE_SPIPE_Acceptor::get_local_addr (sa) == -1)
return -1;
ACE_OS::strcpy (buf, sa.get_path_name ());
ACE_OS::strcat (buf, ACE_TEXT (" # tests local STREAM pipe\n"));
if (*strp == 0 && (*strp = ACE_OS::strdup (buf)) == 0)
return -1;
else
ACE_OS::strncpy (*strp, buf, length);
return ACE_OS::strlen (buf);
}
ACE_INLINE int
Handle_L_SPIPE::init (int argc, ACE_TCHAR *argv[])
{
ACE_SPIPE_Addr susp;
const char *rendezvous = Handle_L_SPIPE::DEFAULT_RENDEZVOUS;
ACE_Get_Arg_Opt<char> get_opt (argc, argv, "r:", 0);
for (int c; (c = get_opt ()) != -1; )
switch (c)
{
case 'r':
rendezvous = get_opt.opt_arg ();
break;
default:
break;
}
ACE_OS::unlink (rendezvous);
susp.set (rendezvous);
if (this->open (susp) == -1)
ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1);
else if (ACE_Reactor::instance ()->register_handler
(this, ACE_Event_Handler::ACCEPT_MASK) == -1)
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT ("%p\n"),
ACE_TEXT ("registering service with ACE_Reactor")),
-1);
return 0;
}
ACE_INLINE int
Handle_L_SPIPE::fini (void)
{
return ACE_Reactor::instance ()->remove_handler
(this, ACE_Event_Handler::ACCEPT_MASK);
}
ACE_INLINE int
Handle_L_SPIPE::get_handle (void) const
{
return ACE_SPIPE::get_handle();
}
ACE_INLINE int
Handle_L_SPIPE::handle_input (int)
{
ACE_SPIPE_Stream new_spipe;
char buf[PIPE_BUF];
ACE_Str_Buf msg (buf, 0, sizeof buf);
int flags = 0;
/* Accept communication requests */
if (this->ACE_SPIPE_Acceptor::accept (new_spipe) == -1)
return -1;
else
{
ACE_SPIPE_Addr sa;
new_spipe.get_remote_addr (sa);
ACE_DEBUG ((LM_INFO,
ACE_TEXT ("accepted request from %s (gid = %d, uid = %d)\n"),
sa.get_path_name (), sa.group_id (), sa.user_id ()));
}
while (new_spipe.recv ((ACE_Str_Buf *) 0, &msg, &flags) >= 0)
if (msg.len != 0)
ACE_OS::write (ACE_STDOUT, (const char *) msg.buf, (int) msg.len);
else
break;
if (new_spipe.close () == -1)
return -1;
return 0;
}
ACE_INLINE int
Handle_L_SPIPE::handle_close (int, ACE_Reactor_Mask)
{
return this->ACE_SPIPE_Acceptor::remove ();
}
#endif /* ACE_HAS_STREAM_PIPES */
|
