summaryrefslogtreecommitdiff
path: root/cethcan
diff options
context:
space:
mode:
authorChristian Franke <nobody@nowhere.ws>2016-10-14 16:08:33 +0200
committerChristian Franke <nobody@nowhere.ws>2016-10-14 16:08:33 +0200
commitd4208574b657365de1a9535823460a0e4becf60f (patch)
treef36f0f6eb11b8380a4b83713f01a6c61402341b9 /cethcan
parenta55daf0b6c2930660499e40a455bd1011f44f1eb (diff)
Limit the rate at which updates are sent to lightsHEADmaster
Diffstat (limited to 'cethcan')
-rw-r--r--cethcan/light.c41
1 files changed, 36 insertions, 5 deletions
diff --git a/cethcan/light.c b/cethcan/light.c
index 0adf28a..c605e81 100644
--- a/cethcan/light.c
+++ b/cethcan/light.c
@@ -17,6 +17,11 @@ struct light {
struct light **slaves;
struct value set, actual;
+
+ struct event *holdoff;
+ bool holdoff_pending;
+ bool holdoff_changed;
+ unsigned holdoff_value;
};
static struct light *lights = NULL, **plights = &lights;
@@ -30,6 +35,31 @@ struct light *light_find(const char *name)
return l;
}
+static void light_holdoff_event(int sock, short event, void *arg)
+{
+ struct light *l = arg;
+
+ l->holdoff_pending = false;
+ if (!l->holdoff_changed)
+ return;
+
+ struct can_message msg;
+ msg.daddr = CANA_LIGHT_F(0, l->logical_addr);
+ msg.dlc = 1;
+ msg.bytes[0] = l->holdoff_value;
+ can_broadcast(l->u, &msg);
+
+ l->holdoff_changed = false;
+ if (!l->holdoff)
+ l->holdoff = evtimer_new(ev_base, light_holdoff_event, l);
+
+ struct timeval holdoff_time = {
+ .tv_usec = 40000UL
+ };
+ evtimer_add(l->holdoff, &holdoff_time);
+ l->holdoff_pending = true;
+}
+
int light_set(struct light *l, unsigned value)
{
if (l->aggregate) {
@@ -39,12 +69,13 @@ int light_set(struct light *l, unsigned value)
return ec;
}
- struct can_message msg;
- msg.daddr = CANA_LIGHT_F(0, l->logical_addr);
- msg.dlc = 1;
- msg.bytes[0] = value;
- can_broadcast(l->u, &msg);
+ l->holdoff_changed = true;
+ l->holdoff_value = value;
+
+ if (l->holdoff_pending)
+ return 0;
+ light_holdoff_event(0,0,l);
return 0;
}