light9 Changeset - 7aca3145c96e

Changeset - 7aca3145c96e

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

Drew Perttula - 11 years ago 2014-06-03 08:28:10
drewp@bigasterisk.com

refactor rdfdb patch()
Ignore-this: b4e99ad7be01e4e1f1d28340258a5fb6

1 file changed with 7 insertions and 4 deletions:

bin/rdfdb

0 comments (0 inline, 0 general)

bin/rdfdb

➞

Show inline comments

@@ @@ -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)

0 comments (0 inline, 0 general)