123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144 |
- #if !BESTHTTP_DISABLE_ALTERNATE_SSL && (!UNITY_WEBGL || UNITY_EDITOR)
- #pragma warning disable
- using System;
- using System.IO;
- namespace BestHTTP.SecureProtocol.Org.BouncyCastle.Utilities.Zlib {
- /// <summary>
- /// Summary description for DeflaterOutputStream.
- /// </summary>
- public class ZInflaterInputStream : Stream {
- protected ZStream z=new ZStream();
- protected int flushLevel=JZlib.Z_NO_FLUSH;
- private const int BUFSIZE = 4192;
- protected byte[] buf=new byte[BUFSIZE];
- private byte[] buf1=new byte[1];
- protected Stream inp=null;
- private bool nomoreinput=false;
- public ZInflaterInputStream(Stream inp) : this(inp, false) {
- }
-
- public ZInflaterInputStream(Stream inp, bool nowrap) {
- this.inp=inp;
- z.inflateInit(nowrap);
- z.next_in=buf;
- z.next_in_index=0;
- z.avail_in=0;
- }
-
- public override bool CanRead {
- get {
- // TODO: Add DeflaterOutputStream.CanRead getter implementation
- return true;
- }
- }
-
- public override bool CanSeek {
- get {
- // TODO: Add DeflaterOutputStream.CanSeek getter implementation
- return false;
- }
- }
-
- public override bool CanWrite {
- get {
- // TODO: Add DeflaterOutputStream.CanWrite getter implementation
- return false;
- }
- }
-
- public override long Length {
- get {
- // TODO: Add DeflaterOutputStream.Length getter implementation
- return 0;
- }
- }
-
- public override long Position {
- get {
- // TODO: Add DeflaterOutputStream.Position getter implementation
- return 0;
- }
- set {
- // TODO: Add DeflaterOutputStream.Position setter implementation
- }
- }
-
- public override void Write(byte[] b, int off, int len) {
- }
-
- public override long Seek(long offset, SeekOrigin origin) {
- // TODO: Add DeflaterOutputStream.Seek implementation
- return 0;
- }
-
- public override void SetLength(long value) {
- // TODO: Add DeflaterOutputStream.SetLength implementation
- }
-
- public override int Read(byte[] b, int off, int len) {
- if(len==0)
- return(0);
- int err;
- z.next_out=b;
- z.next_out_index=off;
- z.avail_out=len;
- do {
- if((z.avail_in==0)&&(!nomoreinput)) { // if buffer is empty and more input is avaiable, refill it
- z.next_in_index=0;
- z.avail_in=inp.Read(buf, 0, BUFSIZE);//(BUFSIZE<z.avail_out ? BUFSIZE : z.avail_out));
- if(z.avail_in<=0) {
- z.avail_in=0;
- nomoreinput=true;
- }
- }
- err=z.inflate(flushLevel);
- if(nomoreinput&&(err==JZlib.Z_BUF_ERROR))
- return(0);
- if(err!=JZlib.Z_OK && err!=JZlib.Z_STREAM_END)
- throw new IOException("inflating: "+z.msg);
- if((nomoreinput||err==JZlib.Z_STREAM_END)&&(z.avail_out==len))
- return(0);
- }
- while(z.avail_out==len&&err==JZlib.Z_OK);
- //System.err.print("("+(len-z.avail_out)+")");
- return(len-z.avail_out);
- }
-
- public override void Flush() {
- inp.Flush();
- }
-
- public override void WriteByte(byte b) {
- }
- #if PORTABLE || NETFX_CORE
- protected override void Dispose(bool disposing)
- {
- if (disposing)
- {
- BestHTTP.SecureProtocol.Org.BouncyCastle.Utilities.Platform.Dispose(inp);
- }
- base.Dispose(disposing);
- }
- #else
- public override void Close()
- {
- BestHTTP.SecureProtocol.Org.BouncyCastle.Utilities.Platform.Dispose(inp);
- base.Close();
- }
- #endif
- public override int ReadByte() {
- if(Read(buf1, 0, 1)<=0)
- return -1;
- return(buf1[0]&0xFF);
- }
- }
- }
- #pragma warning restore
- #endif
|