Commit 3ef5a5fe authored by Jim Fulton's avatar Jim Fulton

Fixed a bug that could cause invalidations for clients of storage

servers that serve ZEO clients (use ZEO clients as their storages) to
be delayed.
parent fc0848d2
......@@ -1062,10 +1062,11 @@ class StorageServer:
# connections indirectoy by closing them. We don't care about
# later transactions since they will have to validate their
# caches anyway.
connections = connections[:]
connections = connections[:]
for p in connections:
try:
p.connection.should_close()
p.connection.trigger.pull_trigger()
except ZEO.zrpc.error.DisconnectedError:
pass
......
......@@ -61,6 +61,14 @@ stub that implements the client invalidation calls:
... self.mgr.close_conn(self)
... def poll(self):
... pass
...
... @property
... def trigger(self):
... return self
...
... def pull_trigger(self):
... pass
>>> class ZEOStorage:
... def __init__(self, server, name):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment