Commit fcc55973 authored by Vincent Pelletier's avatar Vincent Pelletier

Cleanup a few unused variables.

parent 6be00df7
...@@ -676,7 +676,6 @@ class Application(object): ...@@ -676,7 +676,6 @@ class Application(object):
append = result.append append = result.append
resolved_oid_set = set() resolved_oid_set = set()
update = resolved_oid_set.update update = resolved_oid_set.update
ttid = txn_context['ttid']
_handleConflicts = self._handleConflicts _handleConflicts = self._handleConflicts
queue = txn_context['queue'] queue = txn_context['queue']
conflict_serial_dict = txn_context['conflict_serial_dict'] conflict_serial_dict = txn_context['conflict_serial_dict']
......
...@@ -78,7 +78,7 @@ class ConnectionPool(object): ...@@ -78,7 +78,7 @@ class ConnectionPool(object):
@profiler_decorator @profiler_decorator
def _dropConnections(self): def _dropConnections(self):
"""Drop connections.""" """Drop connections."""
for node_uuid, conn in self.connection_dict.items(): for conn in self.connection_dict.values():
# Drop first connection which looks not used # Drop first connection which looks not used
conn.lock() conn.lock()
try: try:
......
...@@ -236,7 +236,6 @@ class NEOLogger(Logger): ...@@ -236,7 +236,6 @@ class NEOLogger(Logger):
def packet(self, connection, packet, outgoing): def packet(self, connection, packet, outgoing):
if self._db is not None: if self._db is not None:
ip, port = connection.getAddress()
self._queue(PacketRecord( self._queue(PacketRecord(
created=time(), created=time(),
msg_id=packet._id, msg_id=packet._id,
......
...@@ -144,7 +144,6 @@ class ReadBuffer(object): ...@@ -144,7 +144,6 @@ class ReadBuffer(object):
pop_chunk = self.content.popleft pop_chunk = self.content.popleft
append_data = chunk_list.append append_data = chunk_list.append
to_read = size to_read = size
chunk_len = 0
# select required chunks # select required chunks
while to_read > 0: while to_read > 0:
chunk_size, chunk_data = pop_chunk() chunk_size, chunk_data = pop_chunk()
......
...@@ -193,7 +193,6 @@ class BackupApplication(object): ...@@ -193,7 +193,6 @@ class BackupApplication(object):
prev_tid = app.getLastTransaction() prev_tid = app.getLastTransaction()
app.setLastTransaction(tid) app.setLastTransaction(tid)
pt = app.pt pt = app.pt
getByUUID = app.nm.getByUUID
trigger_set = set() trigger_set = set()
untouched_dict = defaultdict(dict) untouched_dict = defaultdict(dict)
for offset in xrange(pt.getPartitions()): for offset in xrange(pt.getPartitions()):
...@@ -252,7 +251,6 @@ class BackupApplication(object): ...@@ -252,7 +251,6 @@ class BackupApplication(object):
replicate_list.append(offset) replicate_list.append(offset)
if not replicate_list: if not replicate_list:
return return
getByUUID = self.nm.getByUUID
getCellList = self.pt.getCellList getCellList = self.pt.getCellList
source_dict = {} source_dict = {}
address_set = set() address_set = set()
......
...@@ -142,7 +142,6 @@ class VerificationManager(BaseServiceHandler): ...@@ -142,7 +142,6 @@ class VerificationManager(BaseServiceHandler):
app.em.poll(0) app.em.poll(0)
def verifyTransaction(self, tid): def verifyTransaction(self, tid):
em = self.app.em
nm = self.app.nm nm = self.app.nm
uuid_set = set() uuid_set = set()
...@@ -193,7 +192,6 @@ class VerificationManager(BaseServiceHandler): ...@@ -193,7 +192,6 @@ class VerificationManager(BaseServiceHandler):
def answerTransactionInformation(self, conn, tid, def answerTransactionInformation(self, conn, tid,
user, desc, ext, packed, oid_list): user, desc, ext, packed, oid_list):
uuid = conn.getUUID() uuid = conn.getUUID()
app = self.app
if not self._gotAnswerFrom(uuid): if not self._gotAnswerFrom(uuid):
return return
oid_set = set(oid_list) oid_set = set(oid_list)
......
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