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_len, u16_t length, u32_t remaining_length) in mqtt_message_received() argument
763 qos, topic, remaining_length + payload_length)); in mqtt_message_received()
765 client->pub_cb(client->inpub_arg, (const char *)topic, remaining_length + payload_length); in mqtt_message_received()
770 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()
779 if (remaining_length == 0 && qos > 0) { in mqtt_message_received()
1104 u16_t remaining_length; in mqtt_publish() local
1125 remaining_length = (u16_t)total_len; in mqtt_publish()
1134 if (mqtt_output_check_space(&client->output, remaining_length) == 0) { in mqtt_publish()
1139 …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
541 rc = fixedheader(fd, &byte, &remaining_length, &bytes); in mqttit()
545 if(remaining_length >= buff_size) { in mqttit()
546 buff_size = remaining_length; in mqttit()
554 if(remaining_length) { in mqttit()
556 rc = sread(fd, (char *)buffer, remaining_length); in mqttit()
564 logprotocol(FROM_CLIENT, "CONNECT", remaining_length, in mqttit()
623 logprotocol(FROM_CLIENT, "SUBSCRIBE", remaining_length, in mqttit()
637 if(topic_len != (remaining_length - 5)) { in mqttit()
639 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/curl/lib/ |
| D | mqtt.h | 58 size_t remaining_length; member
|
| D | mqtt.c | 663 remlen = mq->remaining_length; in mqtt_read_publish()
793 mq->remaining_length = mqtt_decode_len(mq->pkt_hd, mq->npacket, NULL); in mqtt_doing()
795 if(mq->remaining_length) { in mqtt_doing()
|
| /third_party/libcoap/src/ |
| D | coap_resource.c | 81 size_t remaining_length = text->length; in match() local
82 while (remaining_length) { in match()
85 next_token = (unsigned char *)memchr(token, ' ', remaining_length); in match()
89 remaining_length -= (token_length + 1); in match()
92 token_length = remaining_length; in match()
93 remaining_length = 0; in match()
|
| /third_party/node/deps/v8/tools/wasm-compilation-hints/ |
| D | wasm-objdump-compilation-hints.py | 43 remaining_length = payload_length \ variable
|
| /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()
|
| /third_party/rust/crates/memchr/bench/data/code/ |
| D | rust-library.rs | 29944 Dropper { front: root.into_dying().first_leaf_edge(), remaining_length: self.length };
30130 remaining_length: usize,
31237 if this.remaining_length == 0 {
31241 this.remaining_length -= 1;
31268 Dropper { front, remaining_length: self.length };
|