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
|
/*
* Copyright (C) 2006 Paul Davis
* Copyright (C) 2007 Michael Taht
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*
* */
/* The routines in here should know absolutely nothing about how io is actually done */
#include <tranzport_control_protocol.h>
int
TranzportControlProtocol::flush ()
{
int pending = 0;
// Always write the lights first
if(!(pending = lights_flush())) {
pending = screen_flush();
}
#if DEBUG_TRANZPORT_BITS > 9
int s;
if(s = (screen_invalid.count())) { // + lights_invalid.count())) {
printf("VALID : %s %s\n",
screen_invalid.to_string().c_str(),
lights_invalid.to_string().c_str());
printf("CURR : %s %s\n",
screen_invalid.to_string().c_str(),
lights_current.to_string().c_str());
printf("PENDING : %s %s\n",
screen_invalid.to_string().c_str(),
lights_pending.to_string().c_str());
#if DEBUG_TRANZPORT_BITS > 10
printf("invalid bits: %d\n",s);
#endif
}
#endif
return pending;
}
int
TranzportControlProtocol::lights_flush ()
{
std::bitset<LIGHTS> light_state;
light_state = lights_pending ^ lights_current;
if ( (light_state.none() || lights_invalid.none()))
{
return (0);
}
#if DEBUG_TRANZPORT_LIGHTS
printf("LPEND : %s\n", lights_pending.to_string().c_str());
printf("LCURR : %s\n", lights_current.to_string().c_str());
#endif
// if ever we thread reads/writes STATUS_OK will have to move into the loop
int i;
if ( _device_status == STATUS_OK || _device_status == STATUS_ONLINE) {
for (i = 0; i<LIGHTS; i++) {
if(light_state[i]) {
if(light_set ((LightID)i,lights_pending[i])) {
#if DEBUG_TRANZPORT_LIGHTS > 2
printf("Did %d light writes\n",i);
#endif
return light_state.count();
} else {
light_state[i] = 0;
}
}
}
}
light_state = lights_pending ^ lights_current;
#if DEBUG_TRANZPORT_LIGHTS > 2
printf("Did %d light writes, left: %d\n",i, light_state.count());
#endif
return light_state.count();
}
|