Method Next

src/brpc/rpc_dump.cpp:275–320

}

SampledRequest* SampleIterator::Next() {
    if (!_cur_buf.empty()) {
        bool error = false;
        SampledRequest* r = Pop(_cur_buf, &error);
        if (r) {
            return r;
        }
        if (error) {
            _cur_buf.clear();
            if (_cur_fd >= 0) {
                ::close(_cur_fd);
                _cur_fd = -1;
            }
        }
    }
    while (1) {
        while (_cur_fd >= 0) {
            ssize_t nr = _cur_buf.append_from_file_descriptor(_cur_fd, 524288);
            if (nr < 0) {
                if (errno != EAGAIN && errno != EINTR) {
                    PLOG(ERROR) << "Fail to read fd=" << _cur_fd;
                    break;
                }
            } else if (nr == 0) {  // EOF
                break;
            } else {
                return Next();  // tailr
            }
        }
        _cur_buf.clear();
        if (_cur_fd >= 0) {
            ::close(_cur_fd);
            _cur_fd = -1;
        }
        
        if (_enum == NULL) {
            _enum = new butil::FileEnumerator(
                _dir, false, butil::FileEnumerator::FILES);
        }
        butil::FilePath filename = _enum->Next();
        if (filename.empty()) {
            return NULL;
        }
        _cur_fd = open(filename.value().c_str(), O_RDONLY);
    }
}

SampledRequest* SampleIterator::Pop(butil::IOBuf& buf, bool* format_error) {
    char backing_buf[12];