Lines Matching refs:ebuf
193 struct lws_tokens ebuf; in lws_mqtt_client_socket_service() local
310 ebuf.token = pt->serv_buf; in lws_mqtt_client_socket_service()
311 ebuf.len = (int)wsi->a.context->pt_serv_buf_size; in lws_mqtt_client_socket_service()
313 if ((unsigned int)ebuf.len > wsi->a.context->pt_serv_buf_size) in lws_mqtt_client_socket_service()
314 ebuf.len = (int)wsi->a.context->pt_serv_buf_size; in lws_mqtt_client_socket_service()
316 if ((int)pending > ebuf.len) in lws_mqtt_client_socket_service()
317 pending = (char)ebuf.len; in lws_mqtt_client_socket_service()
319 ebuf.len = lws_ssl_capable_read(wsi, ebuf.token, in lws_mqtt_client_socket_service()
321 ebuf.len)); in lws_mqtt_client_socket_service()
322 switch (ebuf.len) { in lws_mqtt_client_socket_service()
336 if (ebuf.len < 0) in lws_mqtt_client_socket_service()
339 n = lws_read_mqtt(wsi, ebuf.token, (unsigned int)ebuf.len); in lws_mqtt_client_socket_service()
345 m = ebuf.len - n; in lws_mqtt_client_socket_service()
347 lwsl_debug("%s: consuming %d / %d\n", __func__, n, ebuf.len); in lws_mqtt_client_socket_service()
348 if (lws_buflist_aware_finished_consuming(wsi, &ebuf, m, in lws_mqtt_client_socket_service()