From c5688968012fbd4f745aa3fed3c08804887a0b56 Mon Sep 17 00:00:00 2001 From: Anton Khirnov Date: Wed, 26 Feb 2020 18:07:42 +0100 Subject: dash_server: raise an exception on multiple cache entries This means two clients are trying to upload the same file at once. --- dash_server.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/dash_server.py b/dash_server.py index 2ac76b7..9e79c68 100755 --- a/dash_server.py +++ b/dash_server.py @@ -163,11 +163,12 @@ class StreamCache: @contextlib.contextmanager def add_entry(self, key, val): - # XXX handle key already present self._logger.debug('cache add: %s', key) + with self._lock: + if key in self._streams: + raise ValueError('Duplicate cache entry: %s' % key) + self._streams[key] = val try: - with self._lock: - self._streams[key] = val yield val finally: with self._lock: -- cgit v1.2.3