Synnefo » ./kamaki

    def _run(self, local_path, remote_path):

        poolsize = self['poolsize']

        if poolsize > 0:

        params = dict(

            content_encoding=self['content_encoding'],

            content_type=self['content_type'],

        #outputs = self._outputs(local_path)

        poolsize = self['poolsize']

        if poolsize:

        progress_bar = None

        try:

            for f, rpath in self._outputs(local_path):

class Client(object):

    def __init__(self, base_url, token, http_client=KamakiHTTPConnection()):

        self.base_url = base_url

    def _watch_thread_limit(self, threadlist):

        recvlog.debug('# running threads: %s' % len(threadlist))

        if (self._elapsed_old > self._elapsed_new) and (

            self._thread_limit += 1

        elif self._elapsed_old < self._elapsed_new and self._thread_limit > 1:

            self._thread_limit -= 1