# -*- coding: utf-8 -*-
from __future__ import absolute_import, division, print_function, unicode_literals
from six.moves import zip
from os.path import exists, join
import utool as ut
import vtool as vt
(print, rrr, profile) = ut.inject2(__name__, '[preproc_detectimg]')
[docs]def gen_detectimg_and_write(tup):
""" worker function for parallel generator """
gid, gfpath, new_gfpath, new_size = tup
#print('[preproc] writing detectimg: %r' % new_gfpath)
img = vt.imread(gfpath)
new_img = vt.resize(img, new_size)
vt.imwrite(new_gfpath, new_img)
return gid, new_gfpath
[docs]def gen_detectimg_async(gid_list, gfpath_list, new_gfpath_list,
newsize_list, nImgs=None):
""" Resizes images and yeilds results asynchronously """
# Compute and write detectimg in asychronous process
if nImgs is None:
nImgs = len(gid_list)
arg_iter = zip(gid_list, gfpath_list, new_gfpath_list, newsize_list)
arg_list = list(arg_iter)
# THis probably wont work for the same reason gen_chip wont work
return ut.util_parallel.generate(gen_detectimg_and_write, arg_list, force_serial=True)
[docs]def get_image_detectimg_fpath_list(ibs, gid_list):
r""" Returns detectimg path list
Example:
>>> # ENABLE_DOCTEST
>>> import ibeis
>>> from os.path import basename
>>> from ibeis.algo.preproc.preproc_detectimg import * # NOQA
>>> ibs = ibeis.opendb('testdb1')
>>> valid_gids = ibs.get_valid_gids()
>>> gid_list = valid_gids[0:2]
>>> new_gfpath_list = get_image_detectimg_fpath_list(ibs, gid_list)
>>> result = ('\n'.join(map(basename, new_gfpath_list)))
>>> target = '\n'.join((
... 'reszd_sqrtArea=800_66ec193a-1619-b3b6-216d-1784b4833b61.jpg',
... 'reszd_sqrtArea=800_d8903434-942f-e0f5-d6c2-0dcbe3137bf7.jpg'))
>>> assert result == target, 'got result=\n%s' % result
"""
ut.assert_all_not_None(gid_list, 'gid_list')
sqrt_area = ibs.cfg.detect_cfg.detectimg_sqrt_area
gext_list = ibs.get_image_exts(gid_list)
guuid_list = ibs.get_image_uuids(gid_list)
cachedir = ibs.get_detectimg_cachedir()
new_gfpath_list = [join(cachedir, 'reszd_sqrtArea=' + str(sqrt_area) + '_' + str(guuid) + ext)
for (guuid, ext) in zip(guuid_list, gext_list)]
return new_gfpath_list
[docs]def compute_and_write_detectimg(ibs, gid_list):
"""
CommandLine:
python -m ibeis.algo.preproc.preproc_detectimg --test-compute_and_write_detectimg --show
Example:
>>> # SLOW_DOCTEST
>>> import ibeis
>>> from ibeis.algo.preproc.preproc_detectimg import * # NOQA
>>> ibs = ibeis.opendb('testdb1')
>>> valid_gids = ibs.get_valid_gids()
>>> gid_list = valid_gids[0:2]
>>> new_gfpath_list = compute_and_write_detectimg(ibs, gid_list)
>>> print(ut.list_str(new_gfpath_list))
>>> ut.quit_if_noshow()
>>> import plottool as pt
>>> #pt.imshow(new_gfpath_list[0])
>>> iteract_obj = pt.interact_multi_image.MultiImageInteraction(new_gfpath_list, nPerPage=4)
>>> pt.show_if_requested()
"""
ut.ensuredir(ibs.get_detectimg_cachedir())
# Get img configuration information
sqrt_area = ibs.cfg.detect_cfg.detectimg_sqrt_area
target_area = sqrt_area ** 2
# Get img dest information (output path)
new_gfpath_list = get_image_detectimg_fpath_list(ibs, gid_list)
# Get img source information (image, annotation_bbox, theta)
gfpath_list = ibs.get_image_paths(gid_list)
gsize_list = ibs.get_image_sizes(gid_list)
newsize_list = vt.get_scaled_sizes_with_area(target_area, gsize_list)
# Define "Asynchronous" generator
print('[preproc_detectimg] Computing %d imgs asynchronously' % (len(gfpath_list)))
detectimg_async_iter = gen_detectimg_async(gid_list, gfpath_list,
new_gfpath_list, newsize_list)
for gid, new_gfpath in detectimg_async_iter:
# print('Wrote detectimg: %r' % new_gfpath)
pass
print('[preproc_detectimg] Done computing detectimgs')
return new_gfpath_list
[docs]def compute_and_write_detectimg_lazy(ibs, gid_list):
"""
Will write a img if it does not exist on disk, regardless of if it exists
in the SQL database
Example:
>>> # SLOW_DOCTEST
>>> import ibeis
>>> from ibeis.algo.preproc.preproc_detectimg import * # NOQA
>>> ibs = ibeis.opendb('testdb1')
>>> valid_gids = ibs.get_valid_gids()
>>> gid_list = valid_gids[0:2]
>>> result = compute_and_write_detectimg_lazy(ibs, gid_list)
"""
print('[preproc_detectimg] compute_and_write_detectimg_lazy')
# Mark which aid's need their detectimg computed
new_gfpath_list = get_image_detectimg_fpath_list(ibs, gid_list)
exists_flags = [exists(gfpath) for gfpath in new_gfpath_list]
invalid_gids = ut.get_dirty_items(gid_list, exists_flags)
print('[preproc_detectimg] %d / %d detectimgs need to be computed' %
(len(invalid_gids), len(gid_list)))
compute_and_write_detectimg(ibs, invalid_gids)
return new_gfpath_list
if __name__ == '__main__':
"""
CommandLine:
python -m ibeis.algo.preproc.preproc_detectimg
python -m ibeis.algo.preproc.preproc_detectimg --allexamples
python -m ibeis.algo.preproc.preproc_detectimg --test-compute_and_write_detectimg_lazy
"""
ut.doctest_funcs()