Lines Matching defs:buf
527 const uint8_t *buf, size_t len)
546 par->packet_type_flags = *buf++;
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)) {
616 memcmp(par->s_temp.buf, "MQTT",
620 par->s_temp.buf);
632 par->conn_protocol_version = *buf++;
643 par->cpkt_flags = *buf++;
663 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
680 if (*buf++)
685 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
705 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
728 par->cpkt_id = lws_ser_ru16be(buf);
730 buf += 2;
741 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
764 par->cpkt_id = lws_ser_ru16be(buf);
766 buf += 2;
777 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
800 par->cpkt_id = lws_ser_ru16be(buf);
802 buf += 2;
820 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
846 par->n = lws_ser_ru16be(buf);
847 buf += 2;
877 lws_strncpy(pub->topic, (const char *)buf,
879 buf += pub->topic_len;
920 par->cpkt_id = lws_ser_ru16be(buf);
921 buf += 2;
945 pub->payload = buf;
958 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
979 par->cpkt_flags = *buf++;
1022 par->conn_rc = *buf++;
1056 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
1080 par->cpkt_id = lws_ser_ru16be(buf);
1082 buf += 2;
1092 lws_mqtt_qos_levels_t qos = (lws_mqtt_qos_levels_t)*buf++;
1126 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
1150 par->cpkt_id = lws_ser_ru16be(buf);
1152 buf += 2;
1161 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
1192 par->fixed_seen[par->fixed++] = *buf++;
1213 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
1246 buf++;
1666 buf += chunk;
1706 switch (lws_mqtt_vbi_r(&par->vbit, &buf, &len)) {
1770 par->payload_format = *buf++;
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)) {
1958 const void *buf, uint32_t len, int is_complete)
1984 start = (uint8_t *)buf;
2056 memcpy(p, buf, len);