Synnefo » ./kamaki

            self).main(container___path, path_is_optional=False)

        try:

            f = open(local_path, 'r')

            try:

                upload_cb = progress_bar.get_generator('Appending blocks')

            except Exception:

                upload_cb = None

                source_file=f,

                upload_cb=upload_cb)

        except ClientError as err:

            raiseCLIError(err)

@command(pithos_cmds)

            self).main(container___path, path_is_optional=False)

        try:

            f = open(local_path, 'r')

            try:

                upload_cb = progress_bar.get_generator('Overwritting blocks')

            except Exception:

                upload_cb = None

                source_file=f,

                upload_cb=upload_cb)

        except ClientError as err:

            raiseCLIError(err)

@command(pithos_cmds)

            sharing=self.get_argument('sharing'),

            public=self.get_argument('public'))

        try:

            with open(local_path) as f:

                if self.get_argument('unchunked'):

                    self.client.upload_object_unchunked(remote_path, f,

                    withHashFile=self.get_argument('use_hashes'),

                    **params)

                else:

                        'Calculating block hashes')

                    upload_cb = progress_bar.get_generator('Uploading')

                    self.client.upload_object(remote_path, f,

        except ClientError as err:

            raiseCLIError(err)

        except IOError as err:

                importance=2,

                details=unicode(err))

        print 'Upload completed'

                raise CLIError(message='Cannot write to file %s - %s'\

                    % (local_path, unicode(err)),

                    importance=1)

        poolsize = self.get_argument('poolsize')

        if poolsize is not None:

            self.client.POOL_SIZE = int(poolsize)

        try:

            self.client.download_object(self.path, out,

                download_cb=download_cb,

                range=self.get_argument('range'),

                if_none_match=self.get_argument('if_none_match'),

                if_modified_since=self.get_argument('if_modified_since'),

                if_unmodified_since=self.get_argument('if_unmodified_since'))

        except ClientError as err:

            raiseCLIError(err)

        except KeyboardInterrupt:

            from threading import enumerate as activethreads

                    stdout.write('.')

                except RuntimeError:

                    continue

            print('\ndownload canceled by user')

            if local_path is not None:

                print('to resume, re-run with --resume')

        print