don't send two write heartbeats within 2 seconds of eachother

This commit is contained in:
Alan Hamlett 2015-05-06 12:22:42 -07:00
parent 5cd0061653
commit b51ae5c2c4

View file

@ -136,9 +136,11 @@ def obfuscate_apikey(command_list):
return cmd return cmd
def enough_time_passed(now, last_time): def enough_time_passed(now, last_time, is_write):
if now - last_time > ACTION_FREQUENCY * 60: if now - last_time > ACTION_FREQUENCY * 60:
return True return True
if is_write and now - last_time > 2:
return True
return False return False
@ -201,7 +203,7 @@ class SendActionThread(threading.Thread):
with self.lock: with self.lock:
if self.target_file: if self.target_file:
self.timestamp = time.time() self.timestamp = time.time()
if self.force or (self.is_write and not self.last_action['is_write']) or self.target_file != self.last_action['file'] or enough_time_passed(self.timestamp, self.last_action['time']): if self.force or self.target_file != self.last_action['file'] or enough_time_passed(self.timestamp, self.last_action['time'], self.is_write):
self.send_heartbeat() self.send_heartbeat()
def send_heartbeat(self): def send_heartbeat(self):