Lines Matching defs:ONW
49 ONW
106 if (conn->r[ONW])
107 lws_ring_destroy(conn->r[ONW]);
143 i.pwsi = &pss->conn->wsi[ONW];
166 lwsl_info("%s: %s side: %s\n", __func__, side ? "ONW" : "ACC",
267 conn->established[ONW] = 1;
270 conn->rx_enabled[ONW] = 1;
284 conn->closed[ONW] = 1;
311 if (!lws_ring_insert(conn->r[ONW], &pkt, 1)) {
318 (int)lws_ring_get_count_free_elements(conn->r[ONW]));
320 if (conn->rx_enabled[ONW] &&
321 lws_ring_get_count_free_elements(conn->r[ONW]) < 2)
322 flow_control(conn, ONW, 0);
386 if (lws_ring_get_element(conn->r[ONW], &conn->t[ONW]))
411 conn->r[ONW] = lws_ring_create(sizeof(struct packet),
413 if (!conn->r[ONW]) {
439 if (conn->closed[ONW])
446 if (!conn || !conn->wsi[ONW]) {
448 "conn->wsi[ONW] NULL\n", __func__);
451 if (conn->closed[ONW]) {
452 lwsl_info(" closed[ONW] %d\n", conn->closed[ONW]);
481 if (conn->established[ONW] && !conn->closed[ONW])
482 lws_callback_on_writable(conn->wsi[ONW]);
488 if (!conn || !conn->established[ONW] || conn->closed[ONW])
491 ppkt = lws_ring_get_element(conn->r[ONW], &conn->t[ONW]);
501 lws_callback_on_writable(conn->wsi[ONW]);
513 lws_ring_consume(conn->r[ONW], &conn->t[ONW], NULL, 1);
514 lws_ring_update_oldest_tail(conn->r[ONW], conn->t[ONW]);
517 (int)lws_ring_get_count_free_elements(conn->r[ONW]),
518 (int)lws_ring_get_count_waiting_elements(conn->r[ONW],
519 &conn->t[ONW]));
521 if (!conn->rx_enabled[ONW] &&
522 lws_ring_get_count_free_elements(conn->r[ONW]) > 2)
523 flow_control(conn, ONW, 1);
525 ppkt = lws_ring_get_element(conn->r[ONW], &conn->t[ONW]);
537 if (conn->closed[ONW])
546 lws_callback_on_writable(conn->wsi[ONW]);