mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
e393f0ad16
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@3645 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
2768 lines
64 KiB
C
2768 lines
64 KiB
C
/*
|
|
* 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((unsigned int)(RSTRING(dst)->ptr[0]) & 0xff);
|
|
}
|
|
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 */
|
|
}
|