blob: 6348ba66009d820ab99faa604fdde6b7f3181416 (
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
|
// file : ace/RMCast/Retransmit.h
// author : Boris Kolpackov <boris@kolpackov.net>
// cvs-id : $Id$
#ifndef ACE_RMCAST_RETRANSMIT_H
#define ACE_RMCAST_RETRANSMIT_H
#include <ace/Hash_Map_Manager.h>
#include <ace/Thread_Manager.h>
#include <ace/RMCast/Stack.h>
#include <ace/RMCast/Protocol.h>
#include <ace/RMCast/Bits.h>
namespace ACE_RMCast
{
class Retransmit : public Element
{
public:
Retransmit ();
virtual void
out_start (Out_Element* out);
virtual void
out_stop ();
public:
virtual void
send (Message_ptr m);
virtual void
recv (Message_ptr m);
private:
struct Descr
{
// Shouldn't be available but ACE_Hash_Map needs it.
//
Descr ()
: data_ (), count_ (0)
{
}
Descr (Data_ptr d)
: data_ (d), count_ (0)
{
}
unsigned long
inc ()
{
return ++count_;
}
void
reset ()
{
count_ = 0;
}
// It would be logical to return data_ptr but ACE ref_auto_ptr
// hasn't learned how to convert between pointers yet.
//
Profile_ptr
data () const
{
return Profile_ptr (new Data (*data_));
}
private:
Data_ptr data_;
unsigned long count_;
};
typedef
ACE_Hash_Map_Manager<u64, Descr, ACE_Null_Mutex>
Queue;
private:
void
track ();
static ACE_THR_FUNC_RETURN
track_thunk (void* obj);
private:
Queue queue_;
Mutex mutex_;
ACE_Thread_Manager tracker_mgr_;
};
}
#endif // ACE_RMCAST_RETRANSMIT_H
|
