def _run_pipeline(self, multiprocessing):
if not self._flag_m:<EOL><INDENT>raise UnsupportedCall(f"<STR_LIT>")<EOL><DEDENT>if not self._flag_q:<EOL><INDENT>self._flag_q = True<EOL>warnings.warn("<STR_LIT>"<EOL>f"<STR_LIT>", AttributeWarning, stacklevel=stacklevel())<EOL><DEDENT>self._frnum = <NUM_LIT:1>                                                 <EOL>self._expkg = multiprocessing                                   <EOL>self._mpprc = list()                                            <EOL>self._mpfdp = collections.defaultdict(multiprocessing.Queue)    <EOL>self._mpmng = multiprocessing.Manager()                         <EOL>self._mpkit = self._mpmng.Namespace()                           <EOL>self._mpkit.counter = <NUM_LIT:0>                                         <EOL>self._mpkit.pool = <NUM_LIT:1>                                            <EOL>self._mpkit.current = <NUM_LIT:1>                                         <EOL>self._mpkit.eof = False                                         <EOL>self._mpkit.frames = dict()                                     <EOL>self._mpkit.trace = self._trace                                 <EOL>self._mpkit.reassembly = copy.deepcopy(self._reasm)             <EOL>self.record_header()<EOL>self._mpfdp[<NUM_LIT:0>].put(self._gbhdr.length)<EOL>while True:<EOL><INDENT>if self._mpkit.eof:<EOL><INDENT>self._update_eof()<EOL>break<EOL><DEDENT>if self._mpkit.pool and self._mpkit.counter < CPU_CNT:<EOL><INDENT>self._ifile.seek(self._mpfdp.pop(self._frnum-<NUM_LIT:1>).get(), os.SEEK_SET)<EOL>proc = multiprocessing.Process(<EOL>target=self._pipeline_read_frame,<EOL>kwargs={'<STR_LIT>': self._mpkit, '<STR_LIT>': self._mpfdp[self._frnum]}<EOL>)<EOL>self._mpkit.pool -= <NUM_LIT:1><EOL>self._mpkit.counter += <NUM_LIT:1><EOL>proc.start()<EOL>self._frnum += <NUM_LIT:1><EOL>self._mpprc.append(proc)<EOL><DEDENT>if len(self._mpprc) >= CPU_CNT:<EOL><INDENT>[proc.join() for proc in self._mpprc[:-<NUM_LIT:4>]]<EOL>del self._mpprc[:-<NUM_LIT:4>]<EOL><DEDENT><DEDENT>
Use pipeline multiprocessing to extract PCAP files.