Lines Matching defs:len
161 ss_avs_metadata_rx(void *userobj, const uint8_t *buf, size_t len, int flags);
253 ss_avs_metadata_rx(void *userobj, const uint8_t *buf, size_t len, int flags)
259 lwsl_notice("%s: len %d, flags %d (est peer txcr %d)\n", __func__,
260 (int)len, flags, lws_ss_get_est_peer_tx_credit(m->ss));
262 // lwsl_hexdump_warn(buf, len);
275 while (n < (int)len - 24) {
296 len -= n;
309 lws_ss_add_peer_tx_credit(m->ss, len);
331 lws_ss_add_peer_tx_credit(m->ss, len);
343 if (len) {
353 lwsl_notice("%s: SPOOL %d\n", __func__, (int)len);
354 mpg123_feed(m->mh, buf, len);
360 // len + (MAX_MP3_IN_BUFFERING_BYTES / 2));
363 // lws_ss_add_peer_tx_credit(m->ss, len);
403 if (buf && len && m->inside_mp3) {
405 __func__, (int)len, !!(flags & LWSSS_FLAG_EOM),
407 lwsl_hexdump_notice(buf, len);
408 if (lws_buflist_append_segment(&m->dribble, buf, len) < 0)
415 lws_ss_add_peer_tx_credit(m->ss, len);
419 if (!len && m->se_head != m->se_tail) {
420 /* 0-len EOM... retrospectively mark last stash */
452 size_t *len, int *flags)
461 *len = 0;
473 n = spool_capture(buf, *len);
475 *len = n;
477 *len = 0;
483 m->pos += *len;
490 lwsl_notice("%s: tx audio %d\n", __func__, (int)*len);
497 write(ff, buf, *len);
512 if (*len > tot - m->pos)
513 *len = tot - m->pos;
515 memcpy(buf, metadata + m->pos, *len);
517 m->pos += *len;
576 ss_avs_event_rx(void *userobj, const uint8_t *buf, size_t len, int flags)
583 size_t *len, int *flags)