blob: 516926f814acd990d07e563e70b833fe63b6aa53 (
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
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
// $Id$
#ifndef METRICS_UTILS_H
#define METRICS_UTILS_H
#if ! defined (VXWORKS)
// Comment out both of these to disable output
# define METRICS_UTILS_ERROR_OUTPUT_ENABLED
# define METRICS_UTILS_DEBUG_OUTPUT_ENABLED
#endif /* ! VXWORKS */
#include "ace/OS.h"
#include "ace/Singleton.h"
#include "orbsvcs/RtecSchedulerC.h"
#include "orbsvcs/MetricsC.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
class TAO_Metrics_Export TAO_Metrics_Utils
{
// = TITLE
// Defines a class for various metrics utility functions.
//
// = DESCRIPTION
// This class provides static methods for various general
// purpose tasks for managing and using the metrics framework.
public:
// Type declarations
enum Base_Metrics_Type {SCHED, QUO, RTARM, TNS, TEEC};
static const u_int METRICS_BUFSIZE;
// Constant size for local buffers.
static const u_int METRICS_ENQUEUE_PROBE_ID_BASE;
static const u_int METRICS_DEQUEUE_PROBE_ID_BASE;
static const u_int METRICS_SCHED_PROBE_ID_BASE;
static const u_int METRICS_QUO_PROBE_ID_BASE;
static const u_int METRICS_TNS_PROBE_ID_BASE;
static const u_int METRICS_TEEC_PROBE_ID_BASE;
static const u_int METRICS_RTARM_PROBE_ID_BASE;
static const u_int METRICS_UPCALL_MONITOR_ADAPTER_ID_BASE;
// Constants for offsets into ranges of probe ids.
static void set_mission_state (int i, Metrics::QoSLogger_ptr logger);
// Sets the mission state in the logger referenced by the passed pointer.
static void set_mission_state (int i, const char * logger_ior_str);
// Sets the mission state in the logger referenced by the passed ior string.
static Metrics::QoSLogger_var get_logger (const char * logger_ior_str,
CORBA::ORB_ptr orb_);
// Gets a pointer to a logger from the passed logger ior string,
// using the passed ORB.
static RtecScheduler::handle_t timeoutEvent (void);
// Accessor for static timeout event handle. This handle is ignored
// by the QoS monitor, since by definition it will be dispatched
// after the end-of-frame.
static void timeoutEvent (RtecScheduler::handle_t handle);
// Mutator for static timeout event handle. This handle is ignored
// by the QoS monitor, since by definition it will be dispatched
// after the end-of-frame.
private:
static RtecScheduler::handle_t timeoutEvent_;
};
struct TAO_Metrics_Export WSOA_Metrics_Handles
{
// = TITLE
// Defines a helper class for WSOA METRICS INSTRUMENTATION.
//
// = DESCRIPTION
// This class provides a single point of initialization (registration)
// and storage for the handles used in WSOA metrics collection. It is necessary
// to define this class at this level to cross-cut multiple layers of the
// architecture and provide consistent points of instrumentation across layers.
public:
WSOA_Metrics_Handles ();
// Default constructor - registers all handles.
// number of tile handles to reserve in each category.
static const u_int WSOA_METRICS_MAX_TILING_FACTOR;
// global attribute to decide when image is downloaded.
u_long tiles_requested_;
// Globally accessible handles for METRICS INSTRUMENTATION
RtecScheduler::handle_t compute_metrics_handle_;
RtecScheduler::handle_t RTARM_triggered_adaptation_metrics_handle_;
RtecScheduler::handle_t RTARM_region_transition_metrics_handle_;
RtecScheduler::handle_t QuO_contract_eval_metrics_handle_;
RtecScheduler::handle_t tile_request_delegate_metrics_handle_;
RtecScheduler::handle_t image_received_metrics_handle_;
RtecScheduler::handle_t image_processed_metrics_handle_;
RtecScheduler::handle_t image_quiescent_metrics_handle_;
RtecScheduler::handle_t tile_received_first_metrics_handle_;
RtecScheduler::handle_t tile_queuing_first_metrics_handle_;
RtecScheduler::handle_t tile_decompression_first_metrics_handle_;
RtecScheduler::handle_t tile_decompression_handle_;
RtecScheduler::handle_t tile_ipm_first_metrics_handle_;
RtecScheduler::handle_t tile_processed_first_metrics_handle_;
RtecScheduler::handle_t zlib_compression_handle_;
RtecScheduler::handle_t zlib_decompression_handle_;
};
typedef ACE_Singleton<WSOA_Metrics_Handles, ACE_SYNCH_MUTEX>
WSOA_METRICS_HANDLES_SINGLETON;
#if defined (__ACE_INLINE__)
#include "Metrics_Utils.i"
#endif /* __ACE_INLINE__ */
#endif /* METRICS_UTILS_H */
|
