Home
last modified time | relevance | path

Searched refs:buflist (Results 1 - 14 of 14) sorted by relevance

/third_party/libwebsockets/lib/core-net/
H A Dservice.c256 blen = lws_buflist_next_segment_len(&wsi->buflist, &buffered); in lws_rxflow_cache()
264 * the head buflist to match that situation in lws_rxflow_cache()
267 lws_buflist_use_segment(&wsi->buflist, blen - len); in lws_rxflow_cache()
279 m = lws_buflist_append_segment(&wsi->buflist, buf + n, len - n); in lws_rxflow_cache()
380 * if other material already in the buflist append it and return the buflist
391 // lws_buflist_describe(&wsi->buflist, wsi, __func__); in lws_buflist_aware_read()
408 /* there's something on the buflist? */ in lws_buflist_aware_read()
410 bns = (int)lws_buflist_next_segment_len(&wsi->buflist, &ebuf->token); in lws_buflist_aware_read()
423 if (!bns && /* only acknowledge error when we handled buflist conten in lws_buflist_aware_read()
[all...]
H A Dclose.c106 * Don't let buflist content or state from the wsi's previous life in __lws_reset_wsi()
110 lws_buflist_destroy_all_segments(&wsi->buflist); in __lws_reset_wsi()
363 lwsl_wsi_info(wsi, "going down with stuff in buflist"); in __lws_close_free_wsi()
726 lws_buflist_destroy_all_segments(&wsi->buflist); in __lws_close_free_wsi()
H A Dadopt.c588 n = lws_buflist_append_segment(&wsi->buflist, (const uint8_t *)readbuf, in adopt_socket_readbuf()
H A Dwsi.c529 if (lws_buflist_next_segment_len(&wsi->buflist, NULL)) { in __lws_rx_flow_control()
546 // lws_buflist_describe(&wsi->buflist, NULL, __func__); in __lws_rx_flow_control()
H A Dprivate-lib-core-net.h732 struct lws_buflist *buflist; /* input-side buflist */ member
733 struct lws_buflist *buflist_out; /* output-side buflist */
/third_party/libwebsockets/lib/misc/cache-ttl/
H A Dfile.c728 struct lws_buflist *buflist; member
749 if (ctx->buflist) in nsc_get_cb()
787 * on a buflist and create it when we have it all in nsc_get_cb()
790 if (lws_buflist_append_segment(&ctx->buflist, (const uint8_t *)buf, in nsc_get_cb()
801 lws_buflist_total_len(&ctx->buflist), in nsc_get_cb()
806 /* dump the buflist into the L1 cache entry */ in nsc_get_cb()
810 size_t len = lws_buflist_next_segment_len(&ctx->buflist, &p); in nsc_get_cb()
815 lws_buflist_use_segment(&ctx->buflist, len); in nsc_get_cb()
816 } while (ctx->buflist); in nsc_get_cb()
821 lws_buflist_destroy_all_segments(&ctx->buflist); in nsc_get_cb()
[all...]
/third_party/libwebsockets/lib/roles/h2/
H A Dops-h2.c199 /* 3: network wsi buflist needs to be drained */ in rops_handle_POLLIN_h2()
201 // lws_buflist_describe(&wsi->buflist, wsi, __func__); in rops_handle_POLLIN_h2()
203 ebuf.len = (int)lws_buflist_next_segment_len(&wsi->buflist, in rops_handle_POLLIN_h2()
206 lwsl_info("draining buflist (len %d)\n", ebuf.len); in rops_handle_POLLIN_h2()
307 m = (int)lws_buflist_use_segment(&wsi->buflist, (size_t)n); in rops_handle_POLLIN_h2()
318 m = lws_buflist_append_segment(&wsi->buflist, in rops_handle_POLLIN_h2()
333 // lws_buflist_describe(&wsi->buflist, wsi, __func__); in rops_handle_POLLIN_h2()
884 (blen = lws_buflist_next_segment_len(&wsi->buflist, &buffered))) { in lws_h2_bind_for_post_before_action()
892 lws_buflist_use_segment(&wsi->buflist, blen); in lws_h2_bind_for_post_before_action()
897 if (!wsi->buflist) in lws_h2_bind_for_post_before_action()
[all...]
H A Dhttp2.c2185 &h2n->swsi->buflist, NULL))
2269 &h2n->swsi->buflist, in - 1, (unsigned int)n);
2276 * to the pt list of wsi holding buflist
2306 &wsi->buflist, NULL))) {
/third_party/libwebsockets/lib/roles/mqtt/
H A Dops-mqtt.c89 /* 3: buflist needs to be drained in rops_handle_POLLIN_mqtt()
92 // lws_buflist_describe(&wsi->buflist, wsi, __func__); in rops_handle_POLLIN_mqtt()
93 ebuf.len = (int)lws_buflist_next_segment_len(&wsi->buflist, &ebuf.token); in rops_handle_POLLIN_mqtt()
95 lwsl_info("draining buflist (len %d)\n", ebuf.len); in rops_handle_POLLIN_mqtt()
156 //lws_buflist_describe(&wsi->buflist, wsi, __func__); in rops_handle_POLLIN_mqtt()
165 // lws_buflist_describe(&wsi->buflist, wsi, __func__); in rops_handle_POLLIN_mqtt()
183 !lws_buflist_next_segment_len(&wsi->buflist, NULL)) { in rops_handle_POLLIN_mqtt()
/third_party/libwebsockets/lib/roles/http/server/
H A Dserver.c2039 * own buflist, we need to deal with that first. in lws_http_action()
2046 ebuf.len = (int)lws_buflist_next_segment_len(&wsi->buflist, in lws_http_action()
2639 lws_wsi_tag(wsi), (int)wsi->wsistate, wsi->buflist); in lws_http_transaction_completed()
2672 // lws_buflist_describe(&wsi->buflist, wsi, __func__); in lws_http_transaction_completed()
2673 if (!lws_buflist_next_segment_len(&wsi->buflist, NULL)) { in lws_http_transaction_completed()
2674 lwsl_debug("%s: %s: nothing in buflist, detaching ah\n", in lws_http_transaction_completed()
2712 if (lws_buflist_next_segment_len(&wsi->buflist, NULL)) in lws_http_transaction_completed()
3064 lwsl_info("%s: completing comp partial (buflist %p, may %d)\n", in lws_serve_http_file_fragment()
/third_party/libwebsockets/lib/roles/ws/
H A Dops-ws.c1085 /* 3: buflist needs to be drained in rops_handle_POLLIN_ws()
1088 //lws_buflist_describe(&wsi->buflist, wsi, __func__); in rops_handle_POLLIN_ws()
1089 ebuf.len = (int)lws_buflist_next_segment_len(&wsi->buflist, in rops_handle_POLLIN_ws()
1092 lwsl_info("draining buflist (len %d)\n", ebuf.len); in rops_handle_POLLIN_ws()
1174 //lws_buflist_describe(&wsi->buflist, wsi, __func__); in rops_handle_POLLIN_ws()
1190 //lws_buflist_describe(&wsi->buflist, wsi, __func__); in rops_handle_POLLIN_ws()
1215 lws_buflist_total_len(&wsi->buflist)) in rops_handle_POLLIN_ws()
1237 !lws_buflist_next_segment_len(&wsi->buflist, NULL)) { in rops_handle_POLLIN_ws()
/third_party/libwebsockets/lib/roles/h1/
H A Dops-h1.c384 * regardless of our buflist state, we need to get it, in lws_h1_server_socket_service()
385 * and either use it, or append to the buflist and use in lws_h1_server_socket_service()
386 * buflist head material. in lws_h1_server_socket_service()
388 * We will not notice a connection close until the buflist is in lws_h1_server_socket_service()
640 !lws_buflist_total_len(&wsi->buflist)) in rops_handle_POLLIN_h1()
/third_party/libwebsockets/lib/roles/http/client/
H A Dclient-http.c368 if (lws_buflist_total_len(&wsi->buflist)) in lws_http_client_socket_service()
409 lwsl_debug("%s: buflist-aware-read %d %d\n", __func__, in lws_http_client_socket_service()
1344 *buf = (char *)eb.token; /* may be pointing to buflist or pt_serv_buf */ in lws_http_client_read()
/third_party/libwebsockets/lib/roles/http/
H A Dparsers.c132 lws_buflist_next_segment_len(&wsi->buflist, NULL) && in __lws_header_table_reset()

Completed in 22 milliseconds