8a5e99fa839be41367ea9d67c169124f8dec4124,networkml/parsers/pcap/reader.py,,parallel_sessionizer,#Any#Any#Any#Any#Any#,246

Before Change

                    logger.error("exception processing {0}: {1}".format(pcap_file, err))

        if csv_out_dir is not None:
            for pcap_file, pcap_sessions in pcap_file_sessions.items():
                pcap_to_sessioncsv(csv_out_dir, pcap_file, pcap_sessions)
        return pcap_file_sessions

After Change

        // Retrieve pre-cached CSVs.
        for pcap_file in pcap_files:
            csv_file = csv_filenames[pcap_file]
            if os.path.exists(csv_file):
                pcap_file_sessions[pcap_file] = sessioncsv_to_sessions(csv_filename)
            else:
                unparsed_pcaps.append(pcap_file)
        futures = {
            executor.submit(sessionizer, pcap_file, duration, threshold_time): pcap_file
            for pcap_file in unparsed_pcaps}
        pcap_file_sessions = {}

Instances