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