Function run

lib/client.js:1035–1080

()

    }

    function run() {
        var barrier = vasync.barrier();
        var q = new Queue({
            limit: opts.parallel || 50,
            worker: function (_opts, _cb) {
                self.ls(_opts.path, options, function (err, ls_res) {
                    if (err) {
                        err.path = _opts.path;
                        _cb(err);
                        return;
                    }

                    ls_res.on('entry', function onEntry(obj) {
                        obj.depth = _opts.depth;
                        if (obj.type === 'directory' &&
                            (obj.depth + 1) < maxdepth) {
                            var name = obj.parent + '/' + obj.name;
                            barrier.start(name);
                            q.push({
                                depth: obj.depth + 1,
                                path: name
                            });
                        }
                        filter(obj);
                    });

                    ls_res.once('end', function () {
                        barrier.done(_opts.path);
                        _cb();
                    });

                    ls_res.on('error', _cb);
                });
            }
        });

        q.once('error', res.emit.bind(res, 'error'));
        q.once('end', res.emit.bind(res, 'end'));
        barrier.once('drain', q.close.bind(q));

        barrier.start(_path);
        q.push({
            depth: 0,
            path: _path
        });
    }

    // First ensure we're looking at a directory
    this.info(p, options, function (info_err, meta) {