blob: f66080b62cdea8bc6db1c044318c66c8369f3c24 (
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
76
77
78
79
80
81
82
83
84
85
86
87
|
/* -*- C++ -*- */
/*
** $Id$
**
** Example program from The ACE Programmer's Guide, Chapter 8.
** Copyright 2003 Addison-Wesley. All Rights Reserved.
*/
#ifndef __HA_PROACTIVE_STATUS_H
#define __HA_PROACTIVE_STATUS_H
#include "ace/OS_NS_sys_socket.h"
#include "ace/Asynch_IO.h"
#include "ace/Service_Object.h"
// Listing 1 code/ch08
#include "ace/Asynch_IO.h"
#if (defined (ACE_WIN32) && !defined (ACE_HAS_WINCE)) || (defined (ACE_HAS_AIO_CALLS))
class HA_Proactive_Service : public ACE_Service_Handler
{
public:
~HA_Proactive_Service ()
{
if (this->handle () != ACE_INVALID_HANDLE)
ACE_OS::closesocket (this->handle ());
}
virtual void open (ACE_HANDLE h, ACE_Message_Block&);
// This method will be called when an asynchronous read
// completes on a stream.
virtual void handle_read_stream
(const ACE_Asynch_Read_Stream::Result &result);
// This method will be called when an asynchronous write
// completes on a stream.
virtual void handle_write_stream
(const ACE_Asynch_Write_Stream::Result &result);
private:
ACE_Asynch_Read_Stream reader_;
ACE_Asynch_Write_Stream writer_;
};
// Listing 1
// Listing 2 code/ch08
#include "ace/Asynch_Acceptor.h"
#include "ace/INET_Addr.h"
class HA_Proactive_Acceptor :
public ACE_Asynch_Acceptor<HA_Proactive_Service>
{
public:
virtual int validate_connection
(const ACE_Asynch_Accept::Result& result,
const ACE_INET_Addr &remote,
const ACE_INET_Addr &local);
};
// Listing 2
#endif /* (ACE_WIN32 && != ACE_HAS_WINCE) || ACE_HAS_AIO_CALLS*/
#if 0
// Listing 3 code/ch08
template <class HANDLER>
class ACE_Asynch_Acceptor : public ACE_Handler
...
protected:
virtual HANDLER *make_handler (void)
{
return new HANDLER;
}
// Listing 3
#endif
class HA_Proactive_Status : public ACE_Service_Object
{
public:
// Initializes object when dynamic linking occurs.
virtual int init (int argc, ACE_TCHAR *argv[]);
// Terminates object when dynamic unlinking occurs.
virtual int fini (void);
};
#endif /* __HA_PROACTIVE_STATUS_H */
|
