Method resolve_computers_threaded

core/dns_resolver.py:200–265

Enhanced IP resolution with threading support

(self, computers)

        }
    
    def resolve_computers_threaded(self, computers):
        """Enhanced IP resolution with threading support"""
        ip_records = {}
        resolution_stats = {
            'total_computers': len(computers),
            'successful_resolutions': 0,
            'total_ips_found': 0,
            'online_computers': 0,
            'methods_used': set()
        }
        
        logger.info(f"🔍 Starting threaded IP resolution for {len(computers)} computers...")
        logger.info(f"🌐 DNS Server: {self.dns_server if self.dns_server else 'System default'}")
        logger.info(f"🧵 Using {self.max_threads} concurrent threads")
        logger.info("=" * 70)
        
        # Use ThreadPoolExecutor for concurrent DNS resolution
        with ThreadPoolExecutor(max_workers=self.max_threads) as executor:
            # Submit all DNS resolution tasks
            future_to_computer = {
                executor.submit(self.resolve_single_computer, computer, False): computer
                for computer in computers if computer['computer_name']
            }
            
            # Collect results as they complete
            completed = 0
            for future in as_completed(future_to_computer):
                computer = future_to_computer[future]
                completed += 1
                
                logger.debug(f"[{completed}/{len(future_to_computer)}] Processing: {computer['computer_name']}")
                
                try:
                    resolution_result = future.result()
                    
                    if resolution_result['ips']:
                        ip_records[computer['computer_name']] = resolution_result['ips']
                        resolution_stats['successful_resolutions'] += 1
                        resolution_stats['total_ips_found'] += len(resolution_result['ips'])
                        resolution_stats['methods_used'].update(resolution_result['methods'])
                        
                        if resolution_result['connectivity'] == "Online":
                            resolution_stats['online_computers'] += 1
                        
                        logger.debug(f"Summary: {len(resolution_result['ips'])} IPs found via {', '.join(resolution_result['methods'])}")
                        logger.debug(f"   IPs: {', '.join(resolution_result['ips'])}")
                        logger.debug(f"   Status: {resolution_result['connectivity']}")
                    else:
                        logger.debug(f"No IPs resolved for {computer['computer_name']}")
                except Exception as e:
                    logger.debug(f"Error resolving {computer['computer_name']}: {e}")
        
        # Print final statistics
        logger.info("=" * 70)
        logger.info("📊 THREADED RESOLUTION STATISTICS")
        logger.info("=" * 70)
        logger.info(f"Total computers processed: {resolution_stats['total_computers']}")
        logger.info(f"Successful resolutions: {resolution_stats['successful_resolutions']}")