diff options
| -rwxr-xr-x | dash_server.py | 7 |
1 files 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: |