# HG changeset patch # User Drew Perttula # Date 2014-06-03 08:28:10 # Node ID 7aca3145c96e677367359a124b16ce6954f92d33 # Parent 9ea123a24320a0561b4b00fe5fc3fa9ff795de3f refactor rdfdb patch() Ignore-this: b4e99ad7be01e4e1f1d28340258a5fb6 diff --git a/bin/rdfdb b/bin/rdfdb --- a/bin/rdfdb +++ b/bin/rdfdb @@ -288,6 +288,12 @@ class Db(object): self.watchedFiles.aboutToPatch(ctx) patchQuads(self.graph, p.delQuads, p.addQuads, perfect=True) + self._sendPatch(p) + if not dueToFileChange: + self.watchedFiles.dirtyFiles([ctx]) + sendToLiveClients(asJson=p.jsonRepr) + + def _sendPatch(self, p): senderUpdateUri = getattr(p, 'senderUpdateUri', None) for c in self.clients: @@ -296,10 +302,7 @@ class Db(object): continue d = c.sendPatch(p) d.addErrback(self.clientErrored, c) - if not dueToFileChange: - self.watchedFiles.dirtyFiles([ctx]) - sendToLiveClients(asJson=p.jsonRepr) - + def clientErrored(self, err, c): err.trap(twisted.internet.error.ConnectError) log.info("connection error- dropping client %r" % c)