sys/netgraph/ng_deflate.c

172 	priv_p priv;
175 	priv = malloc(sizeof(*priv), M_NETGRAPH_DEFLATE, M_WAITOK | M_ZERO);
177 	NG_NODE_SET_PRIVATE(node, priv);
192 	const priv_p priv = NG_NODE_PRIVATE(node);
198 		priv->compress = 1;
200 		priv->compress = 0;
213 	const priv_p priv = NG_NODE_PRIVATE(node);
239 		if (priv->cfg.enable) {
240 			if (priv->compress)
241 				deflateEnd(&priv->cx);
243 				inflateEnd(&priv->cx);
244 			priv->cfg.enable = 0;
248 		priv->cfg = *cfg;
250 		if (priv->cfg.enable) {
251 			priv->cx.next_in = NULL;
253 			if (priv->compress) {
254 				if ((res = deflateInit2(&priv->cx,
260 					    res, priv->cx.msg);
261 					priv->cfg.enable = 0;
265 				if ((res = inflateInit2(&priv->cx,
269 					    res, priv->cx.msg);
270 					priv->cfg.enable = 0;
277 		priv->seqnum = 0;
280 		priv->ctrlnode = NGI_RETADDR(item);
297 			bcopy(&priv->stats, resp->data,
303 			bzero(&priv->stats,
324 	const priv_p priv = NG_NODE_PRIVATE(node);
328 	if (!priv->cfg.enable) {
335 	if (priv->compress) {
345 			if (priv->ctrlnode != 0) {
354 					priv->ctrlnode, 0);
370 	const priv_p priv = NG_NODE_PRIVATE(node);
373 	if (priv->cfg.enable) {
374 	    if (priv->compress)
375 		deflateEnd(&priv->cx);
377 		inflateEnd(&priv->cx);
380 	free(priv, M_NETGRAPH_DEFLATE);
393 	const priv_p priv = NG_NODE_PRIVATE(node);
395 	if (priv->cfg.enable) {
396 	    if (priv->compress)
397 		deflateEnd(&priv->cx);
399 		inflateEnd(&priv->cx);
400 	    priv->cfg.enable = 0;
420 	const priv_p 	priv = NG_NODE_PRIVATE(node);
429 	priv->stats.FramesPlain++;
430 	priv->stats.InOctets+=inlen;
433 		priv->stats.Errors++;
441 		priv->stats.Errors++;
446 	m_copydata(m, 0, inlen, (caddr_t)priv->inbuf);
451 	if (priv->inbuf[0] != 0) {
452 		priv->cx.next_in = priv->inbuf;
453 		priv->cx.avail_in = inlen;
455 		priv->cx.next_in = priv->inbuf + 1; /* compress protocol */
456 		priv->cx.avail_in = inlen - 1;
458 	priv->cx.next_out = priv->outbuf + 2 + DEFLATE_HDRLEN;
459 	priv->cx.avail_out = outlen - 2 - DEFLATE_HDRLEN;
462 	rtn = deflate(&priv->cx, Z_SYNC_FLUSH);
466 		priv->stats.Errors++;
468 		    rtn, priv->cx.msg);
474 	outlen -= priv->cx.avail_out;
484 	MPASS(priv->outbuf[outlen + 0] == 0x00);
485 	MPASS(priv->outbuf[outlen + 1] == 0x00);
486 	MPASS(priv->outbuf[outlen + 2] == 0xff);
487 	MPASS(priv->outbuf[outlen + 3] == 0xff);
493 		priv->stats.FramesUncomp++;
494 		priv->stats.OutOctets+=inlen;
497 		be16enc(priv->outbuf, PROT_COMPD);
498 		be16enc(priv->outbuf + 2, priv->seqnum);
501 		m_copyback(m, 0, outlen, (caddr_t)priv->outbuf);
504 			priv->stats.Errors++;
509 		priv->stats.FramesComp++;
510 		priv->stats.OutOctets+=outlen;
514 	priv->seqnum++;
526 	const priv_p 	priv = NG_NODE_PRIVATE(node);
541 		priv->stats.Errors++;
543 		priv->seqnum = 0;
550 		priv->stats.Errors++;
555 	m_copydata(m, 0, inlen, (caddr_t)priv->inbuf);
558 	if ((priv->inbuf[0] & 0x01) != 0) {
559 		proto = priv->inbuf[0];
562 		proto = be16dec(priv->inbuf);
566 	priv->stats.InOctets += inlen;
570 		priv->stats.FramesComp++;
573 		rseqnum = be16dec(priv->inbuf + offset);
575 		if (rseqnum != priv->seqnum) {
576 			priv->stats.Errors++;
578 			    "instead of %u\n", rseqnum, priv->seqnum);
580 			priv->seqnum = 0;
588 		priv->cx.next_in = priv->inbuf + offset;
589 		priv->cx.avail_in = inlen - offset;
591 		priv->cx.next_out = priv->outbuf + 1;
592 		priv->cx.avail_out = outlen - 1;
595 		rtn = inflate(&priv->cx, Z_SYNC_FLUSH);
599 			priv->stats.Errors++;
601 			priv->seqnum = 0;
603 			    __func__, rtn, priv->cx.msg);
616 		if (inflateSyncPoint(&priv->cx)) {
617 			priv->cx.avail_in = 4;
618 			priv->cx.next_in = EMPTY_BLOCK;
619 			inflate(&priv->cx, Z_SYNC_FLUSH);
623 		outlen -= priv->cx.avail_out;
626 		if ((priv->outbuf[1] & 0x01) != 0) {
627 			priv->outbuf[0] = 0;
629 			m_copyback(m, 0, outlen, (caddr_t)priv->outbuf);
633 			m_copyback(m, 0, outlen, (caddr_t)(priv->outbuf + 1));
637 			priv->stats.Errors++;
638 			priv->seqnum = 0;
643 		priv->stats.FramesPlain++;
644 		priv->stats.OutOctets+=outlen;
648 		priv->stats.FramesUncomp++;
660 		priv->cx.next_in = headbuf;
661 		priv->cx.avail_in = sizeof(headbuf);
662 		priv->cx.next_out = priv->outbuf;
663 		priv->cx.avail_out = DEFLATE_BUF_SIZE;
665 		rtn = inflate(&priv->cx, Z_NO_FLUSH);
667 		if (priv->inbuf[0] == 0) {
668 			priv->cx.next_in =
669 			    priv->inbuf + 1; /* compress protocol */
670 			priv->cx.avail_in = inlen - 1;
672 			priv->cx.next_in = priv->inbuf;
673 			priv->cx.avail_in = inlen;
675 		priv->cx.next_out = priv->outbuf;
676 		priv->cx.avail_out = DEFLATE_BUF_SIZE;
678 		rtn = inflate(&priv->cx, Z_SYNC_FLUSH);
682 			priv->stats.Errors++;
684 			    __func__, rtn, priv->cx.msg);
686 			priv->seqnum = 0;
691 		priv->stats.FramesPlain++;
692 		priv->stats.OutOctets += inlen;
696 	priv->seqnum++;
707 	const priv_p priv = NG_NODE_PRIVATE(node);
709 	priv->seqnum = 0;
710 	if (priv->cfg.enable) {
711 	    if (priv->compress)
712 		deflateReset(&priv->cx);
714 		inflateReset(&priv->cx);