Searched refs:remaining_length (Results 1 – 9 of 9) sorted by relevance
| /third_party/lwip/src/apps/mqtt/ |
| D | mqtt.c | 672 …t_message_received(mqtt_client_t *client, u8_t fixed_hdr_idx, u16_t length, u32_t remaining_length) in mqtt_message_received() argument
764 qos, topic, remaining_length + payload_length)); in mqtt_message_received()
766 client->pub_cb(client->inpub_arg, (const char *)topic, remaining_length + payload_length); in mqtt_message_received()
771 if (payload_length > 0 || remaining_length == 0) { in mqtt_message_received()
776 …lient->inpub_arg, var_hdr_payload + payload_offset, payload_length, remaining_length == 0 ? MQTT_D… in mqtt_message_received()
778 if (remaining_length == 0 && qos > 0) { in mqtt_message_received()
1105 u16_t remaining_length; in mqtt_publish() local
1126 remaining_length = (u16_t)total_len; in mqtt_publish()
1135 if (mqtt_output_check_space(&client->output, remaining_length) == 0) { in mqtt_publish()
1140 …tput_append_fixed_header(&client->output, MQTT_MSG_TYPE_PUBLISH, 0, qos, retain, remaining_length); in mqtt_publish()
[all …]
|
| /third_party/curl/tests/server/ |
| D | mqttd.c | 501 size_t remaining_length = 0; in mqttit() local
539 rc = fixedheader(fd, &byte, &remaining_length, &bytes); in mqttit()
543 if(remaining_length >= buff_size) { in mqttit()
544 buff_size = remaining_length; in mqttit()
552 if(remaining_length) { in mqttit()
554 rc = sread(fd, (char *)buffer, remaining_length); in mqttit()
562 logprotocol(FROM_CLIENT, "CONNECT", remaining_length, in mqttit()
619 logprotocol(FROM_CLIENT, "SUBSCRIBE", remaining_length, in mqttit()
633 if(topic_len != (remaining_length - 5)) { in mqttit()
635 topic_len, remaining_length - 5); in mqttit()
[all …]
|
| /third_party/skia/third_party/externals/sfntly/cpp/src/sfntly/data/ |
| D | byte_array.cc | 115 int32_t remaining_length = length; in CopyTo() local
122 remaining_length -= bytes_read; in CopyTo()
123 buffer_length = std::min<int32_t>(b.size(), remaining_length); in CopyTo()
|
| /third_party/flutter/skia/third_party/externals/sfntly/cpp/src/sfntly/data/ |
| D | byte_array.cc | 115 int32_t remaining_length = length; in CopyTo() local
122 remaining_length -= bytes_read; in CopyTo()
123 buffer_length = std::min<int32_t>(b.size(), remaining_length); in CopyTo()
|
| /third_party/gstreamer/gstplugins_good/sys/waveform/ |
| D | gstwaveformsink.c | 446 guint remaining_length = length; in gst_waveform_sink_write() local
450 while (remaining_length > 0) { in gst_waveform_sink_write()
472 if (wfsink->buffer_size - waveheader->dwUser >= remaining_length) in gst_waveform_sink_write()
473 bytes_to_write = remaining_length; in gst_waveform_sink_write()
479 remaining_length -= bytes_to_write; in gst_waveform_sink_write()
|
| /third_party/curl/lib/ |
| D | mqtt.h | 56 size_t remaining_length; member
|
| D | mqtt.c | 624 remlen = mq->remaining_length; in mqtt_read_publish()
743 mq->remaining_length = mqtt_decode_len(&pkt[0], mq->npacket, NULL); in mqtt_doing()
745 if(mq->remaining_length) { in mqtt_doing()
|
| /third_party/libcoap/src/ |
| D | resource.c | 117 size_t remaining_length = text->length; in match() local
118 while (remaining_length) { in match()
121 next_token = (unsigned char *)memchr(token, ' ', remaining_length); in match()
125 remaining_length -= (token_length + 1); in match()
128 token_length = remaining_length; in match()
129 remaining_length = 0; in match()
|
| /third_party/jerryscript/jerry-core/ecma/builtin-objects/ |
| D | ecma-builtin-date.c | 344 ecma_length_t remaining_length = lit_utf8_string_length (date_str_curr_p, in ecma_builtin_date_parse_ISO_string_format() local
347 if (remaining_length >= 5) in ecma_builtin_date_parse_ISO_string_format()
|