Mirroristas/bigchaindb
2
0
Fork 0
mirror of https://github.com/bigchaindb/bigchaindb.git synced 2024-10-13 13:34:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Checking for replica set is now within try..except

Browse Source
This commit is contained in:
vrde 2017-01-31 17:01:22 +01:00
parent 157db3e01f
commit 857cdb9b34
No known key found for this signature in database
GPG Key ID: 6581C7C39B3D397D
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
bigchaindb/backend/mongodb/connection.py
View File

@ -76,17 +76,17 @@ class MongoDBConnection(Connection):
attempt += 1 attempt += 1
try: try:
# we should only return a connection if the replica set is
# initialized. initialize_replica_set will check if the
# replica set is initialized else it will initialize it.
initialize_replica_set(self.host, self.port, self.connection_timeout)
# FYI: this might raise a `ServerSelectionTimeoutError`, # FYI: this might raise a `ServerSelectionTimeoutError`,
# that is a subclass of `ConnectionFailure`. # that is a subclass of `ConnectionFailure`.
self.connection = MongoClient(self.host, self.connection = MongoClient(self.host,
self.port, self.port,
replicaset=self.replicaset, replicaset=self.replicaset,
serverselectiontimeoutms=self.connection_timeout) serverselectiontimeoutms=self.connection_timeout)
# we should only return a connection if the replica set is
# initialized. initialize_replica_set will check if the
# replica set is initialized else it will initialize it.
initialize_replica_set(self.host, self.port, self.connection_timeout)
except (errors.ConnectionFailure, errors.AutoReconnect) as exc: except (errors.ConnectionFailure, errors.AutoReconnect) as exc:
logger.warning('Attempt %s/%s. Connection to %s:%s failed after %sms.', logger.warning('Attempt %s/%s. Connection to %s:%s failed after %sms.',
attempt, self.max_tries if self.max_tries != 0 else '∞', attempt, self.max_tries if self.max_tries != 0 else '∞',