Lines Matching refs:rx
53 /* cap the RX buf at the nearest power of 2 to protocol rx buf */
65 lwsl_wsi_info(wsi, " Capping pmd rx to %d", 1 << extra);
179 (void)inflateEnd(&priv->rx);
192 pmdrx->eb_in.len, priv->rx.avail_in);
220 pmdrx->eb_in.len, priv->rx.avail_in, wsi->ws->final);
225 if (inflateInit2(&priv->rx,
235 "pmd rx inflate buf");
248 if (priv->rx.avail_in && pmdrx->eb_in.token &&
250 lwsl_wsi_warn(wsi, "priv->rx.avail_in %d while getting new in",
251 priv->rx.avail_in);
255 if (!priv->rx.avail_in && pmdrx->eb_in.token && pmdrx->eb_in.len) {
256 priv->rx.next_in = (unsigned char *)pmdrx->eb_in.token;
257 priv->rx.avail_in = (uInt)pmdrx->eb_in.len;
260 priv->rx.next_out = priv->buf_rx_inflated + LWS_PRE;
261 pmdrx->eb_out.token = priv->rx.next_out;
262 priv->rx.avail_out = (uInt)(1 << priv->args[PMD_RX_BUF_PWR2]);
275 if (!priv->rx.avail_in &&
282 priv->rx.next_in = trail;
283 priv->rx.avail_in = sizeof(trail);
291 if (!priv->rx.avail_in)
294 n = inflate(&priv->rx, was_fin ? Z_SYNC_FLUSH : Z_NO_FLUSH);
296 priv->rx.avail_in, priv->rx.avail_out, wsi->ws->final);
303 n, priv->rx.msg);
312 ((unsigned int)pmdrx->eb_in.len - (unsigned int)priv->rx.avail_in);
313 pmdrx->eb_in.len = (int)priv->rx.avail_in;
316 priv->rx.avail_in,
322 if (!priv->rx.avail_in &&
331 priv->rx.avail_out += 5;
335 priv->rx.next_in = trail;
336 priv->rx.avail_in = sizeof(trail);
337 n = inflate(&priv->rx, Z_SYNC_FLUSH);
339 n, priv->rx.avail_in, priv->rx.avail_out);
346 n, priv->rx.msg);
350 assert(priv->rx.avail_out);
353 pmdrx->eb_out.len = lws_ptr_diff(priv->rx.next_out,
358 "rx.avail_in=%d, TOTAL RX since FIN %lu",
359 pmdrx->eb_out.len, priv->rx.avail_in,
367 (void)inflateEnd(&priv->rx);
374 if (priv->rx.avail_in)