Lines Matching defs:cpy_len
886 u16_t cpy_len, buffer_space;
889 cpy_len = (u16_t)LWIP_MIN((u16_t)(p->tot_len - in_offset), msg_rem_len);
893 if (cpy_len > buffer_space) {
894 cpy_len = buffer_space;
896 pbuf_copy_partial(p, client->rx_buffer + fixed_hdr_len, cpy_len, in_offset);
899 client->msg_idx += cpy_len;
900 in_offset += cpy_len;
901 msg_rem_len -= cpy_len;
903 LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_parse_incoming: msg_idx: %"U32_F", cpy_len: %"U16_F", remaining %"U32_F"\n", client->msg_idx, cpy_len, msg_rem_len));
904 if ((msg_rem_len == 0) || (cpy_len == buffer_space)) {
906 mqtt_connection_status_t res = mqtt_message_received(client, fixed_hdr_len, cpy_len, msg_rem_len);