Lines Matching refs:rx
179 (void)inflateEnd(&priv->rx); in lws_extension_callback_pm_deflate()
192 pmdrx->eb_in.len, priv->rx.avail_in); in lws_extension_callback_pm_deflate()
220 pmdrx->eb_in.len, priv->rx.avail_in, wsi->ws->final); in lws_extension_callback_pm_deflate()
225 if (inflateInit2(&priv->rx, in lws_extension_callback_pm_deflate()
248 if (priv->rx.avail_in && pmdrx->eb_in.token && in lws_extension_callback_pm_deflate()
251 priv->rx.avail_in); in lws_extension_callback_pm_deflate()
255 if (!priv->rx.avail_in && pmdrx->eb_in.token && pmdrx->eb_in.len) { in lws_extension_callback_pm_deflate()
256 priv->rx.next_in = (unsigned char *)pmdrx->eb_in.token; in lws_extension_callback_pm_deflate()
257 priv->rx.avail_in = (uInt)pmdrx->eb_in.len; in lws_extension_callback_pm_deflate()
260 priv->rx.next_out = priv->buf_rx_inflated + LWS_PRE; in lws_extension_callback_pm_deflate()
261 pmdrx->eb_out.token = priv->rx.next_out; in lws_extension_callback_pm_deflate()
262 priv->rx.avail_out = (uInt)(1 << priv->args[PMD_RX_BUF_PWR2]); in lws_extension_callback_pm_deflate()
275 if (!priv->rx.avail_in && in lws_extension_callback_pm_deflate()
282 priv->rx.next_in = trail; in lws_extension_callback_pm_deflate()
283 priv->rx.avail_in = sizeof(trail); in lws_extension_callback_pm_deflate()
291 if (!priv->rx.avail_in) in lws_extension_callback_pm_deflate()
294 n = inflate(&priv->rx, was_fin ? Z_SYNC_FLUSH : Z_NO_FLUSH); in lws_extension_callback_pm_deflate()
296 priv->rx.avail_in, priv->rx.avail_out, wsi->ws->final); in lws_extension_callback_pm_deflate()
303 n, priv->rx.msg); in lws_extension_callback_pm_deflate()
312 ((unsigned int)pmdrx->eb_in.len - (unsigned int)priv->rx.avail_in); in lws_extension_callback_pm_deflate()
313 pmdrx->eb_in.len = (int)priv->rx.avail_in; in lws_extension_callback_pm_deflate()
316 priv->rx.avail_in, in lws_extension_callback_pm_deflate()
322 if (!priv->rx.avail_in && in lws_extension_callback_pm_deflate()
331 priv->rx.avail_out += 5; in lws_extension_callback_pm_deflate()
335 priv->rx.next_in = trail; in lws_extension_callback_pm_deflate()
336 priv->rx.avail_in = sizeof(trail); in lws_extension_callback_pm_deflate()
337 n = inflate(&priv->rx, Z_SYNC_FLUSH); in lws_extension_callback_pm_deflate()
339 n, priv->rx.avail_in, priv->rx.avail_out); in lws_extension_callback_pm_deflate()
346 n, priv->rx.msg); in lws_extension_callback_pm_deflate()
350 assert(priv->rx.avail_out); in lws_extension_callback_pm_deflate()
353 pmdrx->eb_out.len = lws_ptr_diff(priv->rx.next_out, in lws_extension_callback_pm_deflate()
359 pmdrx->eb_out.len, priv->rx.avail_in, in lws_extension_callback_pm_deflate()
367 (void)inflateEnd(&priv->rx); in lws_extension_callback_pm_deflate()
374 if (priv->rx.avail_in) in lws_extension_callback_pm_deflate()