X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fmetamovement.go;h=71aa209c67980e7094a65c6c1772ba0f7be4a2f1;hb=237458a36b6c7f5014d9ee61b816a61ebdc5b57d;hp=98d8e8d562fe320776872a0fe14d44b74fb82d0b;hpb=957f71721b04698dd588ffc8dc2ed10775050451;p=svn42.git diff --git a/go/r3-eventbroker_zmq/metamovement.go b/go/r3-eventbroker_zmq/metamovement.go index 98d8e8d..71aa209 100644 --- a/go/r3-eventbroker_zmq/metamovement.go +++ b/go/r3-eventbroker_zmq/metamovement.go @@ -20,7 +20,7 @@ func MetaEventRoutine_Movement(ps *pubsub.PubSub, granularity, gran_duration int movement_window := ring.New(granularity+1) events_chan := ps.Sub("movement") myticker := time.NewTicker(time.Duration(gran_duration) * time.Second) - + for { select { case event := <- events_chan: switch event.(type) { @@ -37,7 +37,7 @@ func MetaEventRoutine_Movement(ps *pubsub.PubSub, granularity, gran_duration int ps.Pub( SomethingReallyIsMoving{true,ts}, "movement") last_movement = ts } - + if last_movement > 0 && ts - last_movement < 3600*6 && ts - last_movement > 3600*3 { last_movement = 0 ps.Pub( SomethingReallyIsMoving{false, ts}, "movement")