139     struct compress_buffer *cb = (struct compress_buffer *) closure;  local
142     if (cb->buf->input == NULL)
153     bd = cb->buf->data;
167 	cb->buf->data = bd;
170     cb->zstr.avail_out = size;
171     cb->zstr.next_out = (Bytef *) data;
182 	cb->zstr.avail_in = bd->size;
183 	cb->zstr.next_in = (Bytef *) bd->bufp;
187 	    zstatus = inflate (&cb->zstr, Z_NO_FLUSH);
192 		compress_error (0, zstatus, &cb->zstr, "inflate");
195 	} while (cb->zstr.avail_in > 0
196 		 && cb->zstr.avail_out > 0);
198 	bd->size = cb->zstr.avail_in;
199 	bd->bufp = (char *) cb->zstr.next_in;
209 	sofar = size - cb->zstr.avail_out;
224 	status = (*cb->buf->input) (cb->buf->closure, bd->text,
243     *got = size - cb->zstr.avail_out;
257     struct compress_buffer *cb = (struct compress_buffer *) closure;  local
259     cb->zstr.avail_in = have;
260     cb->zstr.next_in = (unsigned char *) data;
262     while (cb->zstr.avail_in > 0)
267 	cb->zstr.avail_out = BUFFER_DATA_SIZE;
268 	cb->zstr.next_out = (unsigned char *) buffer;
270 	zstatus = deflate (&cb->zstr, Z_NO_FLUSH);
273 	    compress_error (0, zstatus, &cb->zstr, "deflate");
277 	if (cb->zstr.avail_out != BUFFER_DATA_SIZE)
278 	    buf_output (cb->buf, buffer,
279 			BUFFER_DATA_SIZE - cb->zstr.avail_out);
287     return buf_send_output (cb->buf);
296     struct compress_buffer *cb = (struct compress_buffer *) closure;  local
298     cb->zstr.avail_in = 0;
299     cb->zstr.next_in = NULL;
306 	cb->zstr.avail_out = BUFFER_DATA_SIZE;
307 	cb->zstr.next_out = (unsigned char *) buffer;
309 	zstatus = deflate (&cb->zstr, Z_SYNC_FLUSH);
319 	    compress_error (0, zstatus, &cb->zstr, "deflate flush");
323 	if (cb->zstr.avail_out != BUFFER_DATA_SIZE)
324 	    buf_output (cb->buf, buffer,
325 			BUFFER_DATA_SIZE - cb->zstr.avail_out);
329 	if (cb->zstr.avail_out > 0)
337     return buf_flush (cb->buf, 0);
347     struct compress_buffer *cb = (struct compress_buffer *) closure;  local
350 	return set_block (cb->buf);
352 	return set_nonblock (cb->buf);
361     struct compress_buffer *cb = (struct compress_buffer *) closure;  local
370 	status = compress_buffer_input (cb, buf, 0, sizeof buf, &nread);
377     zstatus = inflateEnd (&cb->zstr);
380 	compress_error (0, zstatus, &cb->zstr, "inflateEnd");
384     return buf_shutdown (cb->buf);
393     struct compress_buffer *cb = (struct compress_buffer *) closure;  local
400 	cb->zstr.avail_out = BUFFER_DATA_SIZE;
401 	cb->zstr.next_out = (unsigned char *) buffer;
403 	zstatus = deflate (&cb->zstr, Z_FINISH);
406 	    compress_error (0, zstatus, &cb->zstr, "deflate finish");
410 	if (cb->zstr.avail_out != BUFFER_DATA_SIZE)
411 	    buf_output (cb->buf, buffer,
412 			BUFFER_DATA_SIZE - cb->zstr.avail_out);
415     zstatus = deflateEnd (&cb->zstr);
418 	compress_error (0, zstatus, &cb->zstr, "deflateEnd");
422     status = buf_flush (cb->buf, 1);
426     return buf_shutdown (cb->buf);