Move current keyspace check out of Connection lock

This commit is contained in:
Tyler Hobbs
2013-06-14 16:41:33 -05:00
parent f722a52850
commit a387644dc8

View File

@@ -443,13 +443,10 @@ class Connection(object):
raise ProtocolError(msg)
def set_keyspace(self, keyspace):
if not keyspace:
if not keyspace or keyspace == self.keyspace:
return
with self.lock:
if keyspace == self.keyspace:
return
query = 'USE "%s"' % (keyspace,)
try:
result = self.wait_for_response(