o ॵi!@sxddlmZddlmZddlZddlmZmZmZm Z m Z m Z m Z ddl mZmZmZGdddZGdd d ZdS) N) OrderedDict)CAP_PROP_FOURCC CAP_PROP_FPSCAP_PROP_FRAME_COUNTCAP_PROP_FRAME_HEIGHTCAP_PROP_FRAME_WIDTHCAP_PROP_POS_FRAMESVideoWriter_fourcc)check_file_existmkdir_or_existtrack_progressc@s>eZdZddZeddZeddZddZd d d Zd S) CachecCs&t|_t||_|dkrtddS)Nrz#capacity must be a positive integer)r_cacheint _capacity ValueError)selfcapacityrf/home/ubuntu/.local/lib/python3.10/site-packages/modelscope/preprocessors/cv/video_super_resolution.py__init__s  zCache.__init__cC|jSN)rrrrrrszCache.capacitycCs t|jSr)lenrrrrrsizes z Cache.sizecCs:||jvrdSt|j|jkr|jjdd||j|<dS)NF)last)rrrpopitem)rkeyvalrrrputs z Cache.putNcCs ||jvr |j|}|S|}|Sr)r)rrdefaultr rrrget&sz Cache.getr) __name__ __module__ __qualname__rpropertyrrr!r#rrrrrs  rc@seZdZdZd3ddZeddZeddZed d Zed d Z ed dZ eddZ eddZ eddZ eddZddZddZddZddZdd Z ! " ! ! #d4d$d%Zd&d'Zd(d)Zd*d+Zd,d-ZeZd.d/Zd0d1Zd2S)5 VideoReaderaVideo class with similar usage to a list object. This video warpper class provides convenient apis to access frames. There exists an issue of OpenCV's VideoCapture class that jumping to a certain frame may be inaccurate. It is fixed in this class by checking the position after jumping each time. Cache is used when decoding videos. So if the same frame is visited for the second time, there is no need to decode again if it is stored in the cache. Example: >>> import mmcv >>> v = mmcv.VideoReader('sample.mp4') >>> len(v) # get the total frame number with `len()` 120 >>> for img in v: # v is iterable >>> mmcv.imshow(img) >>> v[5] # get the 6th frame cCs|ds t|d|t||_|dksJt||_d|_t|j t |_ t|j t |_ |j t|_t|j t|_|j t|_dS)N)zhttps://zhttp://zVideo file not found: r) startswithr cv2 VideoCapture_vcaprr _positionrr#r_widthr_heightr_fpsr _frame_cntr_fourcc)rfilenamecache_capacityrrrr?s    zVideoReader.__init__cCr)z5:obj:`cv2.VideoCapture`: The raw VideoCapture object.)r-rrrrvcapNzVideoReader.vcapcCs |jS)z+bool: Indicate whether the video is opened.)r-isOpenedrrrropenedSs zVideoReader.openedcCr)zint: Width of video frames.)r/rrrrwidthXr7zVideoReader.widthcCr)zint: Height of video frames.)r0rrrrheight]r7zVideoReader.heightcCs |j|jfS)z(tuple: Video resolution (width, height).)r/r0rrrr resolutionbs zVideoReader.resolutioncCr)zfloat: FPS of the video.)r1rrrrfpsgr7zVideoReader.fpscCr)zint: Total frames of the video.)r2rrrr frame_cntlr7zVideoReader.frame_cntcCr)z(str: "Four character code" of the video.)r3rrrrfourccqr7zVideoReader.fourcccCr)z7int: Current cursor position, indicating frame decoded.)r.rrrrpositionvr7zVideoReader.positioncCstt|jtSr)rroundr-r#rrrrr_get_real_position{szVideoReader._get_real_positioncCs<|jt||}t||D]}|jq||_dSr)r-setrrBrangereadr.)rframe_idpos_rrr_set_real_position~s   zVideoReader._set_real_positioncCs|jr0|j|j}|durd}n&|j|kr||j|j\}}|r/|j|j|n|j\}}|r@|jd7_|S)aRead the next frame. If the next frame have been decoded before and in the cache, then return it directly, otherwise decode, cache and return it. Returns: ndarray or None: Return the frame if successful, otherwise None. NTr )rr#r.rBrIr-rEr!)rimgretrrrrEs zVideoReader.readcCs|dks ||jkrtd|jd||jkr|S|jr0|j|}|dur0|d|_|S|||j\}}|rP|jrI|j|j||jd7_|S)zGet frame by index. Args: frame_id (int): Index of the expected frame, 0-based. Returns: ndarray or None: Return the frame if successful, otherwise None. rz!"frame_id" must be between 0 and r N) r2 IndexErrorr.rErr#rIr-r!)rrFrJrKrrr get_frames$    zVideoReader.get_framecCs |jdkrdS|j|jdS)zGet the current frame (frame that is just visited). Returns: ndarray or None: If the video is fresh, return None, otherwise return the frame. rNr )r.rr#rrrr current_frames zVideoReader.current_framer {:06d}.jpgTc st|dkrj|}ntj||}|dkrtd|dkr'|fdd}|r=t|t|||dSt|D]} ||| qAdS)aConvert a video to frame images. Args: frame_dir (str): Output directory to store all the frame images. file_start (int): Filenames will start from the specified number. filename_tmpl (str): Filename template with the index as the placeholder. start (int): The starting frame index. max_num (int): Maximum number of frames to be written. show_progress (bool): Whether to show a progress bar. rz*start must be less than total frame numbercs6}|dur dSt|}t||dSr)rEospjoinformatr+imwrite)file_idxrJr4 filename_tmpl frame_dirrrr write_frames z+VideoReader.cvt2frames..write_frameN)r r>minrrIr rD) rrW file_startrVstartmax_num show_progresstask_numrXirrUr cvt2framess    zVideoReader.cvt2framescCrr)r>rrrr__len__szVideoReader.__len__csTt|trfddt|jDS|dkr%|j7}|dkr%td|S)Ncsg|]}|qSr)rM).0r_rrr sz+VideoReader.__getitem__..rzindex out of range) isinstanceslicerDindicesr>rLrM)rindexrrr __getitem__s    zVideoReader.__getitem__cCs|d|S)Nr)rIrrrr__iter__s zVideoReader.__iter__cCs|}|dur |Str)rE StopIteration)rrJrrr__next__szVideoReader.__next__cCs|Srrrrrr __enter__szVideoReader.__enter__cCs|jdSr)r-release)rexc_type exc_value tracebackrrr__exit__ szVideoReader.__exit__N)r))rrOrrT)r$r%r&__doc__rr'r6r9r:r;r<r=r>r?r@rBrIrErMrNr`rarhrirknextrlrqrrrrr(+sN            )  r()os.pathpathrP collectionsrr+rrrrrrr utilr r r rr(rrrrs  $