75d7e3313db6c40a19d48cb9d1b66366d6ff7d8d,w3af/core/controllers/core_helpers/strategy_observers/thread_state_observer.py,ThreadStateObserver,crawl,#ThreadStateObserver#Any#,57

Before Change

        
        with self._lock:
            if self.crawl_infra_thread is not None:
                return

            self.crawl_infra_thread = threading.Thread(target=self.thread_worker,
                                                       args=(consumer, "CrawlInfraWorker"),
                                                       name="CrawlInfraPoolStateObserver")

After Change

            if self.worker_thread is None:
                pool = consumer._w3af_core.worker_pool
                self.worker_thread = threading.Thread(target=self.thread_worker,
                                                      args=(pool, "Worker"),
                                                      name="WorkerPoolStateObserver")
                self.worker_thread.start()

    def audit(self, consumer, *args):
        
        Log the thread state for audit plugins

Instances