Commit 5c004da1 authored by Jim Fulton's avatar Jim Fulton

Fixed a bug that could cause invalidations for clients of storage

servers with zeo clients to be delayed.
parent 66dd368f
...@@ -1013,10 +1013,11 @@ class StorageServer: ...@@ -1013,10 +1013,11 @@ class StorageServer:
# connections indirectoy by closing them. We don't care about # connections indirectoy by closing them. We don't care about
# later transactions since they will have to validate their # later transactions since they will have to validate their
# caches anyway. # caches anyway.
connections = connections[:] connections = connections[:]
for p in connections: for p in connections:
try: try:
p.connection.should_close() p.connection.should_close()
p.connection.trigger.pull_trigger()
except ZEO.zrpc.error.DisconnectedError: except ZEO.zrpc.error.DisconnectedError:
pass pass
......
...@@ -61,6 +61,14 @@ stub that implements the client invalidation calls: ...@@ -61,6 +61,14 @@ stub that implements the client invalidation calls:
... self.mgr.close_conn(self) ... self.mgr.close_conn(self)
... def poll(self): ... def poll(self):
... pass ... pass
...
... @property
... def trigger(self):
... return self
...
... def pull_trigger(self):
... pass
>>> class ZEOStorage: >>> class ZEOStorage:
... def __init__(self, server, name): ... 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