Commit da601241 authored by Jim Fulton's avatar Jim Fulton

The (commit) invalidate method incorrectly sent messages that are part

of the startup invalidation protocol.
parent 77bb14bc
...@@ -83,7 +83,7 @@ ...@@ -83,7 +83,7 @@
# #
############################################################################## ##############################################################################
__version__ = "$Revision: 1.9 $"[11:-2] __version__ = "$Revision: 1.10 $"[11:-2]
import asyncore, socket, string, sys, cPickle, os import asyncore, socket, string, sys, cPickle, os
from smac import SizedMessageAsyncConnection from smac import SizedMessageAsyncConnection
...@@ -159,9 +159,7 @@ class StorageServer(asyncore.dispatcher): ...@@ -159,9 +159,7 @@ class StorageServer(asyncore.dispatcher):
dump=dump): dump=dump):
for c in self.__connections[storage_id]: for c in self.__connections[storage_id]:
if c is connection: continue if c is connection: continue
c.message_output('bN.')
c.message_output('I'+dump(invalidated, 1)) c.message_output('I'+dump(invalidated, 1))
c.message_output('eN.')
def writable(self): return 0 def writable(self): return 0
......
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