def __init__(self, config, timer, db):
self.config = config
self.timer = timer
self.db = db
self.balancer_wait_secs = self.config.sharding.balancer.wait_secs
self.balancer_sleep = self.config.sharding.balancer.ping_secs
self.timer_name = self.__class__.__name__
self.config_server = None
self.config_db = None
self.mongos_db = None
self._balancer_state_start = None
self.restored = False
# Get a DB connection
try:
if isinstance(self.db, DB):
self.connection = self.db.connection()
if not self.db.is_mongos() and not self.db.is_configsvr():
raise DBOperationError('MongoDB connection is not to a mongos or configsvr!')
else:
raise Error("'db' field is not an instance of class: 'DB'!")
except Exception, e:
logging.fatal("Could not get DB connection! Error: %s" % e)
raise DBOperationError(e)
评论列表
文章目录