msr_runscript.py 文件源码

def tmp_master_process(self, worker_result):
    task, geom, surf, bounds = worker_result

    if geom != "None":

        active_data.set_value(task, 'geom_val', geom)

        master_grid.update(bounds, surf)
        # ileft = (bounds[0] - core.bounds[0]) / core.pixel_size
        # itop = (core.bounds[3] - bounds[3]) / core.pixel_size

        # iright = ileft + surf.shape[0]
        # ibottom = itop + surf.shape[1]


        # # add worker surf as slice to sum_mean_surf
        # sum_mean_surf[ileft:iright, itop:ibottom] += surf


        # mstack.append_stack(surf)

        # if mstack.get_stack_size() > 1:
           # print "reducing stack"
        #    mstack.reduce_stack()