Lines Matching defs:length
258 /* Use the lesser one of ring buffer linear length and TCP send buffer size */
464 mqtt_output_append_buf(struct mqtt_ringbuf_t *rb, const void *data, u16_t length)
467 for (n = 0; n < length; n++) {
473 mqtt_output_append_string(struct mqtt_ringbuf_t *rb, const char *str, u16_t length)
476 mqtt_ringbuf_put(rb, length >> 8);
477 mqtt_ringbuf_put(rb, length & 0xff);
478 for (n = 0; n < length; n++) {
490 * @param r_length Remaining length after fixed header
499 /* Encode remaining length field */
510 * @param r_length Remaining length after fixed header
516 /* Start with length of type byte + remaining length */
667 * @param fixed_hdr_len length of fixed header
668 * @param length length received part
669 * @param remaining_length Remaining length of complete message
672 mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_len, u16_t length, u32_t remaining_length)
684 LWIP_ERROR("buffer length mismatch", fixed_hdr_len + length <= MQTT_VAR_HEADER_BUFFER_LEN,
689 if (length < 2) {
713 u16_t payload_length = length;
723 if (length < 2 + qos_len) {
729 if ((topic_len > length - (2 + qos_len)) ||
737 /* Check buffer length, add one byte even for QoS 0 so that zero termination will fit */
745 if (length < after_topic + 2U) {
759 payload_length = length - after_topic;
762 LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_incomming_publish: Received message with QoS %d at topic: %s, payload length %"U32_F"\n",
771 if (length < (size_t)(payload_offset + payload_length)) {
809 if (length < 3) {
866 'remaining length'. All bytes but the last of this have 0x80 set to
871 LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_parse_incoming: Remaining length after fixed header: %"U32_F"\n", msg_rem_len));
878 /* Bytes remaining in message (changes remaining length if this is
888 /* Allow to copy the lesser one of available length in input data or bytes remaining in message */
1112 LWIP_ERROR("mqtt_publish: topic length overflow", (topic_strlen <= (0xFFFF - 2)), return ERR_ARG);
1124 LWIP_ERROR("mqtt_publish: total length overflow", (total_len <= 0xFFFF), return ERR_ARG);
1127 LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_publish: Publish with payload length %d to topic \"%s\"\n", payload_length, topic));
1186 LWIP_ERROR("mqtt_sub_unsub: topic length overflow", (topic_strlen <= (0xFFFF - 2)), return ERR_ARG);
1190 LWIP_ERROR("mqtt_sub_unsub: total length overflow", (total_len <= 0xFFFF), return ERR_ARG);
1232 * @param pub_cb Callback invoked when publish starts, contain topic and total length of payload
1319 LWIP_ERROR("mqtt_client_connect: client_info->will_topic length overflow", len <= 0xFF, return ERR_VAL);
1320 LWIP_ERROR("mqtt_client_connect: client_info->will_topic length must be > 0", len > 0, return ERR_VAL);
1323 LWIP_ERROR("mqtt_client_connect: client_info->will_msg length overflow", len <= 0xFF, return ERR_VAL);
1332 LWIP_ERROR("mqtt_client_connect: client_info->client_user length overflow", len <= 0xFFFF, return ERR_VAL);
1333 LWIP_ERROR("mqtt_client_connect: client_info->client_user length must be > 0", len > 0, return ERR_VAL);
1342 LWIP_ERROR("mqtt_client_connect: client_info->client_pass length overflow", len <= 0xFFFF, return ERR_VAL);
1343 LWIP_ERROR("mqtt_client_connect: client_info->client_pass length must be > 0", len > 0, return ERR_VAL);
1354 LWIP_ERROR("mqtt_client_connect: client_info->client_id length overflow", len <= 0xFFFF, return ERR_VAL);