sys/netgraph/ng_deflate.c

177 	priv_p priv;
180 	priv = malloc(sizeof(*priv), M_NETGRAPH_DEFLATE, M_WAITOK | M_ZERO);
182 	NG_NODE_SET_PRIVATE(node, priv);
197 	const priv_p priv = NG_NODE_PRIVATE(node);
203 		priv->compress = 1;
205 		priv->compress = 0;
218 	const priv_p priv = NG_NODE_PRIVATE(node);
244 		if (priv->cfg.enable) {
245 			if (priv->compress)
246 				deflateEnd(&priv->cx);
248 				inflateEnd(&priv->cx);
249 			priv->cfg.enable = 0;
253 		priv->cfg = *cfg;
255 		if (priv->cfg.enable) {
256 			priv->cx.next_in = NULL;
257 			priv->cx.zalloc = z_alloc;
258 			priv->cx.zfree = z_free;
260 			if (priv->compress) {
261 				if ((res = deflateInit2(&priv->cx,
267 					    res, priv->cx.msg);
268 					priv->cfg.enable = 0;
272 				if ((res = inflateInit2(&priv->cx,
276 					    res, priv->cx.msg);
277 					priv->cfg.enable = 0;
284 		priv->seqnum = 0;
287 		priv->ctrlnode = NGI_RETADDR(item);
304 			bcopy(&priv->stats, resp->data,
310 			bzero(&priv->stats,
331 	const priv_p priv = NG_NODE_PRIVATE(node);
335 	if (!priv->cfg.enable) {
342 	if (priv->compress) {
353 			if (priv->ctrlnode != 0) {
362 					priv->ctrlnode, 0);
378 	const priv_p priv = NG_NODE_PRIVATE(node);
381 	if (priv->cfg.enable) {
382 	    if (priv->compress)
383 		deflateEnd(&priv->cx);
385 		inflateEnd(&priv->cx);
388 	free(priv, M_NETGRAPH_DEFLATE);
401 	const priv_p priv = NG_NODE_PRIVATE(node);
403 	if (priv->cfg.enable) {
404 	    if (priv->compress)
405 		deflateEnd(&priv->cx);
407 		inflateEnd(&priv->cx);
408 	    priv->cfg.enable = 0;
446 	const priv_p 	priv = NG_NODE_PRIVATE(node);
455 	priv->stats.FramesPlain++;
456 	priv->stats.InOctets+=inlen;
459 		priv->stats.Errors++;
467 		priv->stats.Errors++;
472 	m_copydata(m, 0, inlen, (caddr_t)priv->inbuf);
477 	if (priv->inbuf[0] != 0) {
478 		priv->cx.next_in = priv->inbuf;
479 		priv->cx.avail_in = inlen;
481 		priv->cx.next_in = priv->inbuf + 1; /* compress protocol */
482 		priv->cx.avail_in = inlen - 1;
484 	priv->cx.next_out = priv->outbuf + 2 + DEFLATE_HDRLEN;
485 	priv->cx.avail_out = outlen - 2 - DEFLATE_HDRLEN;
488 	rtn = deflate(&priv->cx, Z_PACKET_FLUSH);
492 		priv->stats.Errors++;
494 		    rtn, priv->cx.msg);
500 	outlen -= priv->cx.avail_out;
506 		priv->stats.FramesUncomp++;
507 		priv->stats.OutOctets+=inlen;
510 		be16enc(priv->outbuf, PROT_COMPD);
511 		be16enc(priv->outbuf + 2, priv->seqnum);
514 		m_copyback(m, 0, outlen, (caddr_t)priv->outbuf);
517 			priv->stats.Errors++;
522 		priv->stats.FramesComp++;
523 		priv->stats.OutOctets+=outlen;
527 	priv->seqnum++;
539 	const priv_p 	priv = NG_NODE_PRIVATE(node);
552 		priv->stats.Errors++;
554 		priv->seqnum = 0;
561 		priv->stats.Errors++;
566 	m_copydata(m, 0, inlen, (caddr_t)priv->inbuf);
569 	if ((priv->inbuf[0] & 0x01) != 0) {
570 		proto = priv->inbuf[0];
573 		proto = be16dec(priv->inbuf);
577 	priv->stats.InOctets += inlen;
581 		priv->stats.FramesComp++;
584 		rseqnum = be16dec(priv->inbuf + offset);
586 		if (rseqnum != priv->seqnum) {
587 			priv->stats.Errors++;
589 			    "instead of %u\n", rseqnum, priv->seqnum);
591 			priv->seqnum = 0;
599 		priv->cx.next_in = priv->inbuf + offset;
600 		priv->cx.avail_in = inlen - offset;
602 		priv->cx.next_out = priv->outbuf + 1;
603 		priv->cx.avail_out = outlen - 1;
606 		rtn = inflate(&priv->cx, Z_PACKET_FLUSH);
610 			priv->stats.Errors++;
612 			priv->seqnum = 0;
614 			    __func__, rtn, priv->cx.msg);
627 		outlen -= priv->cx.avail_out;
630 		if ((priv->outbuf[1] & 0x01) != 0) {
631 			priv->outbuf[0] = 0;
633 			m_copyback(m, 0, outlen, (caddr_t)priv->outbuf);
637 			m_copyback(m, 0, outlen, (caddr_t)(priv->outbuf + 1));
641 			priv->stats.Errors++;
642 			priv->seqnum = 0;
647 		priv->stats.FramesPlain++;
648 		priv->stats.OutOctets+=outlen;
651 		priv->stats.FramesUncomp++;
652 		if (priv->inbuf[0] == 0) {
653 		    priv->cx.next_in = priv->inbuf + 1; /* compress protocol */
654 		    priv->cx.avail_in = inlen - 1;
656 		    priv->cx.next_in = priv->inbuf;
657 		    priv->cx.avail_in = inlen;
660 		rtn = inflateIncomp(&priv->cx);
664 			priv->stats.Errors++;
666 			    __func__, rtn, priv->cx.msg);
668 			priv->seqnum = 0;
673 		priv->stats.FramesPlain++;
674 		priv->stats.OutOctets += inlen;
678 	priv->seqnum++;
689 	const priv_p priv = NG_NODE_PRIVATE(node);
691 	priv->seqnum = 0;
692 	if (priv->cfg.enable) {
693 	    if (priv->compress)
694 		deflateReset(&priv->cx);
696 		inflateReset(&priv->cx);