External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-03-07 11:41:08 -03:30
Code Issues Packages Projects Releases Wiki Activity

fix sliding window calculation

Browse Source
This commit is contained in:
chris meyers
2020-02-28 09:50:27 -05:00
committed by Ryan Petrello
parent 3f5e2a3cd3
commit d58df0f34a
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
awx/main/analytics/broadcast_websocket.py
View File

@@ -36,16 +36,18 @@ class FixedSlidingWindow():
self.buckets = dict() self.buckets = dict()
self.start_time = start_time or now_seconds() self.start_time = start_time or now_seconds()
def cleanup(self, now_bucket=now_seconds()): def cleanup(self, now_bucket=None):
if self.start_time + 60 >= now_bucket: now_bucket = now_bucket or now_seconds()
self.start_time = now_bucket - 60 + 1 if self.start_time + 60 <= now_bucket:
self.start_time = now_bucket + 60 + 1
# Delete old entries # Delete old entries
for k,v in self.buckets.items(): for k in list(self.buckets.keys()):
if k < self.start_time: if k < self.start_time:
del self.buckets[k] del self.buckets[k]
def record(self, ts=datetime.datetime.now()): def record(self, ts=None):
ts = ts or datetime.datetime.now()
now_bucket = int((ts - datetime.datetime(1970,1,1)).total_seconds()) now_bucket = int((ts - datetime.datetime(1970,1,1)).total_seconds())
val = self.buckets.get(now_bucket, 0) val = self.buckets.get(now_bucket, 0)