blob: e860731f0ad17d0c3eccef9a5462526d256d5518 (
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
|
#ifndef TIMESTAMP_H
#define TIMESTAMP_H
#include /**/ "ace/pre.h"
#include "orbsvcs/orbsvcs/AV/Protocol_Factory.h"
#include "ace/Dynamic_Service.h"
#include "export.h"
// $Id$
class TAO_TS_Export TimeStamp_Protocol_Object : public TAO_AV_Protocol_Object
{
public:
TimeStamp_Protocol_Object (TAO_AV_Callback *callback,
TAO_AV_Transport *transport);
virtual int handle_input (void);
/// send a data frame.
virtual int send_frame (ACE_Message_Block *frame,
TAO_AV_frame_info *frame_info = 0);
virtual int send_frame (iovec const* iov,
int iovcnt,
TAO_AV_frame_info *frame_info = 0);
virtual int send_frame (const char*buf,
size_t len);
/// end the stream.
virtual int destroy (void);
private:
/// Pre-allocated memory to receive the data...
ACE_Message_Block* frame_;
};
class TAO_TS_Export TimeStamp_Protocol_Factory : public TAO_AV_Flow_Protocol_Factory
{
public:
/// Initialization hook.
TimeStamp_Protocol_Factory (void);
virtual ~TimeStamp_Protocol_Factory (void);
virtual int init (int argc, char *argv[]);
virtual int match_protocol (const char *flow_string);
// Note : Some platforms still don't support Covariant returns
virtual TAO_AV_Protocol_Object* make_protocol_object (TAO_FlowSpec_Entry *entry,
TAO_Base_StreamEndPoint *endpoint,
TAO_AV_Flow_Handler *handler,
TAO_AV_Transport *transport);
};
ACE_STATIC_SVC_DECLARE (TimeStamp_Protocol_Factory)
ACE_FACTORY_DECLARE (TAO_TS, TimeStamp_Protocol_Factory)
#include /**/ "ace/post.h"
#endif /*TIMESTAMP_H*/
|
