Function xs_deflate_push

modules/data/zlib/deflate.c:100–162

}

void xs_deflate_push(xsMachine *the)
{
	uint8_t *output = xsmcGetHostDataValidate(xsThis, xs_deflate_destructor);
	z_stream *zlib = (z_stream *)(kOutputBufferSize + (char *)output); 
	int inputOffset = 0;
	xsUnsignedValue inputRemaining;
	void *input;
	int inputEnd = (xsmcArgc > 1) ? xsmcTest(xsArg(1)) : 0;
	int status = Z_OK;
	uint8_t isString = xsStringType == xsmcTypeOf(xsArg(0));

	if (isString)
		inputRemaining = c_strlen(xsmcToString(xsArg(0)));
	else
		xsmcGetBufferReadable(xsArg(0), &input, &inputRemaining);

	while ((0 != inputRemaining) || (Z_OK == status)) {
		zlib->next_out	= output;
		zlib->avail_out	= kOutputBufferSize;
		zlib->total_out	= 0;

		if (isString)
			zlib->next_in = inputOffset + (uint8_t *)xsmcToString(xsArg(0));
		else {
			xsUnsignedValue ignore;
			xsmcGetBufferReadable(xsArg(0), &input, &ignore);
			zlib->next_in = inputOffset + (uint8_t *)input;
		}
		zlib->avail_in = inputRemaining;
		zlib->total_in = 0;

		status = deflate(zlib, (inputEnd ? Z_FINISH : Z_NO_FLUSH));
		if (Z_BUF_ERROR == status) {
			status = Z_OK;
			goto bail;
		}
		if ((Z_OK != status) && (Z_STREAM_END != status)) {
			xs_deflate_close(the);

			xsmcSetInteger(xsResult, status);
			xsCall1(xsThis, xsID_onEnd, xsResult);
			goto bail;
		}

		if (zlib->total_out) {
			xsmcSetArrayBuffer(xsResult, output, zlib->total_out);
			xsCall1(xsThis, xsID_onData, xsResult);
		}

		inputOffset += zlib->total_in;
		inputRemaining -= zlib->total_in;
	}

	if (inputEnd || (status == Z_STREAM_END)) {
		xs_deflate_close(the);

		xsmcSetInteger(xsResult, (Z_STREAM_END == status) ? Z_OK : status);
		xsCall1(xsThis, xsID_onEnd, xsResult);