Lines Matching refs:par
300 lws_ss_deserialize_parse(struct lws_ss_serialization_parser *par, in lws_ss_deserialize_parse() argument
315 switch (par->ps) { in lws_ss_deserialize_parse()
317 par->type = *cp++; in lws_ss_deserialize_parse()
318 par->ps++; in lws_ss_deserialize_parse()
322 par->rem = (*cp++) << 8; in lws_ss_deserialize_parse()
323 par->ps++; in lws_ss_deserialize_parse()
327 par->rem |= *cp++; in lws_ss_deserialize_parse()
328 switch (par->type) { in lws_ss_deserialize_parse()
337 par->ps = RPAR_FLAG_B3; in lws_ss_deserialize_parse()
343 par->ps = RPAR_TYPE; in lws_ss_deserialize_parse()
352 par->ps = RPAR_TYPE; in lws_ss_deserialize_parse()
362 if (par->rem < 4) in lws_ss_deserialize_parse()
364 par->ctr = 0; in lws_ss_deserialize_parse()
365 par->ps = RPAR_INITTXC0; in lws_ss_deserialize_parse()
371 if (par->rem < 3) in lws_ss_deserialize_parse()
373 par->ctr = 0; in lws_ss_deserialize_parse()
374 par->ps = RPAR_METADATA_NAMELEN; in lws_ss_deserialize_parse()
378 par->ps = RPAR_TXCR0; in lws_ss_deserialize_parse()
379 par->ctr = 0; in lws_ss_deserialize_parse()
392 par->rideshare[0] = '\0'; in lws_ss_deserialize_parse()
393 par->ps = RPAR_FLAG_B3; in lws_ss_deserialize_parse()
403 if (par->rem < 1) { in lws_ss_deserialize_parse()
407 par->ps = RPAR_RESULT_CREATION; in lws_ss_deserialize_parse()
418 if (par->rem < 4) { in lws_ss_deserialize_parse()
422 par->ps = RPAR_STATEINDEX; in lws_ss_deserialize_parse()
426 par->ctr = 0; in lws_ss_deserialize_parse()
427 par->ps = RPAR_RX_TXCR_UPDATE; in lws_ss_deserialize_parse()
432 par->type); in lws_ss_deserialize_parse()
441 par->flags <<= 8; in lws_ss_deserialize_parse()
442 par->flags |= *cp++; in lws_ss_deserialize_parse()
443 par->ps++; in lws_ss_deserialize_parse()
444 if (!par->rem--) in lws_ss_deserialize_parse()
452 par->usd_phandling <<= 8; in lws_ss_deserialize_parse()
453 par->usd_phandling |= *cp++; in lws_ss_deserialize_parse()
454 par->ps++; in lws_ss_deserialize_parse()
455 if (!par->rem--) in lws_ss_deserialize_parse()
467 par->ust_pwait <<= 8; in lws_ss_deserialize_parse()
468 par->ust_pwait |= *cp++; in lws_ss_deserialize_parse()
469 par->ps++; in lws_ss_deserialize_parse()
470 par->frag1 = 1; in lws_ss_deserialize_parse()
471 if (!par->rem--) in lws_ss_deserialize_parse()
474 if (par->ps == RPAR_RIDESHARE_LEN && in lws_ss_deserialize_parse()
475 !(par->flags & LWSSS_FLAG_RIDESHARE)) in lws_ss_deserialize_parse()
476 par->ps = RPAR_PAYLOAD; in lws_ss_deserialize_parse()
478 if (par->rem) in lws_ss_deserialize_parse()
483 if (!(par->flags & LWSSS_FLAG_RIDESHARE)) in lws_ss_deserialize_parse()
493 par->slen = *cp++; in lws_ss_deserialize_parse()
494 par->ctr = 0; in lws_ss_deserialize_parse()
495 par->ps++; in lws_ss_deserialize_parse()
496 if (par->rem-- < par->slen) in lws_ss_deserialize_parse()
501 par->rideshare[par->ctr++] = *cp++; in lws_ss_deserialize_parse()
502 if (!par->rem--) in lws_ss_deserialize_parse()
504 if (par->ctr != par->slen) in lws_ss_deserialize_parse()
506 par->ps = RPAR_PAYLOAD; in lws_ss_deserialize_parse()
507 if (par->rem) in lws_ss_deserialize_parse()
515 if (n > par->rem) in lws_ss_deserialize_parse()
516 n = par->rem; in lws_ss_deserialize_parse()
522 flags = par->flags & LWSSS_FLAG_RELATED_START; in lws_ss_deserialize_parse()
523 if (par->frag1) in lws_ss_deserialize_parse()
524 flags |= par->flags & in lws_ss_deserialize_parse()
527 if (par->rem == n) in lws_ss_deserialize_parse()
528 flags |= par->flags & (LWSSS_FLAG_EOM | in lws_ss_deserialize_parse()
531 par->frag1 = 0; in lws_ss_deserialize_parse()
549 lws_ser_wu32be(&p[3], par->flags); in lws_ss_deserialize_parse()
551 lws_ser_wu32be(&p[7], par->usd_phandling); in lws_ss_deserialize_parse()
553 lws_ser_wu32be(&p[11], us - par->ust_pwait); in lws_ss_deserialize_parse()
576 h = lws_container_of(par, lws_sspc_handle_t, parser); in lws_ss_deserialize_parse()
590 par->usd_phandling; in lws_ss_deserialize_parse()
592 us - par->ust_pwait; in lws_ss_deserialize_parse()
601 par->rem -= n; in lws_ss_deserialize_parse()
604 if (!par->rem) in lws_ss_deserialize_parse()
605 par->ps = RPAR_TYPE; in lws_ss_deserialize_parse()
609 if (!--par->rem && par->ctr != 3) in lws_ss_deserialize_parse()
612 par->temp32 = (par->temp32 << 8) | *cp++; in lws_ss_deserialize_parse()
613 if (++par->ctr < 4) in lws_ss_deserialize_parse()
621 h = lws_container_of(par, lws_sspc_handle_t, parser); in lws_ss_deserialize_parse()
622 h->txc.tx_cr += par->temp32; in lws_ss_deserialize_parse()
623 lwsl_info("%s: RX_PEER_TXCR: %d\n", __func__, par->temp32); in lws_ss_deserialize_parse()
625 par->ctr = 0; in lws_ss_deserialize_parse()
626 par->ps = RPAR_TYPE; in lws_ss_deserialize_parse()
630 if (!--par->rem) in lws_ss_deserialize_parse()
633 par->temp32 = (par->temp32 << 8) | *cp++; in lws_ss_deserialize_parse()
634 if (++par->ctr < 4) in lws_ss_deserialize_parse()
637 par->txcr_out = par->temp32; in lws_ss_deserialize_parse()
638 par->ctr = 0; in lws_ss_deserialize_parse()
639 par->ps = RPAR_STREAMTYPE; in lws_ss_deserialize_parse()
649 par->temp32 = (par->temp32 << 8) | *cp++; in lws_ss_deserialize_parse()
650 if (++par->ctr < 4) { in lws_ss_deserialize_parse()
651 if (!--par->rem) in lws_ss_deserialize_parse()
656 if (--par->rem) in lws_ss_deserialize_parse()
669 par->temp32); in lws_ss_deserialize_parse()
671 __func__, par->temp32, in lws_ss_deserialize_parse()
684 h = lws_container_of(par, lws_sspc_handle_t, parser); in lws_ss_deserialize_parse()
685 h->txc.tx_cr += par->temp32; in lws_ss_deserialize_parse()
687 __func__, par->temp32); in lws_ss_deserialize_parse()
690 par->ps = RPAR_TYPE; in lws_ss_deserialize_parse()
694 if (!--par->rem) in lws_ss_deserialize_parse()
696 par->slen = *cp++; in lws_ss_deserialize_parse()
697 if (par->slen >= sizeof(par->metadata_name) - 1) in lws_ss_deserialize_parse()
699 par->ctr = 0; in lws_ss_deserialize_parse()
700 par->ps++; in lws_ss_deserialize_parse()
704 if (!--par->rem) in lws_ss_deserialize_parse()
706 par->metadata_name[par->ctr++] = *cp++; in lws_ss_deserialize_parse()
707 if (par->ctr != par->slen) in lws_ss_deserialize_parse()
709 par->ps = RPAR_METADATA_VALUE; in lws_ss_deserialize_parse()
718 par->metadata_name); in lws_ss_deserialize_parse()
721 __func__, par->metadata_name); in lws_ss_deserialize_parse()
726 par->ssmd = &(*pss)->metadata[pm->length]; in lws_ss_deserialize_parse()
728 if (par->ssmd->value_on_lws_heap) in lws_ss_deserialize_parse()
729 lws_free_set_NULL(par->ssmd->value); in lws_ss_deserialize_parse()
730 par->ssmd->value_on_lws_heap = 0; in lws_ss_deserialize_parse()
732 par->ssmd->value = lws_malloc(par->rem + 1, "metadata"); in lws_ss_deserialize_parse()
733 if (!par->ssmd->value) { in lws_ss_deserialize_parse()
737 par->ssmd->length = par->rem; in lws_ss_deserialize_parse()
739 par->ssmd->value_on_lws_heap = 1; in lws_ss_deserialize_parse()
740 par->ctr = 0; in lws_ss_deserialize_parse()
744 ((uint8_t *)(par->ssmd->value))[par->ctr++] = *cp++; in lws_ss_deserialize_parse()
745 if (--par->rem) in lws_ss_deserialize_parse()
750 __func__, par->ssmd->name, in lws_ss_deserialize_parse()
751 (int)par->ssmd->length); in lws_ss_deserialize_parse()
752 lwsl_hexdump_info(par->ssmd->value, par->ssmd->length); in lws_ss_deserialize_parse()
753 par->ps = RPAR_TYPE; in lws_ss_deserialize_parse()
759 if (par->ctr == sizeof(par->streamtype) - 1) in lws_ss_deserialize_parse()
767 par->streamtype[par->ctr++] = *cp++; in lws_ss_deserialize_parse()
768 if (--par->rem) in lws_ss_deserialize_parse()
771 par->ps = RPAR_TYPE; in lws_ss_deserialize_parse()
772 par->streamtype[par->ctr] = '\0'; in lws_ss_deserialize_parse()
774 __func__, par->streamtype, par->txcr_out); in lws_ss_deserialize_parse()
776 ssi->streamtype = par->streamtype; in lws_ss_deserialize_parse()
777 if (par->txcr_out) in lws_ss_deserialize_parse()
778 ssi->manual_initial_tx_credit = par->txcr_out; in lws_ss_deserialize_parse()
787 __func__, par->streamtype); in lws_ss_deserialize_parse()
791 __func__, par->streamtype); in lws_ss_deserialize_parse()
798 __func__, par->txcr_out); in lws_ss_deserialize_parse()
799 (*pss)->info.manual_initial_tx_credit = par->txcr_out; in lws_ss_deserialize_parse()
816 h = lws_container_of(par, lws_sspc_handle_t, parser); in lws_ss_deserialize_parse()
829 par->rsl_pos = 0; in lws_ss_deserialize_parse()
830 par->rsl_idx = 0; in lws_ss_deserialize_parse()
831 h = lws_container_of(par, lws_sspc_handle_t, parser); in lws_ss_deserialize_parse()
836 if (!--par->rem) in lws_ss_deserialize_parse()
837 par->ps = RPAR_TYPE; in lws_ss_deserialize_parse()
839 par->ps = RPAR_RESULT_CREATION_RIDESHARE; in lws_ss_deserialize_parse()
840 if (par->rem >= sizeof(h->rideshare_list)) in lws_ss_deserialize_parse()
846 h = lws_container_of(par, lws_sspc_handle_t, parser); in lws_ss_deserialize_parse()
849 h->rideshare_list[par->rsl_pos++] = '\0'; in lws_ss_deserialize_parse()
850 if (par->rsl_idx == LWS_ARRAY_SIZE(h->rideshare_ofs)) in lws_ss_deserialize_parse()
852 h->rideshare_ofs[++par->rsl_idx] = par->rsl_pos; in lws_ss_deserialize_parse()
854 h->rideshare_list[par->rsl_pos++] = *cp++; in lws_ss_deserialize_parse()
855 if (!--par->rem) in lws_ss_deserialize_parse()
856 par->ps = RPAR_TYPE; in lws_ss_deserialize_parse()
860 par->ctr = *cp++; in lws_ss_deserialize_parse()
861 par->ps = RPAR_ORD3; in lws_ss_deserialize_parse()
865 par->flags = (*cp++) << 24; in lws_ss_deserialize_parse()
866 par->ps++; in lws_ss_deserialize_parse()
870 par->flags |= (*cp++) << 16; in lws_ss_deserialize_parse()
871 par->ps++; in lws_ss_deserialize_parse()
875 par->flags |= (*cp++) << 8; in lws_ss_deserialize_parse()
876 par->ps++; in lws_ss_deserialize_parse()
880 par->flags |= *cp++; in lws_ss_deserialize_parse()
881 par->ps++; in lws_ss_deserialize_parse()
882 par->ps = RPAR_TYPE; in lws_ss_deserialize_parse()
888 switch (par->ctr) { in lws_ss_deserialize_parse()
905 if (par->ctr < 0 || par->ctr > 9) in lws_ss_deserialize_parse()
910 __func__, sn[par->ctr]); in lws_ss_deserialize_parse()
912 if (ssi->state((void *)pss, NULL, par->ctr, par->flags)) in lws_ss_deserialize_parse()