Lines Matching defs:len
527 const uint8_t *buf, size_t len)
538 * Notice that len can always be 1 if under attack, even over tls if
542 while (len) {
543 lwsl_debug("%s: %d, len = %d\n", __func__, par->state, (int)len);
547 len--;
570 lwsl_notice("%s: %s: bad flags, 0x%02x mask 0x%02x (len %d)\n",
572 par->packet_type_flags, n, (int)len + 1);
573 lwsl_hexdump_err(buf - 1, len + 1);
594 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
611 switch (lws_mqtt_str_parse(&par->s_temp, &buf, &len)) {
615 if (par->s_temp.len != 4 ||
617 par->s_temp.len)) {
619 __func__, par->s_temp.len,
633 len--;
644 len--;
663 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
678 len--;
685 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
705 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
710 lwsl_debug("%s: PUBREC pkt len = %d\n",
723 if (len < 2) {
724 lwsl_notice("%s: len breakage 3\n", __func__);
731 len -= 2;
741 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
746 lwsl_debug("%s: PUBREL pkt len = %d\n",
759 if (len < 2) {
760 lwsl_notice("%s: len breakage 3\n", __func__);
767 len -= 2;
777 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
782 lwsl_debug("%s: PUBCOMP pkt len = %d\n",
795 if (len < 2) {
796 lwsl_notice("%s: len breakage 3\n", __func__);
803 len -= 2;
820 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
825 lwsl_debug("%s: PUBLISH pkt len = %d\n",
840 if (len < 2) {
845 /* Topic len */
848 len -= 2;
850 if (len < par->n) {/* the way this is written... */
851 lwsl_notice("%s: len breakage\n", __func__);
855 /* Invalid topic len */
857 lwsl_notice("%s: zero topic len\n", __func__);
861 lwsl_debug("%s: PUBLISH topic len %d\n",
880 len -= pub->topic_len;
915 if (len < 2) {
916 lwsl_notice("%s: len breakage 2\n", __func__);
922 len -= 2;
958 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
963 lwsl_debug("%s: CONNACK pkt len = %d\n",
980 len--;
1023 len--;
1056 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
1061 lwsl_debug("%s: SUBACK pkt len = %d\n",
1075 if (len < 2) {
1076 lwsl_notice("%s: len breakage 4\n", __func__);
1083 len -= 2;
1094 len--;
1126 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
1131 lwsl_debug("%s: UNSUBACK pkt len = %d\n",
1145 if (len < 2) {
1146 lwsl_notice("%s: len breakage 3\n", __func__);
1153 len -= 2;
1161 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
1166 lwsl_info("%s: PUBACK pkt len = %d\n", __func__,
1193 if (len < par->cpkt_remlen - par->n) {
1194 lwsl_notice("%s: len breakage 4\n", __func__);
1197 len--;
1213 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
1218 lwsl_info("%s: PUBACK props len = %d\n",
1245 len--;
1644 if (chunk > len)
1645 chunk = len;
1665 len -= chunk;
1668 lwsl_debug("%s: post pos %d, plen %d, len %d\n",
1670 (int)pub->payload_len, (int)len);
1706 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
1771 len--;
1786 switch (lws_mqtt_mb_parse(&par->vbit, &buf, &len)) {
1808 switch (lws_mqtt_mb_parse(&par->vbit, &buf, &len)) {
1836 switch (lws_mqtt_str_parse(&par->s_temp, &buf, &len)) {
1840 if (lws_mqtt_pconsume(par, par->s_temp.len))
1958 const void *buf, uint32_t len, int is_complete)
1968 lwsl_debug("%s: len = %d, is_complete = %d\n",
1969 __func__, (int)len, (int)is_complete);
1985 p = start + len;
2004 * Topic len field + Topic len + Packet ID
2005 * (for QOS>0) + Payload len
2009 lwsl_debug("%s: Remaining len = %d\n", __func__, (int) rem_len);
2012 if ((vh_len + len) >=
2030 (uint16_t)(unsigned int)(pub->topic_len + ((pub->qos) ? 2u : 0u) + len),
2056 memcpy(p, buf, len);
2057 if (lws_mqtt_str_advance(&mqtt_vh_payload, (int)len))
2208 * Pid + (Topic len field + Topic len + Req. QoS) x Num of Topics
2218 lwsl_debug("%s: Number of topics = %d, Remaining len = %d\n",
2378 * Pid + (Topic len field + Topic len) x Num of Topics
2388 lwsl_debug("%s: Number of topics = %d, Remaining len = %d\n",