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
/*
*cmd_thread.h
*
* $Author: graziano $
*
* $Revision: 1.2 $
*
* $Log: cmd_thread.h,v $
* Revision 1.2 2008-11-17 13:10:36 graziano
* command action can be: without arguments or with string argument
*
* Revision 1.1 2008/11/10 10:53:31 graziano
* thread for execution of commands
*
* Revision 1.2 2008/10/07 14:03:07 graziano
* added handling of multi axis groups and spindle groups
*
* Revision 1.1 2008/09/30 09:46:32 graziano
* first version
*
* Revision 1.3 2008/04/23 15:00:57 graziano
* small code cleanings
*
*
*
* 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 CMD_THREAD_H
#define CMD_THREAD_H
#ifndef _LOGA
#define _LOGA 1
#endif // _LOGA
//#define CMD_THREAD_EXIT "EXIT"
#define CMD_COMMAND 1
#define CMD_RESPONSE 2
#define CMD_THREAD_EXIT 3
#include <omnithread.h>
#include <tango.h>
#include "Alarm.h"
struct cmd_t
{
short cmd_id;
long call_id;
string arg_s1;
string arg_s2;
string arg_s3;
bool arg_b;
long dp_add;
};
class cmd_list : public omni_mutex {
public:
cmd_list(void): empty(this) {}
~cmd_list(void) {}
void push_back(cmd_t& cmd);
const cmd_t pop_front(void);
void clear(void);
protected:
list<cmd_t> l_cmd;
private:
omni_condition empty;
};
class cmd_thread : public omni_thread{
public:
cmd_thread();
~cmd_thread();
cmd_list list;
//omni_mutex::omni_mutex *mutex_dp;
protected:
void run(void *);
private:
Tango::DeviceProxy *dp;
};
#endif /* CMD_THREAD_H */
/* EOF */