Newer
Older
Graziano Scalamera
committed
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
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
/*
* event_table.h
*
* $Author: graziano $
*
* $Revision: 1.2 $
*
* $Log: event_table.h,v $
*
*
* copyleft: Sincrotrone Trieste S.C.p.A. di interesse nazionale
* Strada Statale 14 - km 163,5 in AREA Science Park
* 34012 Basovizza, Trieste ITALY
*/
#ifndef EVENT_TABLE_H
#define EVENT_TABLE_H
#include <iostream>
#include <string>
#include <map>
#include <tango.h>
using namespace std;
#define INTERNAL_ERROR "internal_error"
#define TYPE_TANGO_ERR -2
#define TYPE_GENERIC_ERR -3
class event;
class event_list;
class event_table;
class EventCallBack;
typedef vector<Tango::DevDouble> value_t;
/*
* basic event type
*/
class event {
public:
string name, /* event name */
device, /* device name */
attribute; /* attribute name */
value_t value; /* event value */
Tango::TimeVal ts; /* event timestamp */
int type, /* attribute data type */
counter, /* molteplicita' */
err_counter; /* molteplicita' errore */
//map<string, string> m_alarm;
vector<string> m_alarm;
bool valid;
Tango::DeviceProxy *dp;
unsigned int eid;
vector<string> filter;
/*
* methods
*/
event(string& s, value_t& v, Tango::TimeVal& t);
event(string& s);
event() {}
~event() {}
void push_alarm(string& n);
void pop_alarm(string& n);
// bool event::operator==(const event& e); //TODO: gcc 4 problem??
bool operator==(const event& e);
// bool event::operator==(const string& s); //TODO: gcc 4 problem??
bool operator==(const string& s);
protected:
private:
};
typedef struct basic_event_info_s {
string ev_name;
value_t value;
int type;
Tango::TimeVal ts;
string msg;
} bei_t;
/*
* here the event callback handler will store the relevant
* events info coming from subscribed events for the
* processing thread
*/
class event_list : public omni_mutex {
public:
event_list(void): full(this), empty(this) {}
~event_list(void) {}
void push_back(bei_t& e);
const bei_t pop_front(void);
void clear(void);
list<bei_t> show(void);
protected:
list<bei_t> l_event;
private:
omni_condition full,
empty;
};
/*
* store all the events
*/
class event_table : public event , Tango::LogAdapter {
public:
event_table(Tango::DeviceImpl *s):Tango::LogAdapter(s) {}
~event_table(void) {}
void push_back(event e);
void show(void);
unsigned int size(void);
void init_proxy(void) throw(vector<string> &);
void free_proxy(void);
void subscribe(EventCallBack& ecb) throw(vector<string> &);//throw(string&);
void unsubscribe(void) throw(string&);
void update_events(bei_t& e) throw(string&);
vector<event> v_event;
protected:
private:
}; /* class event_table */
/*
* event callback
*/
class EventCallBack : public Tango::CallBack {
public:
EventCallBack(void);
~EventCallBack(void);
void push_event(Tango::EventData* ev);
void init(event_list* e);
void extract_values(Tango::DeviceAttribute *attr_value, vector<double> &val, int &type);
private:
event_list* e_ptr;
};
/*
* utility function
*/
Tango::TimeVal gettime(void);
#endif /* EVENT_TABLE_H */