Mirrors/libwebsockets
1
0
Fork 0
mirror of https://github.com/warmcat/libwebsockets.git synced 2025-03-09 00:00:04 +01:00
Code Issues Releases Wiki Activity

ss: avs test: disable rate limiting

Browse source 
Rate limiting does not work correctly with AVS server, the last
block of rx data is not coming.  Disable it for now so the
returned data comes as rapidly as the server can send and the
client receive.
This commit is contained in:
Andy Green 2020-04-06 14:06:33 +01:00
parent 5e99b9f3ee
commit 66d1f34846
1 changed files with 9 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
minimal-examples/secure-streams/minimal-secure-streams-avs/avs.c
View file

@ -46,7 +46,7 @@ typedef struct ss_avs_metadata {
*/
lws_sorted_usec_list_t sul;
uint8_t buf[8192];
uint8_t buf[256 * 1024]; /* to test rate-limiting, set to 8 * 1024 */
int head;
int tail;
@ -125,8 +125,9 @@ ss_avs_metadata_rx(void *userobj, const uint8_t *buf, size_t len, int flags)
(int)len, (int)m->head, (int)m->tail, (int)n);
lws_ss_get_est_peer_tx_credit(m->ss);
if (len > n) {
lwsl_err("%s: bad len: len %d, n %d\n", __func__, (int)len, (int)n);
assert(0);
lwsl_err("%s: bad len\n", __func__);
return 1;
}
@ -159,11 +160,11 @@ ss_avs_metadata_tx(void *userobj, lws_ss_tx_ordinal_t ord, uint8_t *buf,
if ((long)m->pos < 0) {
*len = 0;
lwsl_notice("%s: skip tx\n", __func__);
lwsl_debug("%s: skip tx\n", __func__);
return 1;
}
lwsl_notice("%s: rideshare '%s'\n", __func__, lws_ss_rideshare(m->ss));
// lwsl_notice("%s: rideshare '%s'\n", __func__, lws_ss_rideshare(m->ss));
if (!strcmp(lws_ss_rideshare(m->ss), "avs_audio")) {
/* audio rideshare */
@ -268,7 +269,7 @@ ss_avs_event_rx(void *userobj, const uint8_t *buf, size_t len, int flags)
lwsl_notice("%s: rideshare %s, len %d, flags 0x%x\n", __func__,
lws_ss_rideshare(m->ss), (int)len, flags);
//lwsl_hexdump_warn(buf, len);
// lwsl_hexdump_warn(buf, len);
bad = 0; /* for this demo, receiving something here == success */
@ -327,8 +328,9 @@ ss_avs_event_state(void *userobj, void *sh,
* framing like multipart MIME and contains other parts
*/
ssi.manual_initial_tx_credit =
sizeof(((ss_avs_metadata_t *)0)->buf) / 2;
/* uncomment to test rate-limiting, doesn't work with AVS servers */
// ssi.manual_initial_tx_credit =
// sizeof(((ss_avs_metadata_t *)0)->buf) / 2;
if (lws_ss_create(context, 0, &ssi, context, &hss_avs_sync,
NULL, NULL)) {