diff options
Diffstat (limited to 'ext/zlib/zlib.c')
| -rw-r--r-- | ext/zlib/zlib.c | 2768 |
1 files changed, 2768 insertions, 0 deletions
diff --git a/ext/zlib/zlib.c b/ext/zlib/zlib.c new file mode 100644 index 0000000000..b89738de89 --- /dev/null +++ b/ext/zlib/zlib.c @@ -0,0 +1,2768 @@ +/* + * zlib.c - An interface for zlib. + * + * Copyright (C) UENO Katsuhiro 2000-2003 + * + * $Id$ + */ + +#include <ruby.h> +#include <zlib.h> +#include <time.h> + +#define RUBY_ZLIB_VERSION "0.6.0" + + +#define OBJ_IS_FREED(val) (RBASIC(val)->flags == 0) + +#ifndef GZIP_SUPPORT +#define GZIP_SUPPORT 1 +#endif + +/* from zutil.h */ +#ifndef DEF_MEM_LEVEL +#if MAX_MEM_LEVEL >= 8 +#define DEF_MEM_LEVEL 8 +#else +#define DEF_MEM_LEVEL MAX_MEM_LEVEL +#endif +#endif + + + +/*--------- Prototypes --------*/ + +static NORETURN(void raise_zlib_error _((int, const char *))); +static VALUE rb_zlib_version _((VALUE)); +static VALUE do_checksum _((int, VALUE*, uLong (*) _((uLong, const Bytef*, uInt)))); +static VALUE rb_zlib_adler32 _((int, VALUE*, VALUE)); +static VALUE rb_zlib_crc32 _((int, VALUE*, VALUE)); +static VALUE rb_zlib_crc_table _((VALUE)); +static voidpf zlib_mem_alloc _((voidpf, uInt, uInt)); +static void zlib_mem_free _((voidpf, voidpf)); + +struct zstream; +struct zstream_funcs; +static void zstream_init _((struct zstream*, const struct zstream_funcs *)); +static void zstream_expand_buffer _((struct zstream*)); +static void zstream_expand_buffer_into _((struct zstream*, int)); +static void zstream_append_buffer _((struct zstream*, const char*, int)); +static VALUE zstream_detach_buffer _((struct zstream*)); +static VALUE zstream_shift_buffer _((struct zstream*, int)); +static void zstream_buffer_ungetc _((struct zstream*, int)); +static void zstream_append_input _((struct zstream*, const char*, unsigned int)); +static void zstream_discard_input _((struct zstream*, unsigned int)); +static void zstream_reset_input _((struct zstream*)); +static void zstream_passthrough_input _((struct zstream*)); +static VALUE zstream_detach_input _((struct zstream*)); +static void zstream_reset _((struct zstream*)); +static void zstream_end _((struct zstream*)); +static void zstream_run _((struct zstream*, Bytef*, uInt, int)); +static VALUE zstream_sync _((struct zstream*, Bytef*, uInt)); +static void zstream_mark _((struct zstream*)); +static void zstream_free _((struct zstream*)); +static VALUE zstream_new _((VALUE, const struct zstream_funcs*)); +static struct zstream *get_zstream _((VALUE)); + +static VALUE rb_zstream_end _((VALUE)); +static VALUE rb_zstream_reset _((VALUE)); +static VALUE rb_zstream_finish _((VALUE)); +static VALUE rb_zstream_flush_next_in _((VALUE)); +static VALUE rb_zstream_flush_next_out _((VALUE)); +static VALUE rb_zstream_avail_out _((VALUE)); +static VALUE rb_zstream_set_avail_out _((VALUE, VALUE)); +static VALUE rb_zstream_avail_in _((VALUE)); +static VALUE rb_zstream_total_in _((VALUE)); +static VALUE rb_zstream_total_out _((VALUE)); +static VALUE rb_zstream_data_type _((VALUE)); +static VALUE rb_zstream_adler _((VALUE)); +static VALUE rb_zstream_finished_p _((VALUE)); +static VALUE rb_zstream_closed_p _((VALUE)); + +static VALUE rb_deflate_s_allocate _((VALUE)); +static VALUE rb_deflate_initialize _((int, VALUE*, VALUE)); +static VALUE rb_deflate_clone _((VALUE)); +static VALUE rb_deflate_s_deflate _((int, VALUE*, VALUE)); +static void do_deflate _((struct zstream*, VALUE, int)); +static VALUE rb_deflate_deflate _((int, VALUE*, VALUE)); +static VALUE rb_deflate_addstr _((VALUE, VALUE)); +static VALUE rb_deflate_flush _((int, VALUE*, VALUE)); +static VALUE rb_deflate_params _((VALUE, VALUE, VALUE)); +static VALUE rb_deflate_set_dictionary _((VALUE, VALUE)); + +static VALUE rb_inflate_s_allocate _((VALUE)); +static VALUE rb_inflate_initialize _((int, VALUE*, VALUE)); +static VALUE rb_inflate_s_inflate _((VALUE, VALUE)); +static void do_inflate _((struct zstream*, VALUE)); +static VALUE rb_inflate_inflate _((VALUE, VALUE)); +static VALUE rb_inflate_addstr _((VALUE, VALUE)); +static VALUE rb_inflate_sync _((VALUE, VALUE)); +static VALUE rb_inflate_sync_point_p _((VALUE)); +static VALUE rb_inflate_set_dictionary _((VALUE, VALUE)); + +#if GZIP_SUPPORT +struct gzfile; +static void gzfile_mark _((struct gzfile*)); +static void gzfile_free _((struct gzfile*)); +static VALUE gzfile_new _((VALUE, const struct zstream_funcs*, void (*) _((struct gzfile*)))); +static void gzfile_reset _((struct gzfile*)); +static void gzfile_close _((struct gzfile*, int)); +static void gzfile_write_raw _((struct gzfile*)); +static VALUE gzfile_read_raw _((struct gzfile*)); +static int gzfile_read_raw_ensure _((struct gzfile*, int)); +static char *gzfile_read_raw_until_zero _((struct gzfile*, long)); +static unsigned int gzfile_get16 _((const unsigned char*)); +static unsigned long gzfile_get32 _((const unsigned char*)); +static void gzfile_set32 _((unsigned long n, unsigned char*)); +static void gzfile_make_header _((struct gzfile*)); +static void gzfile_make_footer _((struct gzfile*)); +static void gzfile_read_header _((struct gzfile*)); +static void gzfile_check_footer _((struct gzfile*)); +static void gzfile_write _((struct gzfile*, Bytef*, uInt)); +static long gzfile_read_more _((struct gzfile*)); +static VALUE gzfile_read _((struct gzfile*, int)); +static VALUE gzfile_read_all _((struct gzfile*)); +static void gzfile_ungetc _((struct gzfile*, int)); +static VALUE gzfile_finalize _((VALUE)); +static void gzfile_writer_end _((struct gzfile*)); +static void gzfile_reader_end _((struct gzfile*)); +static void gzfile_reader_rewind _((struct gzfile*)); +static VALUE gzfile_reader_get_unused _((struct gzfile*)); +static struct gzfile *get_gzfile _((VALUE)); +static VALUE gzfile_ensure_close _((VALUE)); +static VALUE rb_gzfile_s_wrap _((int, VALUE*, VALUE)); +static VALUE gzfile_s_open _((int, VALUE*, VALUE, const char*)); + +static VALUE rb_gzfile_to_io _((VALUE)); +static VALUE rb_gzfile_crc _((VALUE)); +static VALUE rb_gzfile_mtime _((VALUE)); +static VALUE rb_gzfile_level _((VALUE)); +static VALUE rb_gzfile_os_code _((VALUE)); +static VALUE rb_gzfile_orig_name _((VALUE)); +static VALUE rb_gzfile_comment _((VALUE)); +static VALUE rb_gzfile_lineno _((VALUE)); +static VALUE rb_gzfile_set_lineno _((VALUE, VALUE)); +static VALUE rb_gzfile_set_mtime _((VALUE, VALUE)); +static VALUE rb_gzfile_set_orig_name _((VALUE, VALUE)); +static VALUE rb_gzfile_set_comment _((VALUE, VALUE)); +static VALUE rb_gzfile_close _((VALUE)); +static VALUE rb_gzfile_finish _((VALUE)); +static VALUE rb_gzfile_closed_p _((VALUE)); +static VALUE rb_gzfile_eof_p _((VALUE)); +static VALUE rb_gzfile_sync _((VALUE)); +static VALUE rb_gzfile_set_sync _((VALUE, VALUE)); +static VALUE rb_gzfile_total_in _((VALUE)); +static VALUE rb_gzfile_total_out _((VALUE)); + +static VALUE rb_gzwriter_s_allocate _((VALUE)); +static VALUE rb_gzwriter_s_open _((int, VALUE*, VALUE)); +static VALUE rb_gzwriter_initialize _((int, VALUE*, VALUE)); +static VALUE rb_gzwriter_flush _((int, VALUE*, VALUE)); +static VALUE rb_gzwriter_write _((VALUE, VALUE)); +static VALUE rb_gzwriter_putc _((VALUE, VALUE)); + +static VALUE rb_gzreader_s_allocate _((VALUE)); +static VALUE rb_gzreader_s_open _((int, VALUE*, VALUE)); +static VALUE rb_gzreader_initialize _((VALUE, VALUE)); +static VALUE rb_gzreader_rewind _((VALUE)); +static VALUE rb_gzreader_unused _((VALUE)); +static VALUE rb_gzreader_read _((int, VALUE*, VALUE)); +static VALUE rb_gzreader_getc _((VALUE)); +static VALUE rb_gzreader_readchar _((VALUE)); +static VALUE rb_gzreader_each_byte _((VALUE)); +static VALUE rb_gzreader_ungetc _((VALUE, VALUE)); +static void gzreader_skip_linebreaks _((struct gzfile*)); +static VALUE gzreader_gets _((int, VALUE*, VALUE)); +static VALUE rb_gzreader_gets _((int, VALUE*, VALUE)); +static VALUE rb_gzreader_readline _((int, VALUE*, VALUE)); +static VALUE rb_gzreader_each _((int, VALUE*, VALUE)); +static VALUE rb_gzreader_readlines _((int, VALUE*, VALUE)); +#endif /* GZIP_SUPPORT */ + + +void Init_zlib _((void)); + + + +/*--------- Exceptions --------*/ + +static VALUE cZError, cStreamEnd, cNeedDict; +static VALUE cStreamError, cDataError, cMemError, cBufError, cVersionError; + +static void +raise_zlib_error(err, msg) + int err; + const char *msg; +{ + VALUE exc; + + if (!msg) { + msg = zError(err); + } + + switch(err) { + case Z_STREAM_END: + exc = rb_exc_new2(cStreamEnd, msg); + break; + case Z_NEED_DICT: + exc = rb_exc_new2(cNeedDict, msg); + break; + case Z_STREAM_ERROR: + exc = rb_exc_new2(cStreamError, msg); + break; + case Z_DATA_ERROR: + exc = rb_exc_new2(cDataError, msg); + break; + case Z_BUF_ERROR: + exc = rb_exc_new2(cBufError, msg); + break; + case Z_VERSION_ERROR: + exc = rb_exc_new2(cVersionError, msg); + break; + case Z_MEM_ERROR: + exc = rb_exc_new2(cMemError, msg); + break; + case Z_ERRNO: + rb_sys_fail(msg); + /* no return */ + default: + { + char buf[BUFSIZ]; + snprintf(buf, BUFSIZ, "unknown zlib error %d: %s", err, msg); + exc = rb_exc_new2(cZError, buf); + } + } + + rb_exc_raise(exc); +} + + + +/*-------- module Zlib --------*/ + +static VALUE +rb_zlib_version(klass) + VALUE klass; +{ + VALUE str; + + str = rb_str_new2(zlibVersion()); + OBJ_TAINT(str); /* for safe */ + return str; +} + +static VALUE +do_checksum(argc, argv, func) + int argc; + VALUE *argv; + uLong (*func) _((uLong, const Bytef *, uInt)); +{ + VALUE str, vsum; + unsigned long sum; + + rb_scan_args(argc, argv, "02", &str, &vsum); + + if (!NIL_P(vsum)) { + sum = NUM2ULONG(vsum); + } + else if (NIL_P(str)) { + sum = 0; + } + else { + sum = func(0, Z_NULL, 0); + } + + if (NIL_P(str)) { + sum = func(sum, Z_NULL, 0); + } + else { + StringValue(str); + sum = func(sum, RSTRING(str)->ptr, RSTRING(str)->len); + } + return rb_uint2inum(sum); +} + +static VALUE +rb_zlib_adler32(argc, argv, klass) + int argc; + VALUE *argv; + VALUE klass; +{ + return do_checksum(argc, argv, adler32); +} + +static VALUE +rb_zlib_crc32(argc, argv, klass) + int argc; + VALUE *argv; + VALUE klass; +{ + return do_checksum(argc, argv, crc32); +} + +static VALUE +rb_zlib_crc_table(obj) + VALUE obj; +{ + const unsigned long *crctbl; + VALUE dst; + int i; + + crctbl = get_crc_table(); + dst = rb_ary_new2(256); + + for (i = 0; i < 256; i++) { + rb_ary_push(dst, rb_uint2inum(crctbl[i])); + } + return dst; +} + + + +/*-------- zstream - internal APIs --------*/ + +struct zstream { + unsigned long flags; + VALUE buf; + long buf_filled; + VALUE input; + z_stream stream; + const struct zstream_funcs { + int (*reset) _((z_streamp)); + int (*end) _((z_streamp)); + int (*run) _((z_streamp, int)); + } *func; +}; + +#define ZSTREAM_FLAG_READY 0x1 +#define ZSTREAM_FLAG_IN_STREAM 0x2 +#define ZSTREAM_FLAG_FINISHED 0x4 +#define ZSTREAM_FLAG_FINALIZE 0x8 +#define ZSTREAM_FLAG_UNUSED 0x10 + +#define ZSTREAM_READY(z) ((z)->flags |= ZSTREAM_FLAG_READY) +#define ZSTREAM_IS_READY(z) ((z)->flags & ZSTREAM_FLAG_READY) +#define ZSTREAM_IS_FINISHED(z) ((z)->flags & ZSTREAM_FLAG_FINISHED) +#define ZSTREAM_IS_FINALIZE(z) ((z)->flags & ZSTREAM_FLAG_FINALIZE) + +/* I think that more better value should be found, + but I gave up finding it. B) */ +#define ZSTREAM_INITIAL_BUFSIZE 1024 +#define ZSTREAM_AVAIL_OUT_STEP_MAX 16384 +#define ZSTREAM_AVAIL_OUT_STEP_MIN 2048 + +static const struct zstream_funcs deflate_funcs = { + deflateReset, deflateEnd, deflate, +}; + +static const struct zstream_funcs inflate_funcs = { + inflateReset, inflateEnd, inflate, +}; + + +static voidpf +zlib_mem_alloc(opaque, items, size) + voidpf opaque; + uInt items, size; +{ + return xmalloc(items * size); +} + +static void +zlib_mem_free(opaque, address) + voidpf opaque, address; +{ + free(address); +} + +static void +zstream_init(z, func) + struct zstream *z; + const struct zstream_funcs *func; +{ + z->flags = 0; + z->buf = Qnil; + z->buf_filled = 0; + z->input = Qnil; + z->stream.zalloc = zlib_mem_alloc; + z->stream.zfree = zlib_mem_free; + z->stream.opaque = Z_NULL; + z->stream.msg = Z_NULL; + z->stream.next_in = Z_NULL; + z->stream.avail_in = 0; + z->stream.next_out = Z_NULL; + z->stream.avail_out = 0; + z->func = func; +} + +#define zstream_init_deflate(z) zstream_init((z), &deflate_funcs) +#define zstream_init_inflate(z) zstream_init((z), &inflate_funcs) + +static void +zstream_expand_buffer(z) + struct zstream *z; +{ + long inc; + + if (NIL_P(z->buf)) { + /* I uses rb_str_new here not rb_str_buf_new because + rb_str_buf_new makes a zero-length string. */ + z->buf = rb_str_new(0, ZSTREAM_INITIAL_BUFSIZE); + z->buf_filled = 0; + z->stream.next_out = RSTRING(z->buf)->ptr; + z->stream.avail_out = ZSTREAM_INITIAL_BUFSIZE; + return; + } + + if (RSTRING(z->buf)->len - z->buf_filled >= ZSTREAM_AVAIL_OUT_STEP_MAX) { + /* to keep other threads from freezing */ + z->stream.avail_out = ZSTREAM_AVAIL_OUT_STEP_MAX; + } + else { + inc = z->buf_filled / 2; + if (inc < ZSTREAM_AVAIL_OUT_STEP_MIN) { + inc = ZSTREAM_AVAIL_OUT_STEP_MIN; + } + rb_str_resize(z->buf, z->buf_filled + inc); + z->stream.avail_out = (inc < ZSTREAM_AVAIL_OUT_STEP_MAX) ? + inc : ZSTREAM_AVAIL_OUT_STEP_MAX; + } + z->stream.next_out = RSTRING(z->buf)->ptr + z->buf_filled; +} + +static void +zstream_expand_buffer_into(z, size) + struct zstream *z; + int size; +{ + if (NIL_P(z->buf)) { + /* I uses rb_str_new here not rb_str_buf_new because + rb_str_buf_new makes a zero-length string. */ + z->buf = rb_str_new(0, size); + z->buf_filled = 0; + z->stream.next_out = RSTRING(z->buf)->ptr; + z->stream.avail_out = size; + } + else if (z->stream.avail_out != size) { + rb_str_resize(z->buf, z->buf_filled + size); + z->stream.next_out = RSTRING(z->buf)->ptr + z->buf_filled; + z->stream.avail_out = size; + } +} + +static void +zstream_append_buffer(z, src, len) + struct zstream *z; + const char *src; + int len; +{ + if (NIL_P(z->buf)) { + z->buf = rb_str_buf_new(len); + rb_str_buf_cat(z->buf, src, len); + z->buf_filled = len; + z->stream.next_out = RSTRING(z->buf)->ptr; + z->stream.avail_out = 0; + return; + } + + if (RSTRING(z->buf)->len < z->buf_filled + len) { + rb_str_resize(z->buf, z->buf_filled + len); + z->stream.avail_out = 0; + } + else { + if (z->stream.avail_out >= len) { + z->stream.avail_out -= len; + } + else { + z->stream.avail_out = 0; + } + } + memcpy(RSTRING(z->buf)->ptr + z->buf_filled, src, len); + z->buf_filled += len; + z->stream.next_out = RSTRING(z->buf)->ptr + z->buf_filled; +} + +#define zstream_append_buffer2(z,v) \ + zstream_append_buffer((z),RSTRING(v)->ptr,RSTRING(v)->len) + +static VALUE +zstream_detach_buffer(z) + struct zstream *z; +{ + VALUE dst; + + if (NIL_P(z->buf)) { + dst = rb_str_new(0, 0); + } + else { + dst = z->buf; + rb_str_resize(dst, z->buf_filled); + } + + z->buf = Qnil; + z->buf_filled = 0; + z->stream.next_out = 0; + z->stream.avail_out = 0; + return dst; +} + +static VALUE +zstream_shift_buffer(z, len) + struct zstream *z; + int len; +{ + VALUE dst; + + if (z->buf_filled <= len) { + return zstream_detach_buffer(z); + } + + dst = rb_str_substr(z->buf, 0, len); + z->buf_filled -= len; + memmove(RSTRING(z->buf)->ptr, RSTRING(z->buf)->ptr + len, + z->buf_filled); + z->stream.next_out = RSTRING(z->buf)->ptr + z->buf_filled; + z->stream.avail_out = RSTRING(z->buf)->len - z->buf_filled; + if (z->stream.avail_out > ZSTREAM_AVAIL_OUT_STEP_MAX) { + z->stream.avail_out = ZSTREAM_AVAIL_OUT_STEP_MAX; + } + + return dst; +} + +static void +zstream_buffer_ungetc(z, c) + struct zstream *z; + int c; +{ + if (NIL_P(z->buf) || RSTRING(z->buf)->len - z->buf_filled == 0) { + zstream_expand_buffer(z); + } + + memmove(RSTRING(z->buf)->ptr + 1, RSTRING(z->buf)->ptr, z->buf_filled); + RSTRING(z->buf)->ptr[0] = (char)c; + z->buf_filled++; + if (z->stream.avail_out > 0) { + z->stream.next_out++; + z->stream.avail_out--; + } +} + +static void +zstream_append_input(z, src, len) + struct zstream *z; + const char *src; + unsigned int len; +{ + if (len <= 0) return; + + if (NIL_P(z->input)) { + z->input = rb_str_buf_new(len); + rb_str_buf_cat(z->input, src, len); + } + else { + rb_str_buf_cat(z->input, src, len); + } +} + +#define zstream_append_input2(z,v)\ + zstream_append_input((z), RSTRING(v)->ptr, RSTRING(v)->len) + +static void +zstream_discard_input(z, len) + struct zstream *z; + unsigned int len; +{ + if (NIL_P(z->input) || RSTRING(z->input)->len <= len) { + z->input = Qnil; + } + else { + memmove(RSTRING(z->input)->ptr, RSTRING(z->input)->ptr + len, + RSTRING(z->input)->len - len); + rb_str_resize(z->input, RSTRING(z->input)->len - len); + } +} + +static void +zstream_reset_input(z) + struct zstream *z; +{ + z->input = Qnil; +} + +static void +zstream_passthrough_input(z) + struct zstream *z; +{ + if (!NIL_P(z->input)) { + zstream_append_buffer2(z, z->input); + z->input = Qnil; + } +} + +static VALUE +zstream_detach_input(z) + struct zstream *z; +{ + VALUE dst; + + dst = NIL_P(z->input) ? rb_str_new(0, 0) : z->input; + z->input = Qnil; + return dst; +} + +static void +zstream_reset(z) + struct zstream *z; +{ + int err; + + err = z->func->reset(&z->stream); + if (err != Z_OK && !ZSTREAM_IS_FINALIZE(z)) { + raise_zlib_error(err, z->stream.msg); + } + z->flags = ZSTREAM_FLAG_READY; + z->buf = Qnil; + z->buf_filled = 0; + z->stream.next_out = 0; + z->stream.avail_out = 0; + zstream_reset_input(z); +} + +static void +zstream_end(z) + struct zstream *z; +{ + int err; + + if (!ZSTREAM_IS_READY(z) && !ZSTREAM_IS_FINALIZE(z)) { + if (RTEST(ruby_debug)) { + rb_warning("attempt to close uninitialized zstream; ignored."); + } + return; + } + if (z->flags & ZSTREAM_FLAG_IN_STREAM) { + if (RTEST(ruby_debug)) { + rb_warning("attempt to close unfinished zstream; reset forced."); + } + zstream_reset(z); + } + + zstream_reset_input(z); + err = z->func->end(&z->stream); + if (err != Z_OK && !ZSTREAM_IS_FINALIZE(z)) { + raise_zlib_error(err, z->stream.msg); + } + z->flags = 0; +} + +static void +zstream_run(z, src, len, flush) + struct zstream *z; + Bytef *src; + uInt len; + int flush; +{ + uInt n; + int err; + + if (NIL_P(z->input)) { + z->stream.next_in = src; + z->stream.avail_in = len; + } + else { + zstream_append_input(z, src, len); + z->stream.next_in = RSTRING(z->input)->ptr; + z->stream.avail_in = RSTRING(z->input)->len; + } + + if (z->stream.avail_out == 0) { + zstream_expand_buffer(z); + } + + for (;;) { + n = z->stream.avail_out; + err = z->func->run(&z->stream, flush); + z->buf_filled += n - z->stream.avail_out; + rb_thread_schedule(); + + if (err == Z_STREAM_END) { + z->flags &= ~ZSTREAM_FLAG_IN_STREAM; + z->flags |= ZSTREAM_FLAG_FINISHED; + break; + } + if (err != Z_OK) { + zstream_reset_input(z); + if (z->stream.avail_in > 0) { + zstream_append_input(z, z->stream.next_in, z->stream.avail_in); + } + raise_zlib_error(err, z->stream.msg); + } + if (z->stream.avail_out > 0) { + z->flags |= ZSTREAM_FLAG_IN_STREAM; + break; + } + zstream_expand_buffer(z); + } + + zstream_reset_input(z); + if (z->stream.avail_in > 0) { + zstream_append_input(z, z->stream.next_in, z->stream.avail_in); + } +} + +static VALUE +zstream_sync(z, src, len) + struct zstream *z; + Bytef *src; + uInt len; +{ + VALUE rest; + int err; + + if (!NIL_P(z->input)) { + z->stream.next_in = RSTRING(z->input)->ptr; + z->stream.avail_in = RSTRING(z->input)->len; + err = inflateSync(&z->stream); + if (err == Z_OK) { + zstream_discard_input(z, + RSTRING(z->input)->len - z->stream.avail_in); + zstream_append_input(z, src, len); + return Qtrue; + } + zstream_reset_input(z); + if (err != Z_DATA_ERROR) { + rest = rb_str_new(z->stream.next_in, z->stream.avail_in); + raise_zlib_error(err, z->stream.msg); + } + } + + if (len <= 0) return Qfalse; + + z->stream.next_in = src; + z->stream.avail_in = len; + err = inflateSync(&z->stream); + if (err == Z_OK) { + zstream_append_input(z, z->stream.next_in, z->stream.avail_in); + return Qtrue; + } + if (err != Z_DATA_ERROR) { + rest = rb_str_new(z->stream.next_in, z->stream.avail_in); + raise_zlib_error(err, z->stream.msg); + } + return Qfalse; +} + +static void +zstream_mark(z) + struct zstream *z; +{ + rb_gc_mark(z->buf); + rb_gc_mark(z->input); +} + +static void +zstream_free(z) + struct zstream *z; +{ + z->flags |= ZSTREAM_FLAG_FINALIZE; + zstream_end(z); + free(z); +} + +static VALUE +zstream_new(klass, funcs) + VALUE klass; + const struct zstream_funcs *funcs; +{ + VALUE obj; + struct zstream *z; + + obj = Data_Make_Struct(klass, struct zstream, + zstream_mark, zstream_free, z); + zstream_init(z, funcs); + return obj; +} + +#define zstream_deflate_new(klass) zstream_new((klass), &deflate_funcs) +#define zstream_inflate_new(klass) zstream_new((klass), &inflate_funcs) + +static struct zstream * +get_zstream(obj) + VALUE obj; +{ + struct zstream *z; + + Data_Get_Struct(obj, struct zstream, z); + if (!ZSTREAM_IS_READY(z)) { + rb_raise(cZError, "stream is not ready"); + } + return z; +} + + + +/*-------- class Zlib::ZStream ---------*/ + +static VALUE +rb_zstream_end(obj) + VALUE obj; +{ + zstream_end(get_zstream(obj)); + return Qnil; +} + +static VALUE +rb_zstream_reset(obj) + VALUE obj; +{ + zstream_reset(get_zstream(obj)); + return Qnil; +} + +static VALUE +rb_zstream_finish(obj) + VALUE obj; +{ + struct zstream *z = get_zstream(obj); + VALUE dst; + + zstream_run(z, "", 0, Z_FINISH); + dst = zstream_detach_buffer(z); + + OBJ_INFECT(dst, obj); + return dst; +} + +static VALUE +rb_zstream_flush_next_in(obj) + VALUE obj; +{ + struct zstream *z; + VALUE dst; + + Data_Get_Struct(obj, struct zstream, z); + dst = zstream_detach_input(z); + OBJ_INFECT(dst, obj); + return dst; +} + +static VALUE +rb_zstream_flush_next_out(obj) + VALUE obj; +{ + struct zstream *z; + VALUE dst; + + Data_Get_Struct(obj, struct zstream, z); + dst = zstream_detach_buffer(z); + OBJ_INFECT(dst, obj); + return dst; +} + +static VALUE +rb_zstream_avail_out(obj) + VALUE obj; +{ + struct zstream *z; + Data_Get_Struct(obj, struct zstream, z); + return rb_uint2inum(z->stream.avail_out); +} + +static VALUE +rb_zstream_set_avail_out(obj, size) + VALUE obj, size; +{ + struct zstream *z = get_zstream(obj); + + Check_Type(size, T_FIXNUM); + zstream_expand_buffer_into(z, FIX2INT(size)); + return size; +} + +static VALUE +rb_zstream_avail_in(obj) + VALUE obj; +{ + struct zstream *z; + Data_Get_Struct(obj, struct zstream, z); + return INT2FIX(NIL_P(z->input) ? 0 : (int)(RSTRING(z->input)->len)); +} + +static VALUE +rb_zstream_total_in(obj) + VALUE obj; +{ + return rb_uint2inum(get_zstream(obj)->stream.total_in); +} + +static VALUE +rb_zstream_total_out(obj) + VALUE obj; +{ + return rb_uint2inum(get_zstream(obj)->stream.total_out); +} + +static VALUE +rb_zstream_data_type(obj) + VALUE obj; +{ + return INT2FIX(get_zstream(obj)->stream.data_type); +} + +static VALUE +rb_zstream_adler(obj) + VALUE obj; +{ + return rb_uint2inum(get_zstream(obj)->stream.adler); +} + +static VALUE +rb_zstream_finished_p(obj) + VALUE obj; +{ + return ZSTREAM_IS_FINISHED(get_zstream(obj)) ? Qtrue : Qfalse; +} + +static VALUE +rb_zstream_closed_p(obj) + VALUE obj; +{ + struct zstream *z; + Data_Get_Struct(obj, struct zstream, z); + return ZSTREAM_IS_READY(z) ? Qfalse : Qtrue; +} + + + +/*-------- class Zlib::Deflate --------*/ + +#define FIXNUMARG(val, ifnil) \ + (NIL_P((val)) ? (ifnil) \ + : ((void)Check_Type((val), T_FIXNUM), FIX2INT((val)))) + +#define ARG_LEVEL(val) FIXNUMARG((val), Z_DEFAULT_COMPRESSION) +#define ARG_WBITS(val) FIXNUMARG((val), MAX_WBITS) +#define ARG_MEMLEVEL(val) FIXNUMARG((val), DEF_MEM_LEVEL) +#define ARG_STRATEGY(val) FIXNUMARG((val), Z_DEFAULT_STRATEGY) +#define ARG_FLUSH(val) FIXNUMARG((val), Z_NO_FLUSH) + + +static VALUE +rb_deflate_s_allocate(klass) + VALUE klass; +{ + return zstream_deflate_new(klass); +} + +static VALUE +rb_deflate_initialize(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + struct zstream *z; + VALUE level, wbits, memlevel, strategy; + int err; + + rb_scan_args(argc, argv, "04", &level, &wbits, &memlevel, &strategy); + Data_Get_Struct(obj, struct zstream, z); + + err = deflateInit2(&z->stream, ARG_LEVEL(level), Z_DEFLATED, + ARG_WBITS(wbits), ARG_MEMLEVEL(memlevel), + ARG_STRATEGY(strategy)); + if (err != Z_OK) { + raise_zlib_error(err, z->stream.msg); + } + ZSTREAM_READY(z); + + return obj; +} + +static VALUE +rb_deflate_clone(obj) + VALUE obj; +{ + struct zstream *z = get_zstream(obj); + struct zstream *z2; + VALUE clone; + int err; + + clone = zstream_deflate_new(rb_class_of(obj)); + Data_Get_Struct(clone, struct zstream, z2); + + err = deflateCopy(&z2->stream, &z->stream); + if (err != Z_OK) { + raise_zlib_error(err, 0); + } + + z2->flags = z->flags; + CLONESETUP(clone, obj); + OBJ_INFECT(clone, obj); + return clone; +} + +static VALUE +rb_deflate_s_deflate(argc, argv, klass) + int argc; + VALUE *argv; + VALUE klass; +{ + struct zstream z; + VALUE src, level, dst; + int err; + + rb_scan_args(argc, argv, "11", &src, &level); + + zstream_init_deflate(&z); + err = deflateInit(&z.stream, ARG_LEVEL(level)); + if (err != Z_OK) { + raise_zlib_error(err, z.stream.msg); + } + ZSTREAM_READY(&z); + + StringValue(src); + zstream_run(&z, RSTRING(src)->ptr, RSTRING(src)->len, Z_FINISH); + dst = zstream_detach_buffer(&z); + zstream_end(&z); + + OBJ_INFECT(dst, src); + return dst; +} + +static void +do_deflate(z, src, flush) + struct zstream *z; + VALUE src; + int flush; +{ + if (NIL_P(src)) { + zstream_run(z, "", 0, Z_FINISH); + return; + } + StringValue(src); + if (flush != Z_NO_FLUSH || RSTRING(src)->len > 0) { /* prevent BUF_ERROR */ + zstream_run(z, RSTRING(src)->ptr, RSTRING(src)->len, flush); + } +} + +static VALUE +rb_deflate_deflate(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + struct zstream *z = get_zstream(obj); + VALUE src, flush, dst; + + rb_scan_args(argc, argv, "11", &src, &flush); + OBJ_INFECT(obj, src); + do_deflate(z, src, ARG_FLUSH(flush)); + dst = zstream_detach_buffer(z); + + OBJ_INFECT(dst, obj); + return dst; +} + +static VALUE +rb_deflate_addstr(obj, src) + VALUE obj, src; +{ + OBJ_INFECT(obj, src); + do_deflate(get_zstream(obj), src, Z_NO_FLUSH); + return obj; +} + +static VALUE +rb_deflate_flush(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + struct zstream *z = get_zstream(obj); + VALUE v_flush, dst; + int flush; + + rb_scan_args(argc, argv, "01", &v_flush); + flush = FIXNUMARG(v_flush, Z_SYNC_FLUSH); + if (flush != Z_NO_FLUSH) { /* prevent Z_BUF_ERROR */ + zstream_run(z, "", 0, flush); + } + dst = zstream_detach_buffer(z); + + OBJ_INFECT(dst, obj); + return dst; +} + +static VALUE +rb_deflate_params(obj, v_level, v_strategy) + VALUE obj, v_level, v_strategy; +{ + struct zstream *z = get_zstream(obj); + int level, strategy; + int err; + + level = ARG_LEVEL(v_level); + strategy = ARG_STRATEGY(v_strategy); + + err = deflateParams(&z->stream, level, strategy); + while (err == Z_BUF_ERROR) { + if (RTEST(ruby_debug)) { + rb_warning("deflateParams() returned Z_BUF_ERROR"); + } + zstream_expand_buffer(z); + err = deflateParams(&z->stream, level, strategy); + } + if (err != Z_OK) { + raise_zlib_error(err, z->stream.msg); + } + + return Qnil; +} + +static VALUE +rb_deflate_set_dictionary(obj, dic) + VALUE obj, dic; +{ + struct zstream *z = get_zstream(obj); + VALUE src = dic; + int err; + + OBJ_INFECT(obj, dic); + StringValue(src); + err = deflateSetDictionary(&z->stream, + RSTRING(src)->ptr, RSTRING(src)->len); + if (err != Z_OK) { + raise_zlib_error(err, z->stream.msg); + } + + return dic; +} + + + +/*-------- class Zlib::Inflate --------*/ + +static VALUE +rb_inflate_s_allocate(klass) + VALUE klass; +{ + return zstream_inflate_new(klass); +} + +static VALUE +rb_inflate_initialize(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + struct zstream *z; + VALUE wbits; + int err; + + rb_scan_args(argc, argv, "01", &wbits); + Data_Get_Struct(obj, struct zstream, z); + + err = inflateInit2(&z->stream, ARG_WBITS(wbits)); + if (err != Z_OK) { + raise_zlib_error(err, z->stream.msg); + } + ZSTREAM_READY(z); + + return obj; +} + +static VALUE +rb_inflate_s_inflate(obj, src) + VALUE obj, src; +{ + struct zstream z; + VALUE dst; + int err; + + zstream_init_inflate(&z); + err = inflateInit(&z.stream); + if (err != Z_OK) { + raise_zlib_error(err, z.stream.msg); + } + ZSTREAM_READY(&z); + + StringValue(src); + zstream_run(&z, RSTRING(src)->ptr, RSTRING(src)->len, Z_SYNC_FLUSH); + zstream_run(&z, "", 0, Z_FINISH); /* for checking errors */ + dst = zstream_detach_buffer(&z); + zstream_end(&z); + + OBJ_INFECT(dst, src); + return dst; +} + +static void +do_inflate(z, src) + struct zstream *z; + VALUE src; +{ + if (NIL_P(src)) { + zstream_run(z, "", 0, Z_FINISH); + return; + } + StringValue(src); + if (RSTRING(src)->len > 0) { /* prevent Z_BUF_ERROR */ + zstream_run(z, RSTRING(src)->ptr, RSTRING(src)->len, Z_SYNC_FLUSH); + } +} + +static VALUE +rb_inflate_inflate(obj, src) + VALUE obj, src; +{ + struct zstream *z = get_zstream(obj); + VALUE dst; + + OBJ_INFECT(obj, src); + + if (ZSTREAM_IS_FINISHED(z)) { + if (NIL_P(src)) { + dst = zstream_detach_buffer(z); + } + else { + StringValue(src); + zstream_append_buffer2(z, src); + dst = rb_str_new(0, 0); + } + } + else { + do_inflate(z, src); + dst = zstream_detach_buffer(z); + if (ZSTREAM_IS_FINISHED(z)) { + zstream_passthrough_input(z); + } + } + + OBJ_INFECT(dst, obj); + return dst; +} + +static VALUE +rb_inflate_addstr(obj, src) + VALUE obj, src; +{ + struct zstream *z = get_zstream(obj); + + OBJ_INFECT(obj, src); + + if (ZSTREAM_IS_FINISHED(z)) { + if (!NIL_P(src)) { + StringValue(src); + zstream_append_buffer2(z, src); + } + } + else { + do_inflate(z, src); + if (ZSTREAM_IS_FINISHED(z)) { + zstream_passthrough_input(z); + } + } + + return obj; +} + +static VALUE +rb_inflate_sync(obj, src) + VALUE obj, src; +{ + struct zstream *z = get_zstream(obj); + + OBJ_INFECT(obj, src); + StringValue(src); + return zstream_sync(z, RSTRING(src)->ptr, RSTRING(src)->len); +} + +static VALUE +rb_inflate_sync_point_p(obj) + VALUE obj; +{ + struct zstream *z = get_zstream(obj); + int err; + + err = inflateSyncPoint(&z->stream); + if (err == 1) { + return Qtrue; + } + if (err != Z_OK) { + raise_zlib_error(err, z->stream.msg); + } + return Qfalse; +} + +static VALUE +rb_inflate_set_dictionary(obj, dic) + VALUE obj, dic; +{ + struct zstream *z = get_zstream(obj); + VALUE src = dic; + int err; + + OBJ_INFECT(obj, dic); + StringValue(src); + err = inflateSetDictionary(&z->stream, + RSTRING(src)->ptr, RSTRING(src)->len); + if (err != Z_OK) { + raise_zlib_error(err, z->stream.msg); + } + + return dic; +} + + + +#if GZIP_SUPPORT + +/* NOTE: Features for gzip files of Ruby/zlib are written from scratch + * and using undocumented feature of zlib, negative wbits. + * I don't think gzFile APIs of zlib are good for Ruby. + */ + +/*------- .gz file header --------*/ + +#define GZ_MAGIC1 0x1f +#define GZ_MAGIC2 0x8b +#define GZ_METHOD_DEFLATE 8 +#define GZ_FLAG_MULTIPART 0x2 +#define GZ_FLAG_EXTRA 0x4 +#define GZ_FLAG_ORIG_NAME 0x8 +#define GZ_FLAG_COMMENT 0x10 +#define GZ_FLAG_ENCRYPT 0x20 +#define GZ_FLAG_UNKNOWN_MASK 0xc0 + +#define GZ_EXTRAFLAG_FAST 0x4 +#define GZ_EXTRAFLAG_SLOW 0x2 + +/* from zutil.h */ +#define OS_MSDOS 0x00 +#define OS_AMIGA 0x01 +#define OS_VMS 0x02 +#define OS_UNIX 0x03 +#define OS_ATARI 0x05 +#define OS_OS2 0x06 +#define OS_MACOS 0x07 +#define OS_TOPS20 0x0a +#define OS_WIN32 0x0b + +#define OS_VMCMS 0x04 +#define OS_ZSYSTEM 0x08 +#define OS_CPM 0x09 +#define OS_QDOS 0x0c +#define OS_RISCOS 0x0d +#define OS_UNKNOWN 0xff + +#ifndef OS_CODE +#define OS_CODE OS_UNIX +#endif + +static ID id_write, id_read, id_flush, id_seek, id_close; +static VALUE cGzError, cNoFooter, cCRCError, cLengthError; + + + +/*-------- gzfile internal APIs --------*/ + +struct gzfile { + struct zstream z; + VALUE io; + int level; + time_t mtime; /* for header */ + int os_code; /* for header */ + VALUE orig_name; /* for header; must be a String */ + VALUE comment; /* for header; must be a String */ + unsigned long crc; + int lineno; + int ungetc; + void (*end)(struct gzfile *); +}; + +#define GZFILE_FLAG_SYNC ZSTREAM_FLAG_UNUSED +#define GZFILE_FLAG_HEADER_FINISHED (ZSTREAM_FLAG_UNUSED << 1) +#define GZFILE_FLAG_FOOTER_FINISHED (ZSTREAM_FLAG_UNUSED << 2) + +#define GZFILE_IS_FINISHED(gz) \ + (ZSTREAM_IS_FINISHED(&gz->z) && (gz)->z.buf_filled == 0) + +#define GZFILE_READ_SIZE 2048 + + +static void +gzfile_mark(gz) + struct gzfile *gz; +{ + rb_gc_mark(gz->io); + rb_gc_mark(gz->orig_name); + rb_gc_mark(gz->comment); + zstream_mark(&gz->z); +} + +static void +gzfile_free(gz) + struct gzfile *gz; +{ + gz->z.flags |= ZSTREAM_FLAG_FINALIZE; + if (ZSTREAM_IS_READY(&gz->z)) { + gz->end(gz); + } + free(gz); +} + +static VALUE +gzfile_new(klass, funcs, endfunc) + VALUE klass; + const struct zstream_funcs *funcs; + void (*endfunc) _((struct gzfile *)); +{ + VALUE obj; + struct gzfile *gz; + + obj = Data_Make_Struct(klass, struct gzfile, gzfile_mark, gzfile_free, gz); + zstream_init(&gz->z, funcs); + gz->io = Qnil; + gz->level = 0; + gz->mtime = 0; + gz->os_code = OS_CODE; + gz->orig_name = Qnil; + gz->comment = Qnil; + gz->crc = crc32(0, Z_NULL, 0); + gz->lineno = 0; + gz->ungetc = 0; + gz->end = endfunc; + + return obj; +} + +#define gzfile_writer_new(gz) gzfile_new((gz),&deflate_funcs,gzfile_writer_end) +#define gzfile_reader_new(gz) gzfile_new((gz),&inflate_funcs,gzfile_reader_end) + +static void +gzfile_reset(gz) + struct gzfile *gz; +{ + zstream_reset(&gz->z); + gz->crc = crc32(0, Z_NULL, 0); + gz->lineno = 0; + gz->ungetc = 0; +} + +static void +gzfile_close(gz, closeflag) + struct gzfile *gz; + int closeflag; +{ + VALUE io = gz->io; + gz->end(gz); + gz->io = Qnil; + gz->orig_name = Qnil; + gz->comment = Qnil; + if (closeflag && rb_respond_to(io, id_close)) { + rb_funcall(io, id_close, 0); + } +} + +static void +gzfile_write_raw(gz) + struct gzfile *gz; +{ + VALUE str; + + if (gz->z.buf_filled > 0) { + str = zstream_detach_buffer(&gz->z); + OBJ_TAINT(str); /* for safe */ + rb_funcall(gz->io, id_write, 1, str); + if ((gz->z.flags & GZFILE_FLAG_SYNC) + && rb_respond_to(gz->io, id_flush)) + rb_funcall(gz->io, id_flush, 0); + } +} + +static VALUE +gzfile_read_raw(gz) + struct gzfile *gz; +{ + VALUE str; + + str = rb_funcall(gz->io, id_read, 1, INT2FIX(GZFILE_READ_SIZE)); + if (!NIL_P(str)) { + Check_Type(str, T_STRING); + } + return str; +} + +static int +gzfile_read_raw_ensure(gz, size) + struct gzfile *gz; + int size; +{ + VALUE str; + + while (NIL_P(gz->z.input) || RSTRING(gz->z.input)->len < size) { + str = gzfile_read_raw(gz); + if (NIL_P(str)) return Qfalse; + zstream_append_input2(&gz->z, str); + } + return Qtrue; +} + +static char * +gzfile_read_raw_until_zero(gz, offset) + struct gzfile *gz; + long offset; +{ + VALUE str; + char *p; + + for (;;) { + p = memchr(RSTRING(gz->z.input)->ptr + offset, '\0', + RSTRING(gz->z.input)->len - offset); + if (p) break; + str = gzfile_read_raw(gz); + if (NIL_P(str)) { + rb_raise(cGzError, "unexpected end of file"); + } + offset = RSTRING(gz->z.input)->len; + zstream_append_input2(&gz->z, str); + } + return p; +} + +static unsigned int +gzfile_get16(src) + const unsigned char *src; +{ + unsigned int n; + n = *(src++) & 0xff; + n |= (*(src++) & 0xff) << 8; + return n; +} + +static unsigned long +gzfile_get32(src) + const unsigned char *src; +{ + unsigned long n; + n = *(src++) & 0xff; + n |= (*(src++) & 0xff) << 8; + n |= (*(src++) & 0xff) << 16; + n |= (*(src++) & 0xff) << 24; + return n; +} + +static void +gzfile_set32(n, dst) + unsigned long n; + unsigned char *dst; +{ + *(dst++) = n & 0xff; + *(dst++) = (n >> 8) & 0xff; + *(dst++) = (n >> 16) & 0xff; + *dst = (n >> 24) & 0xff; +} + +static void +gzfile_make_header(gz) + struct gzfile *gz; +{ + unsigned char buf[10]; /* the size of gzip header */ + unsigned char flags = 0, extraflags = 0; + + if (!NIL_P(gz->orig_name)) { + flags |= GZ_FLAG_ORIG_NAME; + } + if (!NIL_P(gz->comment)) { + flags |= GZ_FLAG_COMMENT; + } + if (gz->mtime == 0) { + gz->mtime = time(0); + } + + if (gz->level == Z_BEST_SPEED) { + extraflags |= GZ_EXTRAFLAG_FAST; + } + else if (gz->level == Z_BEST_COMPRESSION) { + extraflags |= GZ_EXTRAFLAG_SLOW; + } + + buf[0] = GZ_MAGIC1; + buf[1] = GZ_MAGIC2; + buf[2] = GZ_METHOD_DEFLATE; + buf[3] = flags; + gzfile_set32(gz->mtime, &buf[4]); + buf[8] = extraflags; + buf[9] = gz->os_code; + zstream_append_buffer(&gz->z, buf, sizeof(buf)); + + if (!NIL_P(gz->orig_name)) { + zstream_append_buffer2(&gz->z, gz->orig_name); + zstream_append_buffer(&gz->z, "\0", 1); + } + if (!NIL_P(gz->comment)) { + zstream_append_buffer2(&gz->z, gz->comment); + zstream_append_buffer(&gz->z, "\0", 1); + } + + gz->z.flags |= GZFILE_FLAG_HEADER_FINISHED; +} + +static void +gzfile_make_footer(gz) + struct gzfile *gz; +{ + unsigned char buf[8]; /* 8 is the size of gzip footer */ + + gzfile_set32(gz->crc, buf); + gzfile_set32(gz->z.stream.total_in, &buf[4]); + zstream_append_buffer(&gz->z, buf, sizeof(buf)); + gz->z.flags |= GZFILE_FLAG_FOOTER_FINISHED; +} + +static void +gzfile_read_header(gz) + struct gzfile *gz; +{ + const unsigned char *head; + long len; + char flags, *p; + + if (!gzfile_read_raw_ensure(gz, 10)) { /* 10 is the size of gzip header */ + rb_raise(cGzError, "not in gzip format"); + } + + head = RSTRING(gz->z.input)->ptr; + + if (head[0] != GZ_MAGIC1 || head[1] != GZ_MAGIC2) { + rb_raise(cGzError, "not in gzip format"); + } + if (head[2] != GZ_METHOD_DEFLATE) { + rb_raise(cGzError, "unsupported compression method %d", head[2]); + } + + flags = head[3]; + if (flags & GZ_FLAG_MULTIPART) { + rb_raise(cGzError, "multi-part gzip file is not supported"); + } + else if (flags & GZ_FLAG_ENCRYPT) { + rb_raise(cGzError, "encrypted gzip file is not supported"); + } + else if (flags & GZ_FLAG_UNKNOWN_MASK) { + rb_raise(cGzError, "unknown flags 0x%02x", flags); + } + + if (head[8] & GZ_EXTRAFLAG_FAST) { + gz->level = Z_BEST_SPEED; + } + else if (head[8] & GZ_EXTRAFLAG_SLOW) { + gz->level = Z_BEST_COMPRESSION; + } + else { + gz->level = Z_DEFAULT_COMPRESSION; + } + + gz->mtime = gzfile_get32(&head[4]); + gz->os_code = head[9]; + zstream_discard_input(&gz->z, 10); + + if (flags & GZ_FLAG_EXTRA) { + if (!gzfile_read_raw_ensure(gz, 2)) { + rb_raise(cGzError, "unexpected end of file"); + } + len = gzfile_get16(RSTRING(gz->z.input)->ptr); + if (!gzfile_read_raw_ensure(gz, 2 + len)) { + rb_raise(cGzError, "unexpected end of file"); + } + zstream_discard_input(&gz->z, 2 + len); + } + if (flags & GZ_FLAG_ORIG_NAME) { + p = gzfile_read_raw_until_zero(gz, 0); + len = p - RSTRING(gz->z.input)->ptr; + gz->orig_name = rb_str_new(RSTRING(gz->z.input)->ptr, len); + OBJ_TAINT(gz->orig_name); /* for safe */ + zstream_discard_input(&gz->z, len + 1); + } + if (flags & GZ_FLAG_COMMENT) { + p = gzfile_read_raw_until_zero(gz, 0); + len = p - RSTRING(gz->z.input)->ptr; + gz->comment = rb_str_new(RSTRING(gz->z.input)->ptr, len); + OBJ_TAINT(gz->comment); /* for safe */ + zstream_discard_input(&gz->z, len + 1); + } + + if (RSTRING(gz->z.input)->len > 0) { + zstream_run(&gz->z, 0, 0, Z_SYNC_FLUSH); + } +} + +static void +gzfile_check_footer(gz) + struct gzfile *gz; +{ + unsigned long crc, length; + + gz->z.flags |= GZFILE_FLAG_FOOTER_FINISHED; + + if (!gzfile_read_raw_ensure(gz, 8)) { /* 8 is the size of gzip footer */ + rb_raise(cNoFooter, "footer is not found"); + } + + crc = gzfile_get32(RSTRING(gz->z.input)->ptr); + length = gzfile_get32(RSTRING(gz->z.input)->ptr + 4); + + gz->z.stream.total_in += 8; /* to rewind correctly */ + zstream_discard_input(&gz->z, 8); + + if (gz->crc != crc) { + rb_raise(cCRCError, "invalid compressed data -- crc error"); + } + if (gz->z.stream.total_out != length) { + rb_raise(cLengthError, "invalid compressed data -- length error"); + } +} + +static void +gzfile_write(gz, str, len) + struct gzfile *gz; + Bytef *str; + uInt len; +{ + if (!(gz->z.flags & GZFILE_FLAG_HEADER_FINISHED)) { + gzfile_make_header(gz); + } + + if (len > 0 || (gz->z.flags & GZFILE_FLAG_SYNC)) { + gz->crc = crc32(gz->crc, str, len); + zstream_run(&gz->z, str, len, (gz->z.flags & GZFILE_FLAG_SYNC) + ? Z_SYNC_FLUSH : Z_NO_FLUSH); + } + gzfile_write_raw(gz); +} + +static long +gzfile_read_more(gz) + struct gzfile *gz; +{ + VALUE str; + + while (!ZSTREAM_IS_FINISHED(&gz->z)) { + str = gzfile_read_raw(gz); + if (NIL_P(str)) { + if (!ZSTREAM_IS_FINISHED(&gz->z)) { + rb_raise(cGzError, "unexpected end of file"); + } + break; + } + if (RSTRING(str)->len > 0) { /* prevent Z_BUF_ERROR */ + zstream_run(&gz->z, RSTRING(str)->ptr, RSTRING(str)->len, + Z_SYNC_FLUSH); + } + if (gz->z.buf_filled > 0) break; + } + return gz->z.buf_filled; +} + +static VALUE +gzfile_read(gz, len) + struct gzfile *gz; + int len; +{ + VALUE dst; + + if (len <= 0) return Qnil; + while (!ZSTREAM_IS_FINISHED(&gz->z) && gz->z.buf_filled < len) { + gzfile_read_more(gz); + } + if (GZFILE_IS_FINISHED(gz)) { + if (!(gz->z.flags & GZFILE_FLAG_FOOTER_FINISHED)) { + gzfile_check_footer(gz); + } + return Qnil; + } + + dst = zstream_shift_buffer(&gz->z, len); + if (RSTRING(dst)->len <= gz->ungetc) { + gz->ungetc -= RSTRING(dst)->len; + } + else { + gz->crc = crc32(gz->crc, RSTRING(dst)->ptr + gz->ungetc, + RSTRING(dst)->len - gz->ungetc); + } + + OBJ_TAINT(dst); /* for safe */ + return dst; +} + +static VALUE +gzfile_read_all(gz) + struct gzfile *gz; +{ + VALUE dst; + + while (!ZSTREAM_IS_FINISHED(&gz->z)) { + gzfile_read_more(gz); + } + if (GZFILE_IS_FINISHED(gz)) { + if (!(gz->z.flags & GZFILE_FLAG_FOOTER_FINISHED)) { + gzfile_check_footer(gz); + } + return Qnil; + } + + dst = zstream_detach_buffer(&gz->z); + if (RSTRING(dst)->len <= gz->ungetc) { + gz->ungetc -= RSTRING(dst)->len; + } + else { + gz->crc = crc32(gz->crc, RSTRING(dst)->ptr + gz->ungetc, + RSTRING(dst)->len - gz->ungetc); + } + + OBJ_TAINT(dst); /* for safe */ + return dst; +} + +static void +gzfile_ungetc(gz, c) + struct gzfile *gz; + int c; +{ + zstream_buffer_ungetc(&gz->z, c); + gz->ungetc++; +} + +static VALUE +gzfile_finalize(obj) + VALUE obj; +{ + struct gzfile *gz = (struct gzfile *)obj; + gzfile_write_raw(gz); + return Qnil; +} + +static void +gzfile_writer_end(gz) + struct gzfile *gz; +{ + int aborted; + + if (!(gz->z.flags & GZFILE_FLAG_HEADER_FINISHED)) { + gzfile_make_header(gz); + } + + zstream_run(&gz->z, "", 0, Z_FINISH); + gzfile_make_footer(gz); + + if (ZSTREAM_IS_FINALIZE(&gz->z)) { + rb_warn("Zlib::GzipWriter object must be closed explicitly."); + if (OBJ_IS_FREED(gz->io)) { + aborted = 1; + } + else { + rb_protect(gzfile_finalize, (VALUE)gz, &aborted); + } + if (aborted) { + rb_warn("gzip footer is not written; broken gzip file"); + } + zstream_end(&gz->z); + return; + } + gzfile_write_raw(gz); + zstream_end(&gz->z); +} + +static void +gzfile_reader_end(gz) + struct gzfile *gz; +{ + if (GZFILE_IS_FINISHED(gz) + && !ZSTREAM_IS_FINALIZE(&gz->z) + && !(gz->z.flags & GZFILE_FLAG_FOOTER_FINISHED)) { + gzfile_check_footer(gz); + } + + zstream_end(&gz->z); +} + +static void +gzfile_reader_rewind(gz) + struct gzfile *gz; +{ + long n; + + n = gz->z.stream.total_in; + if (!NIL_P(gz->z.input)) { + n += RSTRING(gz->z.input)->len; + } + + rb_funcall(gz->io, id_seek, 2, rb_int2inum(-n), INT2FIX(1)); + gzfile_reset(gz); +} + +static VALUE +gzfile_reader_get_unused(gz) + struct gzfile *gz; +{ + VALUE str; + + if (!ZSTREAM_IS_READY(&gz->z)) return Qnil; + if (!GZFILE_IS_FINISHED(gz)) return Qnil; + if (!(gz->z.flags & GZFILE_FLAG_FOOTER_FINISHED)) { + gzfile_check_footer(gz); + } + if (NIL_P(gz->z.input)) return Qnil; + + str = rb_str_dup(gz->z.input); + OBJ_TAINT(str); /* for safe */ + return str; +} + +static struct gzfile * +get_gzfile(obj) + VALUE obj; +{ + struct gzfile *gz; + + Data_Get_Struct(obj, struct gzfile, gz); + if (!ZSTREAM_IS_READY(&gz->z)) { + rb_raise(cGzError, "closed gzip stream"); + } + return gz; +} + + + +/*-------- class Zlib::GzipFile --------*/ + +static VALUE +gzfile_ensure_close(obj) + VALUE obj; +{ + struct gzfile *gz; + + Data_Get_Struct(obj, struct gzfile, gz); + if (ZSTREAM_IS_READY(&gz->z)) { + gzfile_close(gz, 1); + } + return Qnil; +} + +static VALUE +rb_gzfile_s_wrap(argc, argv, klass) + int argc; + VALUE *argv; + VALUE klass; +{ + VALUE obj = rb_class_new_instance(argc, argv, klass); + + if (rb_block_given_p()) { + return rb_ensure(rb_yield, obj, gzfile_ensure_close, obj); + } + else { + return obj; + } +} + +static VALUE +gzfile_s_open(argc, argv, klass, mode) + int argc; + VALUE *argv; + VALUE klass; + const char *mode; +{ + VALUE io, filename; + + if (argc < 1) { + rb_raise(rb_eArgError, "wrong number of arguments (0 for 1)"); + } + filename = argv[0]; + SafeStringValue(filename); + io = rb_file_open(RSTRING(filename)->ptr, mode); + + argv[0] = io; + return rb_gzfile_s_wrap(argc, argv, klass); +} + +static VALUE +rb_gzfile_to_io(obj) + VALUE obj; +{ + return get_gzfile(obj)->io; +} + +static VALUE +rb_gzfile_crc(obj) + VALUE obj; +{ + return rb_uint2inum(get_gzfile(obj)->crc); +} + +static VALUE +rb_gzfile_mtime(obj) + VALUE obj; +{ + return rb_time_new(get_gzfile(obj)->mtime, (time_t)0); +} + +static VALUE +rb_gzfile_level(obj) + VALUE obj; +{ + return INT2FIX(get_gzfile(obj)->level); +} + +static VALUE +rb_gzfile_os_code(obj) + VALUE obj; +{ + return INT2FIX(get_gzfile(obj)->os_code); +} + +static VALUE +rb_gzfile_orig_name(obj) + VALUE obj; +{ + VALUE str = get_gzfile(obj)->orig_name; + if (!NIL_P(str)) { + str = rb_str_dup(str); + } + OBJ_TAINT(str); /* for safe */ + return str; +} + +static VALUE +rb_gzfile_comment(obj) + VALUE obj; +{ + VALUE str = get_gzfile(obj)->comment; + if (!NIL_P(str)) { + str = rb_str_dup(str); + } + OBJ_TAINT(str); /* for safe */ + return str; +} + +static VALUE +rb_gzfile_lineno(obj) + VALUE obj; +{ + return INT2NUM(get_gzfile(obj)->lineno); +} + +static VALUE +rb_gzfile_set_lineno(obj, lineno) + VALUE obj, lineno; +{ + struct gzfile *gz = get_gzfile(obj); + gz->lineno = NUM2INT(lineno); + return lineno; +} + +static VALUE +rb_gzfile_set_mtime(obj, mtime) + VALUE obj, mtime; +{ + struct gzfile *gz = get_gzfile(obj); + VALUE val; + + if (gz->z.flags & GZFILE_FLAG_HEADER_FINISHED) { + rb_raise(cGzError, "header is already written"); + } + + if (FIXNUM_P(time)) { + gz->mtime = FIX2INT(mtime); + } + else { + val = rb_Integer(mtime); + gz->mtime = FIXNUM_P(val) ? FIX2INT(val) : rb_big2ulong(val); + } + return mtime; +} + +static VALUE +rb_gzfile_set_orig_name(obj, str) + VALUE obj, str; +{ + struct gzfile *gz = get_gzfile(obj); + VALUE s; + char *p; + + if (gz->z.flags & GZFILE_FLAG_HEADER_FINISHED) { + rb_raise(cGzError, "header is already written"); + } + s = rb_str_dup(rb_str_to_str(str)); + p = memchr(RSTRING(s)->ptr, '\0', RSTRING(s)->len); + if (p) { + rb_str_resize(s, p - RSTRING(s)->ptr); + } + gz->orig_name = s; + return str; +} + +static VALUE +rb_gzfile_set_comment(obj, str) + VALUE obj, str; +{ + struct gzfile *gz = get_gzfile(obj); + VALUE s; + char *p; + + if (gz->z.flags & GZFILE_FLAG_HEADER_FINISHED) { + rb_raise(cGzError, "header is already written"); + } + s = rb_str_dup(rb_str_to_str(str)); + p = memchr(RSTRING(s)->ptr, '\0', RSTRING(s)->len); + if (p) { + rb_str_resize(s, p - RSTRING(s)->ptr); + } + gz->comment = s; + return str; +} + +static VALUE +rb_gzfile_close(obj) + VALUE obj; +{ + struct gzfile *gz = get_gzfile(obj); + VALUE io; + + io = gz->io; + gzfile_close(gz, 1); + return io; +} + +static VALUE +rb_gzfile_finish(obj) + VALUE obj; +{ + struct gzfile *gz = get_gzfile(obj); + VALUE io; + + io = gz->io; + gzfile_close(gz, 0); + return io; +} + +static VALUE +rb_gzfile_closed_p(obj) + VALUE obj; +{ + struct gzfile *gz; + Data_Get_Struct(obj, struct gzfile, gz); + return NIL_P(gz->io) ? Qtrue : Qfalse; +} + +static VALUE +rb_gzfile_eof_p(obj) + VALUE obj; +{ + struct gzfile *gz = get_gzfile(obj); + return GZFILE_IS_FINISHED(gz) ? Qtrue : Qfalse; +} + +static VALUE +rb_gzfile_sync(obj) + VALUE obj; +{ + return (get_gzfile(obj)->z.flags & GZFILE_FLAG_SYNC) ? Qtrue : Qfalse; +} + +static VALUE +rb_gzfile_set_sync(obj, mode) + VALUE obj, mode; +{ + struct gzfile *gz = get_gzfile(obj); + + if (RTEST(mode)) { + gz->z.flags |= GZFILE_FLAG_SYNC; + } + else { + gz->z.flags &= ~GZFILE_FLAG_SYNC; + } + return mode; +} + +static VALUE +rb_gzfile_total_in(obj) + VALUE obj; +{ + return rb_uint2inum(get_gzfile(obj)->z.stream.total_in); +} + +static VALUE +rb_gzfile_total_out(obj) + VALUE obj; +{ + struct gzfile *gz = get_gzfile(obj); + return rb_uint2inum(gz->z.stream.total_out - gz->z.buf_filled); +} + + + +/*-------- class Zlib::GzipWriter --------*/ + +static VALUE +rb_gzwriter_s_allocate(klass) + VALUE klass; +{ + return gzfile_writer_new(klass); +} + +static VALUE +rb_gzwriter_s_open(argc, argv, klass) + int argc; + VALUE *argv; + VALUE klass; +{ + return gzfile_s_open(argc, argv, klass, "wb"); +} + +static VALUE +rb_gzwriter_initialize(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + struct gzfile *gz; + VALUE io, level, strategy; + int err; + + rb_scan_args(argc, argv, "12", &io, &level, &strategy); + Data_Get_Struct(obj, struct gzfile, gz); + + /* this is undocumented feature of zlib */ + gz->level = ARG_LEVEL(level); + err = deflateInit2(&gz->z.stream, gz->level, Z_DEFLATED, + -MAX_WBITS, DEF_MEM_LEVEL, ARG_STRATEGY(strategy)); + if (err != Z_OK) { + raise_zlib_error(err, gz->z.stream.msg); + } + gz->io = io; + ZSTREAM_READY(&gz->z); + + return obj; +} + +static VALUE +rb_gzwriter_flush(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + struct gzfile *gz = get_gzfile(obj); + VALUE v_flush; + int flush; + + rb_scan_args(argc, argv, "01", &v_flush); + + flush = FIXNUMARG(v_flush, Z_SYNC_FLUSH); + if (flush != Z_NO_FLUSH) { /* prevent Z_BUF_ERROR */ + zstream_run(&gz->z, "", 0, flush); + } + + gzfile_write_raw(gz); + if (rb_respond_to(gz->io, id_flush)) { + rb_funcall(gz->io, id_flush, 0); + } + return obj; +} + +static VALUE +rb_gzwriter_write(obj, str) + VALUE obj, str; +{ + struct gzfile *gz = get_gzfile(obj); + + if (TYPE(str) != T_STRING) { + str = rb_obj_as_string(str); + } + gzfile_write(gz, RSTRING(str)->ptr, RSTRING(str)->len); + return INT2FIX(RSTRING(str)->len); +} + +static VALUE +rb_gzwriter_putc(obj, ch) + VALUE obj, ch; +{ + struct gzfile *gz = get_gzfile(obj); + char c = NUM2CHR(ch); + + gzfile_write(gz, &c, 1); + return ch; +} + +#define rb_gzwriter_addstr rb_io_addstr +#define rb_gzwriter_printf rb_io_printf +#define rb_gzwriter_print rb_io_print +#define rb_gzwriter_puts rb_io_puts + + +/*-------- class Zlib::GzipReader --------*/ + +static VALUE +rb_gzreader_s_allocate(klass) + VALUE klass; +{ + return gzfile_reader_new(klass); +} + +static VALUE +rb_gzreader_s_open(argc, argv, klass) + int argc; + VALUE *argv; + VALUE klass; +{ + return gzfile_s_open(argc, argv, klass, "rb"); +} + +static VALUE +rb_gzreader_initialize(obj, io) + VALUE obj, io; +{ + struct gzfile *gz; + int err; + + Data_Get_Struct(obj, struct gzfile, gz); + + /* this is undocumented feature of zlib */ + err = inflateInit2(&gz->z.stream, -MAX_WBITS); + if (err != Z_OK) { + raise_zlib_error(err, gz->z.stream.msg); + } + gz->io = io; + ZSTREAM_READY(&gz->z); + gzfile_read_header(gz); + + return obj; +} + +static VALUE +rb_gzreader_rewind(obj) + VALUE obj; +{ + struct gzfile *gz = get_gzfile(obj); + gzfile_reader_rewind(gz); + return INT2FIX(0); +} + +static VALUE +rb_gzreader_unused(obj) + VALUE obj; +{ + struct gzfile *gz; + Data_Get_Struct(obj, struct gzfile, gz); + return gzfile_reader_get_unused(gz); +} + +static VALUE +rb_gzreader_read(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + struct gzfile *gz = get_gzfile(obj); + VALUE vlen; + int len; + + rb_scan_args(argc, argv, "01", &vlen); + if (NIL_P(vlen)) { + return gzfile_read_all(gz); + } + + len = NUM2INT(vlen); + if (len < 0) { + rb_raise(rb_eArgError, "negative length %d given", len); + } + return gzfile_read(gz, len); +} + +static VALUE +rb_gzreader_getc(obj) + VALUE obj; +{ + struct gzfile *gz = get_gzfile(obj); + VALUE dst; + + dst = gzfile_read(gz, 1); + if (!NIL_P(dst)) { + dst = INT2FIX(RSTRING(dst)->ptr[0]); + } + return dst; +} + +static VALUE +rb_gzreader_readchar(obj) + VALUE obj; +{ + VALUE dst; + dst = rb_gzreader_getc(obj); + if (NIL_P(dst)) { + rb_raise(rb_eEOFError, "End of file reached"); + } + return dst; +} + +static VALUE +rb_gzreader_each_byte(obj) + VALUE obj; +{ + VALUE c; + while (!NIL_P(c = rb_gzreader_getc(obj))) { + rb_yield(c); + } + return Qnil; +} + +static VALUE +rb_gzreader_ungetc(obj, ch) + VALUE obj, ch; +{ + struct gzfile *gz = get_gzfile(obj); + gzfile_ungetc(gz, NUM2CHR(ch)); + return Qnil; +} + +static void +gzreader_skip_linebreaks(gz) + struct gzfile *gz; +{ + VALUE str; + char *p; + int n; + + while (gz->z.buf_filled == 0) { + if (GZFILE_IS_FINISHED(gz)) return; + gzfile_read_more(gz); + } + n = 0; + p = RSTRING(gz->z.buf)->ptr; + + while (n++, *(p++) == '\n') { + if (n >= gz->z.buf_filled) { + str = zstream_detach_buffer(&gz->z); + gz->crc = crc32(gz->crc, RSTRING(str)->ptr, + RSTRING(str)->len); + while (gz->z.buf_filled == 0) { + if (GZFILE_IS_FINISHED(gz)) return; + gzfile_read_more(gz); + } + n = 0; + p = RSTRING(gz->z.buf)->ptr; + } + } + + str = zstream_shift_buffer(&gz->z, n - 1); + gz->crc = crc32(gz->crc, RSTRING(str)->ptr, RSTRING(str)->len); +} + +static VALUE +gzreader_gets(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + struct gzfile *gz = get_gzfile(obj); + VALUE rs, dst; + char *rsptr, *p; + long rslen, n; + int rspara; + + if (argc == 0) { + rs = rb_rs; + } + else { + rb_scan_args(argc, argv, "1", &rs); + if (!NIL_P(rs)) { + Check_Type(rs, T_STRING); + } + } + + if (NIL_P(rs)) { + dst = gzfile_read_all(gz); + if (!NIL_P(dst)) gz->lineno++; + return dst; + } + + if (RSTRING(rs)->len == 0) { + rsptr = "\n\n"; + rslen = 2; + rspara = 1; + } else { + rsptr = RSTRING(rs)->ptr; + rslen = RSTRING(rs)->len; + rspara = 0; + } + + if (rspara) { + gzreader_skip_linebreaks(gz); + } + + while (gz->z.buf_filled < rslen) { + if (ZSTREAM_IS_FINISHED(&gz->z)) { + if (gz->z.buf_filled > 0) gz->lineno++; + return gzfile_read(gz, rslen); + } + gzfile_read_more(gz); + } + + n = rslen; + p = RSTRING(gz->z.buf)->ptr; + for (;;) { + if (n > gz->z.buf_filled) { + if (ZSTREAM_IS_FINISHED(&gz->z)) break; + gzfile_read_more(gz); + p = RSTRING(gz->z.buf)->ptr + n - rslen; + } + if (memcmp(p, rsptr, rslen) == 0) break; + p++, n++; + } + + gz->lineno++; + dst = gzfile_read(gz, n); + if (rspara) { + gzreader_skip_linebreaks(gz); + } + + return dst; +} + +static VALUE +rb_gzreader_gets(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + VALUE dst; + dst = gzreader_gets(argc, argv, obj); + if (!NIL_P(dst)) { + rb_lastline_set(dst); + } + return dst; +} + +static VALUE +rb_gzreader_readline(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + VALUE dst; + dst = rb_gzreader_gets(argc, argv, obj); + if (NIL_P(dst)) { + rb_raise(rb_eEOFError, "End of file reached"); + } + return dst; +} + +static VALUE +rb_gzreader_each(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + VALUE str; + while (!NIL_P(str = gzreader_gets(argc, argv, obj))) { + rb_yield(str); + } + return obj; +} + +static VALUE +rb_gzreader_readlines(argc, argv, obj) + int argc; + VALUE *argv; + VALUE obj; +{ + VALUE str, dst; + dst = rb_ary_new(); + while (!NIL_P(str = gzreader_gets(argc, argv, obj))) { + rb_ary_push(dst, str); + } + return dst; +} + +#endif /* GZIP_SUPPORT */ + + +void Init_zlib() +{ + VALUE mZlib, cZStream, cDeflate, cInflate; +#if GZIP_SUPPORT + VALUE cGzipFile, cGzipWriter, cGzipReader; +#endif + + mZlib = rb_define_module("Zlib"); + + cZError = rb_define_class_under(mZlib, "Error", rb_eStandardError); + cStreamEnd = rb_define_class_under(mZlib, "StreamEnd", cZError); + cNeedDict = rb_define_class_under(mZlib, "NeedDict", cZError); + cDataError = rb_define_class_under(mZlib, "DataError", cZError); + cStreamError = rb_define_class_under(mZlib, "StreamError", cZError); + cMemError = rb_define_class_under(mZlib, "MemError", cZError); + cBufError = rb_define_class_under(mZlib, "BufError", cZError); + cVersionError = rb_define_class_under(mZlib, "VersionError", cZError); + + rb_define_module_function(mZlib, "zlib_version", rb_zlib_version, 0); + rb_define_module_function(mZlib, "adler32", rb_zlib_adler32, -1); + rb_define_module_function(mZlib, "crc32", rb_zlib_crc32, -1); + rb_define_module_function(mZlib, "crc_table", rb_zlib_crc_table, 0); + + rb_define_const(mZlib, "VERSION", rb_str_new2(RUBY_ZLIB_VERSION)); + rb_define_const(mZlib, "ZLIB_VERSION", rb_str_new2(ZLIB_VERSION)); + + cZStream = rb_define_class_under(mZlib, "ZStream", rb_cObject); + rb_undef_alloc_func(cZStream); + rb_define_method(cZStream, "avail_out", rb_zstream_avail_out, 0); + rb_define_method(cZStream, "avail_out=", rb_zstream_set_avail_out, 0); + rb_define_method(cZStream, "avail_in", rb_zstream_avail_in, 0); + rb_define_method(cZStream, "total_in", rb_zstream_total_in, 0); + rb_define_method(cZStream, "total_out", rb_zstream_total_out, 0); + rb_define_method(cZStream, "data_type", rb_zstream_data_type, 0); + rb_define_method(cZStream, "adler", rb_zstream_adler, 0); + rb_define_method(cZStream, "finished?", rb_zstream_finished_p, 0); + rb_define_method(cZStream, "stream_end?", rb_zstream_finished_p, 0); + rb_define_method(cZStream, "closed?", rb_zstream_closed_p, 0); + rb_define_method(cZStream, "ended?", rb_zstream_closed_p, 0); + rb_define_method(cZStream, "close", rb_zstream_end, 0); + rb_define_method(cZStream, "end", rb_zstream_end, 0); + rb_define_method(cZStream, "reset", rb_zstream_reset, 0); + rb_define_method(cZStream, "finish", rb_zstream_finish, 0); + rb_define_method(cZStream, "flush_next_in", rb_zstream_flush_next_in, 0); + rb_define_method(cZStream, "flush_next_out", rb_zstream_flush_next_out, 0); + + rb_define_const(mZlib, "BINARY", INT2FIX(Z_BINARY)); + rb_define_const(mZlib, "ASCII", INT2FIX(Z_ASCII)); + rb_define_const(mZlib, "UNKNOWN", INT2FIX(Z_UNKNOWN)); + + cDeflate = rb_define_class_under(mZlib, "Deflate", cZStream); + rb_define_singleton_method(cDeflate, "deflate", rb_deflate_s_deflate, -1); + rb_define_alloc_func(cDeflate, rb_deflate_s_allocate); + rb_define_method(cDeflate, "initialize", rb_deflate_initialize, -1); + rb_define_method(cDeflate, "clone", rb_deflate_clone, 0); + rb_define_method(cDeflate, "deflate", rb_deflate_deflate, -1); + rb_define_method(cDeflate, "<<", rb_deflate_addstr, 1); + rb_define_method(cDeflate, "flush", rb_deflate_flush, -1); + rb_define_method(cDeflate, "params", rb_deflate_params, 2); + rb_define_method(cDeflate, "set_dictionary", rb_deflate_set_dictionary, 1); + + cInflate = rb_define_class_under(mZlib, "Inflate", cZStream); + rb_define_singleton_method(cInflate, "inflate", rb_inflate_s_inflate, 1); + rb_define_alloc_func(cInflate, rb_inflate_s_allocate); + rb_define_method(cInflate, "initialize", rb_inflate_initialize, -1); + rb_define_method(cInflate, "inflate", rb_inflate_inflate, 1); + rb_define_method(cInflate, "<<", rb_inflate_addstr, 1); + rb_define_method(cInflate, "sync", rb_inflate_sync, 1); + rb_define_method(cInflate, "sync_point?", rb_inflate_sync_point_p, 0); + rb_define_method(cInflate, "set_dictionary", rb_inflate_set_dictionary, 1); + + rb_define_const(mZlib, "NO_COMPRESSION", INT2FIX(Z_NO_COMPRESSION)); + rb_define_const(mZlib, "BEST_SPEED", INT2FIX(Z_BEST_SPEED)); + rb_define_const(mZlib, "BEST_COMPRESSION", INT2FIX(Z_BEST_COMPRESSION)); + rb_define_const(mZlib, "DEFAULT_COMPRESSION", + INT2FIX(Z_DEFAULT_COMPRESSION)); + + rb_define_const(mZlib, "FILTERED", INT2FIX(Z_FILTERED)); + rb_define_const(mZlib, "HUFFMAN_ONLY", INT2FIX(Z_HUFFMAN_ONLY)); + rb_define_const(mZlib, "DEFAULT_STRATEGY", INT2FIX(Z_DEFAULT_STRATEGY)); + + rb_define_const(mZlib, "MAX_WBITS", INT2FIX(MAX_WBITS)); + rb_define_const(mZlib, "DEF_MEM_LEVEL", INT2FIX(DEF_MEM_LEVEL)); + rb_define_const(mZlib, "MAX_MEM_LEVEL", INT2FIX(MAX_MEM_LEVEL)); + + rb_define_const(mZlib, "NO_FLUSH", INT2FIX(Z_NO_FLUSH)); + rb_define_const(mZlib, "SYNC_FLUSH", INT2FIX(Z_SYNC_FLUSH)); + rb_define_const(mZlib, "FULL_FLUSH", INT2FIX(Z_FULL_FLUSH)); + rb_define_const(mZlib, "FINISH", INT2FIX(Z_FINISH)); + +#if GZIP_SUPPORT + id_write = rb_intern("write"); + id_read = rb_intern("read"); + id_flush = rb_intern("flush"); + id_seek = rb_intern("seek"); + id_close = rb_intern("close"); + + cGzipFile = rb_define_class_under(mZlib, "GzipFile", rb_cObject); + cGzError = rb_define_class_under(cGzipFile, "Error", cZError); + + cNoFooter = rb_define_class_under(cGzipFile, "NoFooter", cGzError); + cCRCError = rb_define_class_under(cGzipFile, "CRCError", cGzError); + cLengthError = rb_define_class_under(cGzipFile,"LengthError",cGzError); + + cGzipWriter = rb_define_class_under(mZlib, "GzipWriter", cGzipFile); + cGzipReader = rb_define_class_under(mZlib, "GzipReader", cGzipFile); + rb_include_module(cGzipReader, rb_mEnumerable); + + rb_define_singleton_method(cGzipFile, "wrap", rb_gzfile_s_wrap, -1); + rb_undef_alloc_func(cGzipFile); + rb_define_method(cGzipFile, "to_io", rb_gzfile_to_io, 0); + rb_define_method(cGzipFile, "crc", rb_gzfile_crc, 0); + rb_define_method(cGzipFile, "mtime", rb_gzfile_mtime, 0); + rb_define_method(cGzipFile, "level", rb_gzfile_level, 0); + rb_define_method(cGzipFile, "os_code", rb_gzfile_os_code, 0); + rb_define_method(cGzipFile, "orig_name", rb_gzfile_orig_name, 0); + rb_define_method(cGzipFile, "comment", rb_gzfile_comment, 0); + rb_define_method(cGzipReader, "lineno", rb_gzfile_lineno, 0); + rb_define_method(cGzipReader, "lineno=", rb_gzfile_set_lineno, 1); + rb_define_method(cGzipWriter, "mtime=", rb_gzfile_set_mtime, 1); + rb_define_method(cGzipWriter, "orig_name=", rb_gzfile_set_orig_name,1); + rb_define_method(cGzipWriter, "comment=", rb_gzfile_set_comment, 1); + rb_define_method(cGzipFile, "close", rb_gzfile_close, 0); + rb_define_method(cGzipFile, "finish", rb_gzfile_finish, 0); + rb_define_method(cGzipFile, "closed?", rb_gzfile_closed_p, 0); + rb_define_method(cGzipReader, "eof", rb_gzfile_eof_p, 0); + rb_define_method(cGzipReader, "eof?", rb_gzfile_eof_p, 0); + rb_define_method(cGzipFile, "sync", rb_gzfile_sync, 0); + rb_define_method(cGzipFile, "sync=", rb_gzfile_set_sync, 1); + rb_define_method(cGzipReader, "pos", rb_gzfile_total_out, 0); + rb_define_method(cGzipWriter, "pos", rb_gzfile_total_in, 0); + rb_define_method(cGzipReader, "tell", rb_gzfile_total_out, 0); + rb_define_method(cGzipWriter, "tell", rb_gzfile_total_in, 0); + + rb_define_singleton_method(cGzipWriter, "open", rb_gzwriter_s_open,-1); + rb_define_alloc_func(cGzipWriter, rb_gzwriter_s_allocate); + rb_define_method(cGzipWriter, "initialize", rb_gzwriter_initialize,-1); + rb_define_method(cGzipWriter, "flush", rb_gzwriter_flush, -1); + rb_define_method(cGzipWriter, "write", rb_gzwriter_write, 1); + rb_define_method(cGzipWriter, "putc", rb_gzwriter_putc, 1); + rb_define_method(cGzipWriter, "<<", rb_gzwriter_addstr, 1); + rb_define_method(cGzipWriter, "printf", rb_gzwriter_printf, -1); + rb_define_method(cGzipWriter, "print", rb_gzwriter_print, -1); + rb_define_method(cGzipWriter, "puts", rb_gzwriter_puts, -1); + + rb_define_singleton_method(cGzipReader, "open", rb_gzreader_s_open,-1); + rb_define_alloc_func(cGzipReader, rb_gzreader_s_allocate); + rb_define_method(cGzipReader, "initialize", rb_gzreader_initialize, 1); + rb_define_method(cGzipReader, "rewind", rb_gzreader_rewind, 0); + rb_define_method(cGzipReader, "unused", rb_gzreader_unused, 0); + rb_define_method(cGzipReader, "read", rb_gzreader_read, -1); + rb_define_method(cGzipReader, "getc", rb_gzreader_getc, 0); + rb_define_method(cGzipReader, "readchar", rb_gzreader_readchar, 0); + rb_define_method(cGzipReader, "each_byte", rb_gzreader_each_byte, 0); + rb_define_method(cGzipReader, "ungetc", rb_gzreader_ungetc, 1); + rb_define_method(cGzipReader, "gets", rb_gzreader_gets, -1); + rb_define_method(cGzipReader, "readline", rb_gzreader_readline, -1); + rb_define_method(cGzipReader, "each", rb_gzreader_each, -1); + rb_define_method(cGzipReader, "readlines", rb_gzreader_readlines, -1); + + rb_define_const(mZlib, "OS_CODE", INT2FIX(OS_CODE)); + rb_define_const(mZlib, "OS_MSDOS", INT2FIX(OS_MSDOS)); + rb_define_const(mZlib, "OS_AMIGA", INT2FIX(OS_AMIGA)); + rb_define_const(mZlib, "OS_VMS", INT2FIX(OS_VMS)); + rb_define_const(mZlib, "OS_UNIX", INT2FIX(OS_UNIX)); + rb_define_const(mZlib, "OS_ATARI", INT2FIX(OS_ATARI)); + rb_define_const(mZlib, "OS_OS2", INT2FIX(OS_OS2)); + rb_define_const(mZlib, "OS_MACOS", INT2FIX(OS_MACOS)); + rb_define_const(mZlib, "OS_TOPS20", INT2FIX(OS_TOPS20)); + rb_define_const(mZlib, "OS_WIN32", INT2FIX(OS_WIN32)); + + rb_define_const(mZlib, "OS_VMCMS", INT2FIX(OS_VMCMS)); + rb_define_const(mZlib, "OS_ZSYSTEM", INT2FIX(OS_ZSYSTEM)); + rb_define_const(mZlib, "OS_CPM", INT2FIX(OS_CPM)); + rb_define_const(mZlib, "OS_QDOS", INT2FIX(OS_QDOS)); + rb_define_const(mZlib, "OS_RISCOS", INT2FIX(OS_RISCOS)); + rb_define_const(mZlib, "OS_UNKNOWN", INT2FIX(OS_UNKNOWN)); + +#endif /* GZIP_SUPPORT */ +} |