blob: 4f1ef1bcff17a123f683fd2779608d652dc15048 (
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
|
// $Id$
#include "ace/OS_NS_unistd.h"
#include "ace/Log_Msg.h"
#include "Graph.h"
#include "Graphable_Element.h"
#include "Temperature_Grapher.h"
// Listing 1 code/ch21
void Temperature_Grapher::monitor (void)
{
for (;;)
{
this->update_graph ();
ACE_OS::sleep (this->opt_.poll_interval ());
}
}
// Listing 1
// Listing 2 code/ch21
void Temperature_Grapher::update_graph (void)
{
Name_Binding_Ptr lastUpdate
(this->naming_context_.fetch ("lastUpdate"));
if (!lastUpdate.get ())
{
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("No data to graph\n")));
return;
}
// Listing 2
// Listing 3 code/ch21
Name_Binding_Ptr lastGraphed
(this->naming_context_.fetch ("lastGraphed"));
if (lastGraphed.get () &&
lastGraphed->int_value () == lastUpdate->int_value ())
{
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Data already graphed\n")));
return;
}
// Listing 3
// Listing 4 code/ch21
ACE_BINDING_SET set;
if (this->naming_context_.list_name_entries
(set, "history[") != 0)
{
ACE_DEBUG ((LM_INFO,
ACE_TEXT ("There's nothing to graph\n")));
return;
}
// Listing 4
#if !defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
// Listing 5 code/ch21
Graphable_Element_List graphable;
ACE_BINDING_ITERATOR set_iterator (set);
for (ACE_Name_Binding *entry = 0;
set_iterator.next (entry) != 0;
set_iterator.advance ())
{
Name_Binding binding (entry);
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("%s\t%s\t%s\n"),
binding.type (),
binding.name (),
binding.value ()));
Graphable_Element *ge = new Graphable_Element (entry);
graphable.push_back (*ge);
}
// Listing 5
// Listing 6 code/ch21
Graph g;
g.graph (lastUpdate->value (), graphable);
this->naming_context_.rebind ("lastGraphed",
lastUpdate->int_value ());
// Listing 6
#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
}
|
