1

我正在使用稍微修改过的 DotZlib 版本，它是带有 zlib 源代码的 contrib 目录的一部分，用于扩充实时数据流。

我需要使用 InflateInit2 而不是常规的 inflateInit - 但这是与提供的库的唯一区别。

Netherlesse 经过几次读取后，我从 zlib 收到错误代码 1，并且在添加字节时无法恢复。

zlib contrib 目录中的原始代码是：

    public override void Add(byte[] data, int offset, int count)
        {
            if (data == null) throw new ArgumentNullException();
            if (offset < 0 || count < 0) throw new ArgumentOutOfRangeException()
;
            if ((offset+count) > data.Length) throw new ArgumentException();

            int total = count;
            int inputIndex = offset;
            int err = 0;

            while (err >= 0 && inputIndex < total)
            {
                copyInput(data, inputIndex, Math.Min(total - inputIndex, kBufferSize));
                err = inflate(ref _ztream, (int)FlushTypes.None);
                if (err == 0)
                    while (_ztream.avail_out == 0)
                    {
                        OnDataAvailable();
                        err = inflate(ref _ztream, (int)FlushTypes.None);
                    }

                inputIndex += (int)_ztream.total_in;
            }
            setChecksum( _ztream.adler );
        }

顺便说一句，有谁知道如何贡献改进的代码？该实现设计得很好，但从我的角度来看是不完整的。

4

1 回答 1

1

我觉得

            err = inflate(ref _ztream, (int)FlushTypes.None);
            if (err == 0)
                while (_ztream.avail_out == 0)
                {
                    OnDataAvailable();
                    err = inflate(ref _ztream, (int)FlushTypes.None);
                }

应该

            while (_ztream.avail_in > 0)
            {
                err = inflate(ref _ztream, (int)FlushTypes.None);
                if (err!=0)
                    break;
                OnDataAvailable();
            }

我看到代码的第一个版本存在两个问题：

  1. 如果 inflate() 产生数据但没有产生足够的数据使avail_out 为 0，即使数据可用，您也不会调用 OnDataAvailable。
  2. 即使avail_in 为0，您也可能会调用inflate()，我很容易想象这可能会产生流结束错误。

（注意：我怀疑你是以专业身份认识我的。这个答案是以私人身份给出的，与我为雇主的工作无关。）

于 2009-05-18T10:45:33.827 回答