def open(self):
if not self._oplog:
try:
logging.debug("Opening oplog file %s" % self.oplog_file)
if self.do_gzip:
self._oplog = GzipFile(self.oplog_file, self.file_mode)
else:
self._oplog = open(self.oplog_file, self.file_mode)
except Exception, e:
logging.fatal("Error opening oplog file %s! Error: %s" % (self.oplog_file, e))
raise OperationError(e)
return self._oplog
评论列表
文章目录