storage: relax assertion

Nothing wrong actually happens.

Traceback (most recent call last):
  File "neo/scripts/neostorage.py", line 32, in main
    app.run()
  File "neo/storage/app.py", line 194, in run
    self._run()
  File "neo/storage/app.py", line 225, in _run
    self.doOperation()
  File "neo/storage/app.py", line 310, in doOperation
    poll()
  File "neo/storage/app.py", line 134, in _poll
    self.em.poll(1)
  File "neo/lib/event.py", line 168, in poll
    self._poll(0)
  File "neo/lib/event.py", line 220, in _poll
    if conn.readable():
  File "neo/lib/connection.py", line 483, in readable
    self._closure()
  File "neo/lib/connection.py", line 541, in _closure
    self.close()
  File "neo/lib/connection.py", line 533, in close
    handler.connectionClosed(self)
  File "neo/storage/handlers/client.py", line 46, in connectionClosed
    app.tm.abortFor(conn.getUUID())
  File "neo/storage/transactions.py", line 594, in abortFor
    self.abort(ttid)
  File "neo/storage/transactions.py", line 570, in abort
    self._replicated.get(self.getPartition(oid))), x
AssertionError: ('\x00\x00\x00\x00\x00\x01a\xe5', '\x03\xcaZ\x04\x14o\x8e\xbb', '\x03\xcaZ\x04\x0eX{\xbb', {1: None, 21: '\x03\xcaZ\x04\x11\xc6\x94\xf6'}, set([]))

neo/storage/transactions.py

@@ -556,8 +556,11 @@ class TransactionManager(EventQueue):
                     x = (oid, ttid, write_locking_tid,
                          self._replicated, transaction.lockless)
                 lockless = oid in transaction.lockless
-                assert oid in other.serial_dict and lockless == bool(
-                    self._replicated.get(self.getPartition(oid))), x
+                # If there were multiple lockless writes, lockless can be
+                # False (after a rebase) whereas the partition is still not
+                # notified as replicated.
+                assert oid in other.serial_dict and not (lockless and
+                    not self._replicated.get(self.getPartition(oid))), x
                 if not lockless:
                     assert not locked, x
                     continue # unresolved deadlock