Commit df13013f authored by Jim Fulton's avatar Jim Fulton

Make sure we pass text to note

parent 4438aef4
...@@ -35,7 +35,7 @@ class TransUndoStorageWithCache: ...@@ -35,7 +35,7 @@ class TransUndoStorageWithCache:
# Now start an undo transaction # Now start an undo transaction
t = TransactionMetaData() t = TransactionMetaData()
t.note('undo1') t.note(u'undo1')
oids = self._begin_undos_vote(t, tid) oids = self._begin_undos_vote(t, tid)
# Make sure this doesn't load invalid data into the cache # Make sure this doesn't load invalid data into the cache
......
...@@ -83,7 +83,7 @@ class StressTask: ...@@ -83,7 +83,7 @@ class StressTask:
def commit(self): def commit(self):
cn = self.cn cn = self.cn
key = self.startnum key = self.startnum
self.tm.get().note("add key %s" % key) self.tm.get().note(u"add key %s" % key)
try: try:
self.tm.get().commit() self.tm.get().commit()
except ConflictError as msg: except ConflictError as msg:
...@@ -155,7 +155,7 @@ class StressThread(FailableThread): ...@@ -155,7 +155,7 @@ class StressThread(FailableThread):
while not self.stop.isSet(): while not self.stop.isSet():
try: try:
tree[key] = self.threadnum tree[key] = self.threadnum
tm.get().note("add key %s" % key) tm.get().note(u"add key %s" % key)
tm.commit() tm.commit()
self.commitdict[self] = 1 self.commitdict[self] = 1
if self.sleep: if self.sleep:
...@@ -218,7 +218,7 @@ class LargeUpdatesThread(FailableThread): ...@@ -218,7 +218,7 @@ class LargeUpdatesThread(FailableThread):
break break
else: else:
# print("%d set #%d" % (self.threadnum, len(keys))) # print("%d set #%d" % (self.threadnum, len(keys)))
transaction.get().note("keys %s" % ", ".join(map(str, keys))) transaction.get().note(u"keys %s" % ", ".join(map(str, keys)))
try: try:
transaction.commit() transaction.commit()
self.commitdict[self] = 1 self.commitdict[self] = 1
......
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