blob: 48672ad0feb15fa9d3122a77ff7e1b27fb03e38f (
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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
// -*- C++ -*-
/**
* @file ECG_UDP_EH.h
*
* $Id$
*
* @author Carlos O'Ryan (coryan@cs.wustl.edu)
* @author Marina Spivak (marina@atdesk.com)
*
* http://doc.ece.uci.edu/~coryan/EC/index.html
*/
#ifndef TAO_ECG_UDP_EH_H
#define TAO_ECG_UDP_EH_H
#include /**/ "ace/pre.h"
#include "ace/Event_Handler.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include /**/ "orbsvcs/Event/event_serv_export.h"
#include "orbsvcs/Event/ECG_Adapters.h"
#include "ace/SOCK_Dgram.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_ECG_UDP_Receiver;
/**
* @class TAO_ECG_UDP_EH
*
* @brief Event Handler for UDP messages.
*
* Listens for messages on a UDP socket. When there is a message,
* calls handle_input () on a specified TAO_ECG_Dgram_Handler to
* inform it about message arrival.
*
* NOT THREAD-SAFE.
*/
class TAO_RTEvent_Serv_Export TAO_ECG_UDP_EH :
public ACE_Event_Handler
, public TAO_ECG_Handler_Shutdown
{
public:
/// Initialization and termination methods.
//@{
/// Constructor.
/// Messages received by this EH will be forwarded to the <recv>.
/*
* See comments for <receiver_> data member on why raw pointer is
* used for the <recv> argument.
*/
TAO_ECG_UDP_EH (TAO_ECG_Dgram_Handler *recv);
/// Destructor.
virtual ~TAO_ECG_UDP_EH (void);
/// Open the datagram and register itself with this->reactor().
/// To insure proper resource clean up, if open () is successful,
/// the user MUST call shutdown () when handler is no longer needed
/// (and its reactor still exists).
int open (const ACE_INET_Addr& ipaddr,
int reuse_addr = 0);
/// TAO_ECG_Handler_Shutdown method.
/// Unsubscribe from the reactor and close the datagram.
virtual int shutdown (void);
//@}
/// Main method - reactor callback. Notify <receiver_> that
/// <dgram_> is ready for reading.
virtual int handle_input (ACE_HANDLE fd);
/**
* Obtain the dgram, this is one of those "controlled violations of
* type safety", allowing the user to setup options and gain access
* to low-level features.
*/
ACE_SOCK_Dgram &dgram (void);
private:
/// The datagram used to receive the data.
ACE_SOCK_Dgram dgram_;
/// We callback to this object when a message arrives.
/*
* We can keep a raw pointer to the receiver (even though it may
* be a refcounted object) because receiver guarantees
* to notify us (by calling shutdown ()) before going away.
*
* We have to use raw pointer instead of a refcounting mechanism
* here to avoid a circular refcounting dependency between
* receiver and handler.
*/
TAO_ECG_Dgram_Handler* receiver_;
};
TAO_END_VERSIONED_NAMESPACE_DECL
#if defined(__ACE_INLINE__)
#include "orbsvcs/Event/ECG_UDP_EH.inl"
#endif /* __ACE_INLINE__ */
#include /**/ "ace/post.h"
#endif /* TAO_ECG_UDP_EH_H */
|
