| 
														
															@@ -1015,10 +1015,10 @@ class Repository: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             raise ValueError(self.path + " is in append-only mode") 
														 | 
														
														 | 
														
															             raise ValueError(self.path + " is in append-only mode") 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         error_found = False 
														 | 
														
														 | 
														
															         error_found = False 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        def report_error(msg): 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        def report_error(msg, *args): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             nonlocal error_found 
														 | 
														
														 | 
														
															             nonlocal error_found 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             error_found = True 
														 | 
														
														 | 
														
															             error_found = True 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            logger.error(msg) 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+            logger.error(msg, *args) 
														 | 
													
												
											
												
													
														| 
														 | 
														
															  
														 | 
														
														 | 
														
															  
														 | 
													
												
											
												
													
														| 
														 | 
														
															         logger.info('Starting repository check') 
														 | 
														
														 | 
														
															         logger.info('Starting repository check') 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         assert not self._active_txn 
														 | 
														
														 | 
														
															         assert not self._active_txn 
														 | 
													
												
											
										
											
												
													
														 | 
														
															@@ -1105,8 +1105,8 @@ class Repository: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                 # self.index = "as rebuilt in-memory from segments" 
														 | 
														
														 | 
														
															                 # self.index = "as rebuilt in-memory from segments" 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                 if len(current_index) != len(self.index): 
														 | 
														
														 | 
														
															                 if len(current_index) != len(self.index): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                     report_error('Index object count mismatch.') 
														 | 
														
														 | 
														
															                     report_error('Index object count mismatch.') 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-                    logger.error('committed index: %d objects', len(current_index)) 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-                    logger.error('rebuilt index:   %d objects', len(self.index)) 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+                    report_error('committed index: %d objects', len(current_index)) 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+                    report_error('rebuilt index:   %d objects', len(self.index)) 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                 else: 
														 | 
														
														 | 
														
															                 else: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                     logger.info('Index object count match.') 
														 | 
														
														 | 
														
															                     logger.info('Index object count match.') 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                 line_format = 'ID: %-64s rebuilt index: %-16s committed index: %-16s' 
														 | 
														
														 | 
														
															                 line_format = 'ID: %-64s rebuilt index: %-16s committed index: %-16s' 
														 | 
													
												
											
										
											
												
													
														 | 
														
															@@ -1114,13 +1114,13 @@ class Repository: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                 for key, value in self.index.iteritems(): 
														 | 
														
														 | 
														
															                 for key, value in self.index.iteritems(): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                     current_value = current_index.get(key, not_found) 
														 | 
														
														 | 
														
															                     current_value = current_index.get(key, not_found) 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                     if current_value != value: 
														 | 
														
														 | 
														
															                     if current_value != value: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-                        logger.warning(line_format, bin_to_hex(key), value, current_value) 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+                        report_error(line_format, bin_to_hex(key), value, current_value) 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                 for key, current_value in current_index.iteritems(): 
														 | 
														
														 | 
														
															                 for key, current_value in current_index.iteritems(): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                     if key in self.index: 
														 | 
														
														 | 
														
															                     if key in self.index: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                         continue 
														 | 
														
														 | 
														
															                         continue 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                     value = self.index.get(key, not_found) 
														 | 
														
														 | 
														
															                     value = self.index.get(key, not_found) 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                     if current_value != value: 
														 | 
														
														 | 
														
															                     if current_value != value: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-                        logger.warning(line_format, bin_to_hex(key), value, current_value) 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+                        report_error(line_format, bin_to_hex(key), value, current_value) 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             if repair: 
														 | 
														
														 | 
														
															             if repair: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															                 self.write_index() 
														 | 
														
														 | 
														
															                 self.write_index() 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         self.rollback() 
														 | 
														
														 | 
														
															         self.rollback() 
														 |