| /AliOS-Things-master/components/mqtt/MQTTPacket/ |
| A D | MQTTPacket.c | 89 if (rem_len < 128) in MQTTPacket_len()
90 rem_len += 1; in MQTTPacket_len()
92 rem_len += 2; in MQTTPacket_len()
94 rem_len += 3; in MQTTPacket_len()
96 rem_len += 4; in MQTTPacket_len()
97 return rem_len; in MQTTPacket_len()
295 int rem_len = 0; in MQTTPacket_read() local
309 if (rem_len && ((*getfn)(buf + len, rem_len) != rem_len)) in MQTTPacket_read()
332 trp->rem_len = 0; in MQTTPacket_decodenb()
392 if(trp->rem_len){ in MQTTPacket_readnb()
[all …]
|
| A D | MQTTUnsubscribeClient.c | 54 int rem_len = 0; in MQTTSerialize_unsubscribe() local
59 if (MQTTPacket_len(rem_len = MQTTSerialize_unsubscribeLength(count, topicFilters)) > buflen) in MQTTSerialize_unsubscribe()
71 ptr += MQTTPacket_encode(ptr, rem_len); /* write remaining length */; in MQTTSerialize_unsubscribe()
|
| A D | MQTTSubscribeClient.c | 55 int rem_len = 0; in MQTTSerialize_subscribe() local
60 if (MQTTPacket_len(rem_len = MQTTSerialize_subscribeLength(count, topicFilters)) > buflen) in MQTTSerialize_subscribe()
72 ptr += MQTTPacket_encode(ptr, rem_len); /* write remaining length */; in MQTTSerialize_subscribe()
|
| A D | MQTTSerializePublish.c | 60 int rem_len = 0; in MQTTSerialize_publish() local
64 if (MQTTPacket_len(rem_len = MQTTSerialize_publishLength(qos, topicName, payloadlen)) > buflen) in MQTTSerialize_publish()
76 ptr += MQTTPacket_encode(ptr, rem_len); /* write remaining length */; in MQTTSerialize_publish()
|
| A D | MQTTPacket.h | 100 int MQTTPacket_len(int rem_len);
121 int rem_len; member
|
| /AliOS-Things-master/components/linkkit/mqtt/impl/ |
| A D | MQTTPacket.c | 78 int MQTTPacket_len(int rem_len) in MQTTPacket_len() argument
80 rem_len += 1; /* header byte */ in MQTTPacket_len()
83 if (rem_len < 128) { in MQTTPacket_len()
84 rem_len += 1; in MQTTPacket_len()
85 } else if (rem_len < 16384) { in MQTTPacket_len()
86 rem_len += 2; in MQTTPacket_len()
87 } else if (rem_len < 2097151) { in MQTTPacket_len()
88 rem_len += 3; in MQTTPacket_len()
90 rem_len += 4; in MQTTPacket_len()
92 return rem_len; in MQTTPacket_len()
|
| A D | MQTTUnsubscribeClient.c | 60 int rem_len = 0; in MQTTSerialize_unsubscribe() local
64 rem_len = MQTTSerialize_unsubscribeLength(count, topicFilters); in MQTTSerialize_unsubscribe()
65 if (MQTTPacket_len(rem_len) > buflen) { in MQTTSerialize_unsubscribe()
76 ptr += MQTTPacket_encode(ptr, rem_len); /* write remaining length */ in MQTTSerialize_unsubscribe()
|
| A D | MQTTSerializePublish.c | 64 int rem_len = 0; in MQTTSerialize_publish() local
67 rem_len = MQTTSerialize_publishLength(qos, topicName, payloadlen); in MQTTSerialize_publish()
68 if (MQTTPacket_len(rem_len) > buflen) { in MQTTSerialize_publish()
79 ptr += MQTTPacket_encode(ptr, rem_len); /* write remaining length */ in MQTTSerialize_publish()
|
| A D | MQTTSubscribeClient.c | 61 int rem_len = 0; in MQTTSerialize_subscribe() local
65 if (MQTTPacket_len(rem_len = MQTTSerialize_subscribeLength( in MQTTSerialize_subscribe()
77 ptr += MQTTPacket_encode(ptr, rem_len); /* write remaining length */ in MQTTSerialize_subscribe()
|
| A D | MQTTPacket.h | 123 int MQTTPacket_len(int rem_len);
146 int rem_len; member
|
| A D | iotx_mqtt_client.c | 272 extern int MQTTPacket_len(int rem_len);
530 int rem_len = 0; in iotx_mc_read_packet() local
580 if ((rem_len > 0) && ((rem_len + len) > c->buf_size_read)) { in iotx_mc_read_packet()
586 c->buf_size_read, rem_len); in iotx_mc_read_packet()
592 (rem_len > c->buf_size_read) ? c->buf_size_read : rem_len; in iotx_mc_read_packet()
600 rem_len -= needReadLen; in iotx_mc_read_packet()
601 } while (rem_len); in iotx_mc_read_packet()
621 if (rem_len > 0) { in iotx_mc_read_packet()
626 } else if (rc != rem_len) { in iotx_mc_read_packet()
635 if ((len + rem_len) < c->buf_size_read) { in iotx_mc_read_packet()
[all …]
|
| /AliOS-Things-master/components/lwip/lwip2.0.0/core/ |
| A D | pbuf.c | 271 s32_t rem_len; /* remaining length */ in pbuf_alloc_ext() local
381 rem_len = length - p->len; in pbuf_alloc_ext()
383 while (rem_len > 0) { in pbuf_alloc_ext()
399 q->tot_len = (u16_t)rem_len; in pbuf_alloc_ext()
410 rem_len -= q->len; in pbuf_alloc_ext()
563 u16_t rem_len; /* remaining length */ in pbuf_realloc() local
583 rem_len = new_len; in pbuf_realloc()
586 while (rem_len > q->len) { in pbuf_realloc()
588 rem_len -= q->len; in pbuf_realloc()
601 if ((q->type == PBUF_RAM) && (rem_len != q->len) in pbuf_realloc()
[all …]
|
| /AliOS-Things-master/components/mqtt/MQTTClient-C/ |
| A D | MQTTClient.c | 115 int rem_len = 0; in readPacket() local
124 decodePacket(c, &rem_len, TimerLeftMS(timer)); in readPacket()
125 …len += MQTTPacket_encode(c->readbuf + 1, rem_len); /* put the original remaining length back into … in readPacket()
127 if (rem_len > (c->readbuf_size - len)) in readPacket()
134 …if (rem_len > 0 && (rc = c->ipstack->mqttread(c->ipstack, c->readbuf + len, rem_len, TimerLeftMS(t… in readPacket()
|
| /AliOS-Things-master/components/mbedtls/library/ |
| A D | ssl_tls.c | 3014 const size_t rem_len = hs_len - frag_off; in mbedtls_ssl_flight_transmit() local
3029 cur_hs_frag_len = rem_len > max_hs_frag_len ? in mbedtls_ssl_flight_transmit()
3030 max_hs_frag_len : rem_len; in mbedtls_ssl_flight_transmit()
|