Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   */
  package org.jruby.ext.zlib;
  
  import org.jruby.Ruby;
 import static org.jruby.runtime.Visibility.PRIVATE;
 
 @JRubyClass(name = "Zlib::Deflate", parent = "Zlib::ZStream")
 public class JZlibDeflate extends ZStream {
     public static final int BASE_SIZE = 100;
     
     private int level;
     private int windowBits;
     private int strategy;
     private byte[] collected;
     private int collectedIdx;
     protected static final ObjectAllocator DEFLATE_ALLOCATOR = new ObjectAllocator() {
         public IRubyObject allocate(Ruby runtimeRubyClass klass) {
             return new JZlibDeflate(runtimeklass);
         }
     };
     private com.jcraft.jzlib.Deflater flater = null;
     private int flush = .;
 
     @JRubyMethod(name = "deflate", required = 1, optional = 1, meta = true)
     public static IRubyObject s_deflate(IRubyObject recvIRubyObject[] args) {
         Ruby runtime = recv.getRuntime();
         args = Arity.scanArgs(runtimeargs, 1, 1);
         int level = .;
         if (!args[1].isNil()) {
             level = RubyNumeric.fix2int(args[1]);
             checkLevel(runtimelevel);
         }
 
         RubyClass klass = (RubyClassrecv;
         JZlibDeflate deflate = (JZlibDeflateklass.allocate();
         deflate.init(level., 8, .);
 
         try {
             IRubyObject result = deflate.deflate(args[0].convertToString().getByteList(), .);
             deflate.close();
             return result;
         } catch (IOException ioe) {
             throw runtime.newIOErrorFromException(ioe);
         }
     }
 
     public JZlibDeflate(Ruby runtimeRubyClass type) {
         super(runtimetype);
     }
 
     @JRubyMethod(name = "initialize", optional = 4, visibility = )
     public IRubyObject _initialize(IRubyObject[] args) {
         args = Arity.scanArgs(getRuntime(), args, 0, 4);
          = -1;
          = .;
         int memlevel = 8;
          = 0;
         if (!args[0].isNil()) {
              = RubyNumeric.fix2int(args[0]);
             checkLevel(getRuntime(), );
         }
         if (!args[1].isNil()) {
              = RubyNumeric.fix2int(args[1]);
             checkWindowBits(getRuntime(), false);
         }
         if (!args[2].isNil()) {
             memlevel = RubyNumeric.fix2int(args[2]);
             // We accepts any memlevel and ignores it. Memory setting means nothing on Java platform.
         }
         if (!args[3].isNil()) {
              = RubyNumeric.fix2int(args[3]);
         }
         init(memlevel);
         return this;
     }
 
     private void init(int levelint windowBitsint memlevelint strategy) {
          = .;
          = new com.jcraft.jzlib.Deflater();
 
         // TODO: Can we expect JZlib to check level, windowBits, and strategy here?
         // Then we should remove checkLevel, checkWindowsBits and checkStrategy.
         int err = .init(levelwindowBitsmemlevel);
         if (err == ....) {
            throw RubyZlib.newStreamError(getRuntime(), "stream error");
        }
        err = .params(levelstrategy);
        if (err == ....) {
            throw RubyZlib.newStreamError(getRuntime(), "stream error");
        }
         = new byte[];
         = 0;
    }
    @Override
    @JRubyMethod(visibility = )
    public IRubyObject initialize_copy(IRubyObject _other) {
        if (!(_other instanceof JZlibDeflate)) {
            throw getRuntime().newTypeError("Expecting an instance of class JZlibDeflate");
        }
        if (this == _other) {
            return this;
        }
        JZlibDeflate other = (JZlibDeflate_other;
        this. = other.level;
        this. = other.windowBits;
        this. = other.strategy;
        this. = new byte[other.collected.length];
        System.arraycopy(other.collected, 0, this., 0, other.collected.length);
        this. = other.collectedIdx;
        this. = other.flush;
        this. = new com.jcraft.jzlib.Deflater();
        int ret = this..copy(other.flater);
        if (ret != ....) {
            throw RubyZlib.newStreamError(getRuntime(), "stream error");
        }
        return (IRubyObjectthis;
    }
    @JRubyMethod(name = "<<", required = 1)
    public IRubyObject append(IRubyObject arg) {
        checkClosed();
        try {
            append(arg.convertToString().getByteList());
        } catch (IOException ioe) {
            throw getRuntime().newIOErrorFromException(ioe);
        }
        return this;
    }
    @JRubyMethod(name = "params", required = 2)
    public IRubyObject params(ThreadContext contextIRubyObject levelIRubyObject strategy) {
        int l = RubyNumeric.fix2int(level);
        checkLevel(getRuntime(), l);
        
        int s = RubyNumeric.fix2int(strategy);
        checkStrategy(getRuntime(), s);
        
        if (. == null.setOutput(new byte[0]);
        int err = .params(ls);
        if (err == ....) {
            throw RubyZlib.newStreamError(getRuntime(), "stream error");
        }
        
        run();
        return getRuntime().getNil();
    }
    @JRubyMethod(name = "set_dictionary", required = 1)
    public IRubyObject set_dictionary(ThreadContext contextIRubyObject arg) {
        try {
            byte[] tmp = arg.convertToString().getBytes();
            int err = .setDictionary(tmptmp.length);
            if (err == ....) {
                throw RubyZlib.newStreamError(context.getRuntime(), "stream error: ");
            }
            run();
            return arg;
        } catch (IllegalArgumentException iae) {
            throw RubyZlib.newStreamError(context.getRuntime(), "stream error: " + iae.getMessage());
        }
    }
    @JRubyMethod(name = "flush", optional = 1)
    public IRubyObject flush(IRubyObject[] args) {
        int flush = 2; // SYNC_FLUSH
        
        if (args.length == 1 && !args[0].isNil()) flush = RubyNumeric.fix2int(args[0]);
        return flush(flush);
    }
    @JRubyMethod(name = "deflate", required = 1, optional = 1)
    public IRubyObject deflate(IRubyObject[] args) {
        args = Arity.scanArgs(getRuntime(), args, 1, 1);
        if (internalFinished()) throw RubyZlib.newStreamError(getRuntime(), "stream error");
        ByteList data = null;
        if (!args[0].isNil()) data = args[0].convertToString().getByteList();
        int flush = .;
        if (!args[1].isNil()) flush = RubyNumeric.fix2int(args[1]);
        
        try {
            return deflate(dataflush);
        } catch (IOException ioe) {
            throw getRuntime().newIOErrorFromException(ioe);
        }
    }
    @Override
    protected int internalTotalIn() {
        return (int.;
    }
    @Override
    protected int internalTotalOut() {
        return (int.;
    }
    @Override
    protected boolean internalStreamEndP() {
        return .finished();
    }
    @Override
    protected void internalReset() {
        init(, 8, );
    }
    @Override
    public boolean internalFinished() {
        return .finished();
    }
    @Override
    protected long internalAdler() {
        return .getAdler();
    }
    @Override
    protected IRubyObject internalFinish() {
        return finish();
    }
    @Override
    protected void internalClose() {
        .end();
    }
    private void append(ByteList objthrows IOException {
        .setInput(obj.getUnsafeBytes(), obj.getBegin(), obj.getRealSize(), true);
        run();
    }
    private IRubyObject flush(int flush) {
        int last_flush = this.;
        this. = flush;
        if (flush == .return RubyString.newEmptyString(getRuntime());
        run();
        this. = last_flush;
        IRubyObject obj = RubyString.newString(getRuntime(), , 0, );
         = 0;
        .setOutput();
        return obj;
    }
    private IRubyObject deflate(ByteList strint flushthrows IOException {
        if (null != strappend(str);
        return flush(flush);
    }
    private IRubyObject finish() {
        return flush(.);
    }
    private void run() {
        if (internalFinished()) return;
        while (!internalFinished()) {
            int err = .deflate();
            switch (err) {
                case ....:
                    throw RubyZlib.newStreamError(getRuntime(), "stream error: ");
                default:
            }
            if ( == .break;
             = .;
            
            if (. ==  && !internalFinished()) {
                byte[] tmp = new byte[. * 3];
                System.arraycopy(, 0, tmp, 0, .);
                 = tmp;
            }
        }
    }
New to GrepCode? Check out our FAQ X