From 35a201cc8ef0c3f5b2df88d2e528aabee1048348 Mon Sep 17 00:00:00 2001 From: Wojtek Kosior Date: Fri, 30 Apr 2021 18:47:09 +0200 Subject: Initial/Final commit --- .../libmariadb/my_compress.c | 89 ++++++++++++++++++++++ 1 file changed, 89 insertions(+) create mode 100644 mariadb-connector-c-v_2.3.7/libmariadb/my_compress.c (limited to 'mariadb-connector-c-v_2.3.7/libmariadb/my_compress.c') diff --git a/mariadb-connector-c-v_2.3.7/libmariadb/my_compress.c b/mariadb-connector-c-v_2.3.7/libmariadb/my_compress.c new file mode 100644 index 0000000..71685cd --- /dev/null +++ b/mariadb-connector-c-v_2.3.7/libmariadb/my_compress.c @@ -0,0 +1,89 @@ +/* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB + + This library is free software; you can redistribute it and/or + modify it under the terms of the GNU Library General Public + License as published by the Free Software Foundation; either + version 2 of the License, or (at your option) any later version. + + This library is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + Library General Public License for more details. + + You should have received a copy of the GNU Library General Public + License along with this library; if not, write to the Free + Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, + MA 02111-1301, USA */ + +/* Written by Sinisa Milivojevic */ + +#include +#ifdef HAVE_COMPRESS +#include +#include +#include + +/* +** This replaces the packet with a compressed packet +** Returns 1 on error +** *complen is 0 if the packet wasn't compressed +*/ + +my_bool my_compress(unsigned char *packet, size_t *len, size_t *complen) +{ + if (*len < MIN_COMPRESS_LENGTH) + *complen=0; + else + { + unsigned char *compbuf=my_compress_alloc(packet,len,complen); + if (!compbuf) + return *complen ? 0 : 1; + memcpy(packet,compbuf,*len); + my_free(compbuf); + } + return 0; +} + + +unsigned char *my_compress_alloc(const unsigned char *packet, size_t *len, size_t *complen) +{ + unsigned char *compbuf; + *complen = *len * 120 / 100 + 12; + if (!(compbuf = (unsigned char *) my_malloc(*complen,MYF(MY_WME)))) + return 0; /* Not enough memory */ + if (compress((Bytef*) compbuf,(ulong *) complen, (Bytef*) packet, + (uLong) *len ) != Z_OK) + { + my_free(compbuf); + return 0; + } + if (*complen >= *len) + { + *complen=0; + my_free(compbuf); + return 0; + } + swap(ulong,*len,*complen); /* *len is now packet length */ + return compbuf; +} + +my_bool my_uncompress (unsigned char *packet, size_t *len, size_t *complen) +{ + if (*complen) /* If compressed */ + { + unsigned char *compbuf = (unsigned char *) my_malloc (*complen,MYF(MY_WME)); + if (!compbuf) + return 1; /* Not enough memory */ + if (uncompress((Bytef*) compbuf, (uLongf *)complen, (Bytef*) packet, (uLongf)*len) != Z_OK) + { /* Probably wrong packet */ + my_free (compbuf); + return 1; + } + *len = *complen; + memcpy(packet,compbuf,*len); + my_free(compbuf); + } + else *complen= *len; + return 0; +} +#endif /* HAVE_COMPRESS */ -- cgit v1.2.3