Synnefo » ./kamaki

        #resume if some blocks have been downloaded

                resumed[existing_hash] = i

                if with_progress_bar:

            elif not overide:

                raise ClientError(message='Local file is substantialy different',

                    status=600)

            end = custom_end

        return (start, end)

        newflying = []

        for v in flying:

            h = v['handler']

                if h.exception:

                    h.release()

                    raise h.exception

                objfile.seek(v['start'])

                objfile.flush()

            else:

                #if there are unfinished greenlets, sleep for some time - be carefull with that

                    gevent.Greenlet._report_error(self, exc_info)

                finally:

                    sys.stderr = _stderr

        if self.async_pool is None:

            self.async_pool = gevent.pool.Pool(size=POOL_SIZE)

        g = SilentGreenlet(self._get_block, obj, **kwargs)

        self.async_pool.start(g)

        return g

    def _async_download_missing_blocks(self, obj, objfile, hmap, resumed, blocksize, total_size, 

        download_gen=None, custom_start = None, custom_end=None, **restargs):

        """Attempt pseudo-multithreaded (with greenlets) download of blocks, or if that

            data_range = 'bytes=%s-%s'%(start, end)

            handler = self._get_block_async(obj, data_range=data_range, **restargs)

            flying.append({'handler':handler, 'start':start, 'data_range':data_range})

        #write the last results and exit

        while len(flying) > 0:

        objfile.truncate(total_size)

        gevent.joinall(flying)