aboutsummaryrefslogtreecommitdiff
path: root/nx-X11/lib/lbxutil/lbx_zlib/lbx_zlib.c
diff options
context:
space:
mode:
Diffstat (limited to 'nx-X11/lib/lbxutil/lbx_zlib/lbx_zlib.c')
-rw-r--r--nx-X11/lib/lbxutil/lbx_zlib/lbx_zlib.c543
1 files changed, 0 insertions, 543 deletions
diff --git a/nx-X11/lib/lbxutil/lbx_zlib/lbx_zlib.c b/nx-X11/lib/lbxutil/lbx_zlib/lbx_zlib.c
deleted file mode 100644
index e7105a0c7..000000000
--- a/nx-X11/lib/lbxutil/lbx_zlib/lbx_zlib.c
+++ /dev/null
@@ -1,543 +0,0 @@
-/* $Xorg: lbx_zlib.c,v 1.6 2001/02/09 02:04:05 xorgcvs Exp $ */
-
-/*
-
-Copyright 1995, 1998 The Open Group
-
-Permission to use, copy, modify, distribute, and sell this software and its
-documentation for any purpose is hereby granted without fee, provided that
-the above copyright notice appear in all copies and that both that
-copyright notice and this permission notice appear in supporting
-documentation.
-
-The above copyright notice and this permission notice shall be
-included in all copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
-EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
-MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
-IN NO EVENT SHALL THE OPEN GROUP BE LIABLE FOR ANY CLAIM, DAMAGES OR
-OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
-ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
-OTHER DEALINGS IN THE SOFTWARE.
-
-Except as contained in this notice, the name of The Open Group shall
-not be used in advertising or otherwise to promote the sale, use or
-other dealings in this Software without prior written authorization
-from The Open Group.
-
-*/
-
-/*
- * Copyright 1988, 1989, 1990, 1994 Network Computing Devices, Inc.
- *
- * Permission to use, copy, modify, distribute, and sell this software and
- * its documentation for any purpose is hereby granted without fee, provided
- * that the above copyright notice appear in all copies and that both that
- * copyright notice and this permission notice appear in supporting
- * documentation, and that the name Network Computing Devices, Inc. not be
- * used in advertising or publicity pertaining to distribution of this
- * software without specific, written prior permission.
- *
- * THIS SOFTWARE IS PROVIDED `AS-IS'. NETWORK COMPUTING DEVICES, INC.,
- * DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING WITHOUT
- * LIMITATION ALL IMPLIED WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
- * PARTICULAR PURPOSE, OR NONINFRINGEMENT. IN NO EVENT SHALL NETWORK
- * COMPUTING DEVICES, INC., BE LIABLE FOR ANY DAMAGES WHATSOEVER, INCLUDING
- * SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES, INCLUDING LOSS OF USE, DATA,
- * OR PROFITS, EVEN IF ADVISED OF THE POSSIBILITY THEREOF, AND REGARDLESS OF
- * WHETHER IN AN ACTION IN CONTRACT, TORT OR NEGLIGENCE, ARISING OUT OF OR IN
- * CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
- *
- */
-/* $XFree86: xc/lib/lbxutil/lbx_zlib/lbx_zlib.c,v 1.9 2001/08/27 19:01:07 dawes Exp $ */
-
-#ifdef WIN32
-#define _WILLWINSOCK_
-#endif
-#define _BSD_SOURCE
-#include <X11/Xos.h>
-#include <X11/Xfuncs.h>
-#include <stdio.h>
-#include <errno.h>
-#include <sys/types.h>
-#if !defined(WIN32) && !defined(Lynx)
-#include <sys/param.h>
-#endif
-#include <X11/extensions/lbxbufstr.h>
-#include "lbx_zlib.h"
-#include <X11/extensions/lbxzlib.h>
-
-unsigned long stream_out_compressed;
-unsigned long stream_out_uncompressed;
-unsigned long stream_out_plain;
-unsigned long stream_in_compressed;
-unsigned long stream_in_uncompressed;
-unsigned long stream_in_plain;
-#ifdef LBXREQSTATS
-unsigned long stream_in_packet_header_bytes = 0;
-extern int LbxWhoAmI;
-#endif
-
-struct ZlibInfo {
- struct compress_private compress_state;
- struct compress_private decompress_state;
- int fd;
- int compress_off;
- ZlibBuffer inbuf;
- ZlibBuffer outbuf;
- unsigned char header[ZLIB_PACKET_HDRLEN];
- struct iovec iovbuf[2];
-};
-
-static int
-init_compress(struct compress_private *priv,/* local pointer to private data */
- int level) /* compression level */
-{
- priv->cp_outputcount = 0;
-
- priv->cp_in_count = 0; /* length of input */
- priv->cp_bytes_out = 0; /* length of compressed output */
- priv->cp_inputbuf = priv->cp_inputbufend = NULL;
- priv->cp_packet = NULL;
-
- priv->stream.zalloc = (alloc_func) 0;
- priv->stream.zfree = (free_func) 0;
- priv->stream.next_in = NULL;
- priv->stream.next_out = NULL;
- priv->stream.avail_in = priv->stream.avail_out = 0;
-
- priv->z_err = deflateInit (&(priv->stream), level);
-
- return (priv->compress_inited = (priv->z_err == Z_OK) ? 1 : 0);
-}
-
-static int
-init_decompress(struct compress_private *priv)/* local pointer to private data */
-{
- priv->cp_outputcount = 0;
-
- priv->cp_in_count = 0; /* length of input */
- priv->cp_bytes_out = 0; /* length of compressed output */
- priv->cp_inputbuf = priv->cp_inputbufend = NULL;
- priv->cp_packet = NULL;
-
- priv->stream.zalloc = (alloc_func) 0;
- priv->stream.zfree = (free_func) 0;
- priv->stream.next_in = NULL;
- priv->stream.next_out = NULL;
- priv->stream.avail_in = priv->stream.avail_out = 0;
-
- priv->need_flush_decompress = 0;
-
- priv->z_err = inflateInit (&(priv->stream));
-
-#ifdef LBXREQSTATS
- priv->req_length = -1;
- priv->req_compbytes_read = 0;
- priv->req_uncompbytes_read = 0;
- priv->x_header_bytes_read = 0;
-#endif
-
- return (priv->decompress_inited = (priv->z_err == Z_OK) ? 1 : 0);
-}
-
-
-static void
-do_compress (struct compress_private *priv,
- int flush)
-
-{
- priv->stream.next_in = priv->cp_inputbuf;
- priv->stream.avail_in = priv->cp_inputbufend - priv->cp_inputbuf;
-
- priv->stream.next_out = priv->cp_outputbuf;
- priv->stream.avail_out = priv->cp_outputbufend - priv->cp_outputbuf;
-
- priv->z_err = deflate (&(priv->stream), flush);
-
- priv->cp_inputbuf = priv->stream.next_in;
- priv->cp_outputbuf = priv->stream.next_out;
-}
-
-
-static void
-do_decompress (struct compress_private *priv)
-
-{
- priv->stream.next_in = priv->cp_inputbuf;
- priv->stream.avail_in = priv->cp_inputbufend - priv->cp_inputbuf;
-
- priv->stream.next_out = priv->cp_outputbuf;
- priv->stream.avail_out = priv->cp_outputbufend - priv->cp_outputbuf;
-
- priv->z_err = inflate (&(priv->stream), Z_PARTIAL_FLUSH);
-
- priv->need_flush_decompress = (priv->stream.avail_out == 0);
-
- priv->cp_inputbuf = priv->stream.next_in;
- priv->cp_outputbuf = priv->stream.next_out;
-}
-
-static int
-GetNewPacket(struct ZlibInfo *comp)
-{
- register struct compress_private *priv = &comp->decompress_state;
- int len;
- int result;
-
- if (priv->cp_packet) {
- /* Free up previous packet in input buffer */
- FreeInput(&comp->inbuf, priv->cp_inputbufend - priv->cp_packet);
- priv->cp_packet = NULL;
- }
-
- if ((result = GetInputPtr(comp->fd,
- &comp->inbuf,
- ZLIB_PACKET_HDRLEN,
- &priv->cp_packet)) <= 0)
- return result;
- len = ZLIB_GET_DATALEN(priv->cp_packet);
- if ((result = GetInputPtr(comp->fd,
- &comp->inbuf,
- len + ZLIB_PACKET_HDRLEN,
- &priv->cp_packet)) <= 0) {
- priv->cp_packet = NULL;
- return result;
- }
-
- return len;
-}
-
-static int
-NewPacketAvail(struct ZlibInfo *comp)
-{
- register struct compress_private *priv = &comp->decompress_state;
- char *pkt;
- int len;
-
- if (priv->cp_packet) {
- /* Free up previous packet in input buffer */
- FreeInput(&comp->inbuf, priv->cp_inputbufend - priv->cp_packet);
- priv->cp_packet = NULL;
- }
-
- if ((pkt = BYTES_AVAIL(&comp->inbuf, ZLIB_PACKET_HDRLEN))) {
- len = ZLIB_GET_DATALEN(pkt);
- if (BYTES_AVAIL(&comp->inbuf, len + ZLIB_PACKET_HDRLEN))
- return TRUE;
- }
-
- return FALSE;
-}
-
-static int
-PlainWrite(struct ZlibInfo *comp,
- unsigned char *buffer,
- int buflen)
-{
- int retval;
- int lenleft = buflen;
-
- if ((retval = ZlibFlush(comp->fd)) == 0) {
- register struct iovec *iov = comp->iovbuf;
- while (lenleft) {
- int outlen, written;
- if ((outlen = iov[1].iov_len)) {
- iov[1].iov_base = (caddr_t) buffer;
- }
- else {
- outlen = MIN(lenleft, ZLIB_MAX_DATALEN);
- ZLIB_PUT_PKTHDR(comp->header, outlen, FALSE);
- iov[0].iov_base = (caddr_t) comp->header;
- iov[0].iov_len = ZLIB_PACKET_HDRLEN;
- iov[1].iov_base = (caddr_t) buffer;
- iov[1].iov_len = outlen;
- stream_out_uncompressed += ZLIB_PACKET_HDRLEN;
- }
- if ((retval = FlushIovBuf(comp->fd, iov)) < 0)
- break;
- written = outlen - retval;
- lenleft -= written;
- buffer += written;
- stream_out_plain += written;
- stream_out_uncompressed += written;
- if (retval)
- break;
- }
- if (lenleft == buflen)
- return retval;
- else
- return buflen - lenleft;
- }
-
- else if (retval > 0) {
- retval = -1;
- errno = EWOULDBLOCK;
- }
-
- return retval;
-}
-
-#define MAX_FDS 256
-
-static struct ZlibInfo *per_fd[MAX_FDS];
-
-/*
- * Initialize ZLIB compressor
- */
-void *
-ZlibInit(int fd,
- int level) /* compression level */
-{
- struct ZlibInfo *comp;
- int ret1, ret2;
-
- if ((comp = (struct ZlibInfo *)Xalloc(sizeof(struct ZlibInfo))) == NULL)
- return NULL;
-
- ret1 = InitZlibBuffer(&comp->inbuf, INBUFFER_SIZE);
- ret2 = InitZlibBuffer(&comp->outbuf, OUTBUFFER_SIZE);
- if (ret1 < 0 || ret2 < 0) {
- ZlibFree(comp);
- return NULL;
- }
- comp->compress_off = FALSE;
- comp->iovbuf[1].iov_len = 0;
- comp->fd = fd;
-
- if (!init_compress(&comp->compress_state, level) ||
- !init_decompress(&comp->decompress_state)) {
- ZlibFree(comp);
- return NULL;
- }
-
- per_fd[fd] = comp;
-
-#ifdef LBXREQSTATS
- InitLbxReqStats ();
-#endif
-
- return (void *)comp;
-}
-
-void
-ZlibFree(struct ZlibInfo *comp)
-{
- if (!comp)
- return;
- per_fd[comp->fd] = 0;
- FreeZlibBuffer(&comp->inbuf);
- FreeZlibBuffer(&comp->outbuf);
-
- if (comp->compress_state.compress_inited)
- deflateEnd (&(comp->compress_state.stream));
- else if (comp->decompress_state.decompress_inited)
- inflateEnd (&(comp->compress_state.stream));
-
- Xfree(comp);
-}
-
-int
-ZlibFlush(int fd)
-{
- struct ZlibInfo *comp = per_fd[fd];
- struct compress_private *priv = &comp->compress_state;
-
- if (priv->cp_in_count) {
- int len;
- do_compress (priv, Z_PARTIAL_FLUSH);
- len = priv->cp_outputbuf - (priv->cp_packet + ZLIB_PACKET_HDRLEN);
- ZLIB_PUT_PKTHDR(priv->cp_packet, len, TRUE);
- stream_out_compressed += (len + ZLIB_PACKET_HDRLEN);
-
- CommitOutBuf(&comp->outbuf, len + ZLIB_PACKET_HDRLEN);
- priv->cp_in_count = 0;
- }
-
- return FlushOutBuf(comp->fd, &comp->outbuf);
-}
-
-int
-ZlibStuffInput(int fd,
- unsigned char *buffer,
- int buflen)
-{
- struct ZlibInfo *comp = per_fd[fd];
-
- if (StuffInput (&comp->inbuf, buffer, buflen) != buflen)
- return 0;
- return 1;
-}
-
-void
-ZlibCompressOn(int fd)
-{
- per_fd[fd]->compress_off = FALSE;
-}
-
-void
-ZlibCompressOff(int fd)
-{
- per_fd[fd]->compress_off = TRUE;
-}
-
-int
-ZlibWriteV(int fd,
- struct iovec *iov,
- int iovcnt)
-{
- int i;
- int total = 0;
- int this_time;
-
- for (i = 0; i < iovcnt; i++)
- {
- this_time = ZlibWrite(fd, (unsigned char *)iov[i].iov_base,
- iov[i].iov_len);
- if (this_time > 0)
- total += this_time;
- if (this_time != iov[i].iov_len)
- {
- if (total)
- return total;
- return this_time;
- }
- }
- return total;
-}
-
-int
-ZlibWrite(int fd,
- unsigned char *buffer,
- int buflen)
-{
- struct ZlibInfo *comp = per_fd[fd];
- struct compress_private *priv = &comp->compress_state;
- int len;
- int lenleft = buflen;
- unsigned char *p = buffer;
-
- if (comp->compress_off) {
- return PlainWrite(comp, buffer, buflen);
- }
-
- while (lenleft) {
- if (priv->cp_in_count == 0) {
- priv->cp_packet = (unsigned char *) ReserveOutBuf(&comp->outbuf,
- ZLIB_PACKET_HDRLEN + ZLIB_MAX_OUTLEN);
- if (!priv->cp_packet) {
- errno = EWOULDBLOCK;
- return -1;
- }
- priv->cp_outputbuf = priv->cp_packet + ZLIB_PACKET_HDRLEN;
- priv->cp_outputbufend = priv->cp_outputbuf + ZLIB_MAX_OUTLEN;
- }
-
- len = MIN(ZLIB_MAX_PLAIN - priv->cp_in_count, lenleft);
- stream_out_plain += len;
-
- priv->cp_inputbuf = p;
- priv->cp_inputbufend = p + len;
- do_compress(priv, Z_NO_FLUSH);
-
- p += len;
- lenleft -= len;
- if ((priv->cp_in_count += len) == ZLIB_MAX_PLAIN) {
- if (ZlibFlush(fd) < 0) {
- if (lenleft == buflen)
- return -1;
- return buflen - lenleft;
- }
- }
- }
-
- return buflen;
-}
-
-int
-ZlibRead(int fd,
- unsigned char *buffer,
- int buflen)
-{
- struct ZlibInfo *comp = per_fd[fd];
- struct compress_private *priv = &comp->decompress_state;
- unsigned char *p = buffer;
- int lenleft = buflen;
- int len;
- int retval = -1;
-
- /*
- * First check if there is any data Zlib decompressed already but
- * didn't have output buffer space to store it in.
- */
-
- if (priv->need_flush_decompress)
- {
- priv->cp_outputbuf = p;
- priv->cp_outputbufend = p + lenleft;
-
- do_decompress (priv);
-
- lenleft -= (priv->cp_outputbuf - p);
- p = priv->cp_outputbuf;
- }
-
-
- /*
- * Need to decompress some more data
- */
-
- priv->cp_outputbuf = p;
- priv->cp_outputbufend = p + lenleft;
- while (priv->cp_outputbuf != priv->cp_outputbufend) {
- if (priv->cp_inputbuf == priv->cp_inputbufend) {
- if ((retval = GetNewPacket(comp)) <= 0)
- break;
- priv->cp_inputbuf = priv->cp_packet + ZLIB_PACKET_HDRLEN;
- priv->cp_inputbufend = priv->cp_inputbuf + retval;
- if (ZLIB_COMPRESSED(priv->cp_packet))
- stream_in_compressed += (retval + ZLIB_PACKET_HDRLEN);
- else
- stream_in_uncompressed += (retval + ZLIB_PACKET_HDRLEN);
-#ifdef LBXREQSTATS
- stream_in_packet_header_bytes += ZLIB_PACKET_HDRLEN;
-#endif
- }
-
- if (ZLIB_COMPRESSED(priv->cp_packet))
-#ifdef LBXREQSTATS
- if (LbxWhoAmI == 1) /* only support request stats for now */
- do_decompress_with_stats(priv);
- else
-#endif
- do_decompress(priv);
-
- else {
- len = MIN(priv->cp_inputbufend - priv->cp_inputbuf,
- priv->cp_outputbufend - priv->cp_outputbuf);
- memmove(priv->cp_outputbuf, priv->cp_inputbuf, len);
- priv->cp_inputbuf += len;
- priv->cp_outputbuf += len;
- }
- }
-
- if ((len = priv->cp_outputbuf - buffer) == 0)
- return retval;
- else {
- stream_in_plain += len;
- return len;
- }
-}
-
-int
-ZlibInputAvail(int fd)
-{
- struct ZlibInfo *comp = per_fd[fd];
- struct compress_private *priv = &comp->decompress_state;
-
- return (
- priv->need_flush_decompress ||
- priv->cp_inputbuf != priv->cp_inputbufend ||
- NewPacketAvail(comp) > 0);
-}
generated by cgit v1.2.3 (git 2.25.1) at 2024-07-13 03:15:16 +0000