| /dports/net/mosquitto/mosquitto-2.0.13/lib/ |
| H A D | socks_mosq.c | 159 mosq->in_packet.pos = 0; in socks5__send()
163 if(!mosq->in_packet.payload){ in socks5__send()
225 mosq->in_packet.pos = 0; in socks5__send()
229 if(!mosq->in_packet.payload){ in socks5__send()
254 mosq->in_packet.pos = 0; in socks5__send()
279 …len = net__read(mosq, &(mosq->in_packet.payload[mosq->in_packet.pos]), mosq->in_packet.to_process); in socks5__read()
321 …len = net__read(mosq, &(mosq->in_packet.payload[mosq->in_packet.pos]), mosq->in_packet.to_process); in socks5__read()
377 …len = net__read(mosq, &(mosq->in_packet.payload[mosq->in_packet.pos]), mosq->in_packet.to_process); in socks5__read()
411 mosq->in_packet.to_process += mosq->in_packet.payload[4]; in socks5__read()
412 mosq->in_packet.packet_length += mosq->in_packet.payload[4]; in socks5__read()
[all …]
|
| H A D | packet_mosq.c | 127 packet__cleanup(&mosq->in_packet); in packet__cleanup_all_no_locks()
376 if(!mosq->in_packet.command){
379 mosq->in_packet.command = byte;
430 mosq->in_packet.remaining_length += (byte & 127) * mosq->in_packet.remaining_mult;
455 mosq->in_packet.remaining_count = (int8_t)(mosq->in_packet.remaining_count * -1);
499 mosq->in_packet.payload = mosquitto__malloc(mosq->in_packet.remaining_length*sizeof(uint8_t));
500 if(!mosq->in_packet.payload){
503 mosq->in_packet.to_process = mosq->in_packet.remaining_length;
507 …read_length = net__read(mosq, &(mosq->in_packet.payload[mosq->in_packet.pos]), mosq->in_packet.to_…
546 mosq->in_packet.pos = 0;
[all …]
|
| H A D | handle_pubackcomp.c | 55 if((mosq->in_packet.command&0x0F) != 0x00){ in handle__pubackcomp()
64 rc = packet__read_uint16(&mosq->in_packet, &mid); in handle__pubackcomp()
67 if(mosq->in_packet.command != CMD_PUBACK){ in handle__pubackcomp()
72 if(mosq->in_packet.command != CMD_PUBCOMP){ in handle__pubackcomp()
81 if(mosq->protocol == mosq_p_mqtt5 && mosq->in_packet.remaining_length > 2){ in handle__pubackcomp()
82 rc = packet__read_byte(&mosq->in_packet, &reason_code); in handle__pubackcomp()
87 if(mosq->in_packet.remaining_length > 3){ in handle__pubackcomp()
88 rc = property__read_all(CMD_PUBACK, &mosq->in_packet, &properties); in handle__pubackcomp()
114 if(mosq->in_packet.pos < mosq->in_packet.remaining_length){ in handle__pubackcomp()
|
| H A D | handle_pubrel.c | 56 if(mosq->protocol != mosq_p_mqtt31 && mosq->in_packet.command != (CMD_PUBREL|2)){ in handle__pubrel()
61 if((mosq->in_packet.command&0x0F) != 0x02){ in handle__pubrel()
65 rc = packet__read_uint16(&mosq->in_packet, &mid); in handle__pubrel()
69 if(mosq->protocol == mosq_p_mqtt5 && mosq->in_packet.remaining_length > 2){ in handle__pubrel()
70 rc = packet__read_byte(&mosq->in_packet, &reason_code); in handle__pubrel()
77 if(mosq->in_packet.remaining_length > 3){ in handle__pubrel()
78 rc = property__read_all(CMD_PUBREL, &mosq->in_packet, &properties); in handle__pubrel()
83 if(mosq->in_packet.pos < mosq->in_packet.remaining_length){ in handle__pubrel()
|
| H A D | handle_suback.c | 53 if(mosq->in_packet.command != CMD_SUBACK){ in handle__suback()
66 rc = packet__read_uint16(&mosq->in_packet, &mid); in handle__suback()
71 rc = property__read_all(CMD_SUBACK, &mosq->in_packet, &properties); in handle__suback()
75 qos_count = (int)(mosq->in_packet.remaining_length - mosq->in_packet.pos); in handle__suback()
83 while(mosq->in_packet.pos < mosq->in_packet.remaining_length){ in handle__suback()
84 rc = packet__read_byte(&mosq->in_packet, &qos); in handle__suback()
|
| H A D | handle_pubrec.c | 52 if(mosq->in_packet.command != CMD_PUBREC){ in handle__pubrec()
56 rc = packet__read_uint16(&mosq->in_packet, &mid); in handle__pubrec()
60 if(mosq->protocol == mosq_p_mqtt5 && mosq->in_packet.remaining_length > 2){ in handle__pubrec()
61 rc = packet__read_byte(&mosq->in_packet, &reason_code); in handle__pubrec()
76 if(mosq->in_packet.remaining_length > 3){ in handle__pubrec()
77 rc = property__read_all(CMD_PUBREC, &mosq->in_packet, &properties); in handle__pubrec()
85 if(mosq->in_packet.pos < mosq->in_packet.remaining_length){ in handle__pubrec()
|
| H A D | handle_disconnect.c | 47 if(mosq->in_packet.command != CMD_DISCONNECT){ in handle__disconnect()
51 rc = packet__read_byte(&mosq->in_packet, &reason_code); in handle__disconnect()
54 if(mosq->in_packet.remaining_length > 2){ in handle__disconnect()
55 rc = property__read_all(CMD_DISCONNECT, &mosq->in_packet, &properties); in handle__disconnect()
|
| H A D | handle_publish.c | 56 header = mosq->in_packet.command; in handle__publish()
62 rc = packet__read_string(&mosq->in_packet, &message->msg.topic, &slen); in handle__publish()
81 rc = packet__read_uint16(&mosq->in_packet, &mid); in handle__publish()
94 rc = property__read_all(CMD_PUBLISH, &mosq->in_packet, &properties); in handle__publish()
101 message->msg.payloadlen = (int)(mosq->in_packet.remaining_length - mosq->in_packet.pos); in handle__publish()
109 …rc = packet__read_bytes(&mosq->in_packet, message->msg.payload, (uint32_t)message->msg.payloadlen); in handle__publish()
|
| /dports/www/domoticz/domoticz-2020.2/extern/mosquitto/lib/ |
| H A D | socks_mosq.c | 143 mosq->in_packet.pos = 0; in socks5__send()
147 if(!mosq->in_packet.payload){ in socks5__send()
209 mosq->in_packet.pos = 0; in socks5__send()
213 if(!mosq->in_packet.payload){ in socks5__send()
238 mosq->in_packet.pos = 0; in socks5__send()
263 …len = net__read(mosq, &(mosq->in_packet.payload[mosq->in_packet.pos]), mosq->in_packet.to_process); in socks5__read()
305 …len = net__read(mosq, &(mosq->in_packet.payload[mosq->in_packet.pos]), mosq->in_packet.to_process); in socks5__read()
361 …len = net__read(mosq, &(mosq->in_packet.payload[mosq->in_packet.pos]), mosq->in_packet.to_process); in socks5__read()
395 mosq->in_packet.to_process += mosq->in_packet.payload[4]; in socks5__read()
396 mosq->in_packet.packet_length += mosq->in_packet.payload[4]; in socks5__read()
[all …]
|
| H A D | packet_mosq.c | 127 packet__cleanup(&mosq->in_packet); in packet__cleanup_all()
350 if(!mosq->in_packet.command){
353 mosq->in_packet.command = byte;
402 mosq->in_packet.remaining_length += (byte & 127) * mosq->in_packet.remaining_mult;
439 mosq->in_packet.payload = mosquitto__malloc(mosq->in_packet.remaining_length*sizeof(uint8_t));
440 if(!mosq->in_packet.payload){
443 mosq->in_packet.to_process = mosq->in_packet.remaining_length;
446 while(mosq->in_packet.to_process>0){
447 …read_length = net__read(mosq, &(mosq->in_packet.payload[mosq->in_packet.pos]), mosq->in_packet.to_…
480 mosq->in_packet.pos = 0;
[all …]
|
| H A D | handle_suback.c | 58 rc = packet__read_uint16(&mosq->in_packet, &mid); in handle__suback()
63 rc = property__read_all(CMD_SUBACK, &mosq->in_packet, &properties); in handle__suback()
67 qos_count = mosq->in_packet.remaining_length - mosq->in_packet.pos; in handle__suback()
70 while(mosq->in_packet.pos < mosq->in_packet.remaining_length){ in handle__suback()
71 rc = packet__read_byte(&mosq->in_packet, &qos); in handle__suback()
|
| H A D | handle_pubrel.c | 58 if((mosq->in_packet.command&0x0F) != 0x02){ in handle__pubrel()
62 rc = packet__read_uint16(&mosq->in_packet, &mid); in handle__pubrel()
66 if(mosq->protocol == mosq_p_mqtt5 && mosq->in_packet.remaining_length > 2){ in handle__pubrel()
67 rc = packet__read_byte(&mosq->in_packet, &reason_code); in handle__pubrel()
70 if(mosq->in_packet.remaining_length > 3){ in handle__pubrel()
71 rc = property__read_all(CMD_PUBREL, &mosq->in_packet, &properties); in handle__pubrel()
|
| H A D | handle_publish.c | 55 header = mosq->in_packet.command; in handle__publish()
61 rc = packet__read_string(&mosq->in_packet, &message->msg.topic, &slen); in handle__publish()
80 rc = packet__read_uint16(&mosq->in_packet, &mid); in handle__publish()
93 rc = property__read_all(CMD_PUBLISH, &mosq->in_packet, &properties); in handle__publish()
97 message->msg.payloadlen = mosq->in_packet.remaining_length - mosq->in_packet.pos; in handle__publish()
105 rc = packet__read_bytes(&mosq->in_packet, message->msg.payload, message->msg.payloadlen); in handle__publish()
|
| H A D | handle_pubrec.c | 53 rc = packet__read_uint16(&mosq->in_packet, &mid); in handle__pubrec()
57 if(mosq->protocol == mosq_p_mqtt5 && mosq->in_packet.remaining_length > 2){ in handle__pubrec()
58 rc = packet__read_byte(&mosq->in_packet, &reason_code); in handle__pubrec()
61 if(mosq->in_packet.remaining_length > 3){ in handle__pubrec()
62 rc = property__read_all(CMD_PUBREC, &mosq->in_packet, &properties); in handle__pubrec()
|
| /dports/net/mosquitto/mosquitto-2.0.13/src/ |
| H A D | websockets.c | 304 if(!mosq->in_packet.command){ in callback_mqtt()
328 mosq->in_packet.remaining_length += (byte & 127) * mosq->in_packet.remaining_mult; in callback_mqtt()
331 mosq->in_packet.remaining_count = (int8_t)(mosq->in_packet.remaining_count * -1); in callback_mqtt()
334 mosq->in_packet.payload = mosquitto__malloc(mosq->in_packet.remaining_length*sizeof(uint8_t)); in callback_mqtt()
335 if(!mosq->in_packet.payload){ in callback_mqtt()
338 mosq->in_packet.to_process = mosq->in_packet.remaining_length; in callback_mqtt()
341 if(mosq->in_packet.to_process>0){ in callback_mqtt()
343 memcpy(&mosq->in_packet.payload[mosq->in_packet.pos], &buf[pos], mosq->in_packet.to_process); in callback_mqtt()
344 mosq->in_packet.pos += mosq->in_packet.to_process; in callback_mqtt()
348 memcpy(&mosq->in_packet.payload[mosq->in_packet.pos], &buf[pos], len-pos); in callback_mqtt()
[all …]
|
| H A D | handle_disconnect.c | 40 if(context->in_packet.command != CMD_DISCONNECT){ in handle__disconnect()
44 if(context->protocol == mosq_p_mqtt5 && context->in_packet.remaining_length > 0){ in handle__disconnect()
46 rc = packet__read_byte(&context->in_packet, &reason_code); in handle__disconnect()
49 if(context->in_packet.remaining_length > 1){ in handle__disconnect()
50 rc = property__read_all(CMD_DISCONNECT, &context->in_packet, &properties); in handle__disconnect()
61 if(context->in_packet.pos != context->in_packet.remaining_length){ in handle__disconnect()
66 if((context->in_packet.command&0x0F) != 0x00){ in handle__disconnect()
|
| H A D | handle_unsubscribe.c | 48 if(context->in_packet.command != (CMD_UNSUBSCRIBE|2)){ in handle__unsubscribe()
54 if((context->in_packet.command&0x0F) != 0x02){ in handle__unsubscribe()
58 if(packet__read_uint16(&context->in_packet, &mid)) return MOSQ_ERR_MALFORMED_PACKET; in handle__unsubscribe()
62 rc = property__read_all(CMD_UNSUBSCRIBE, &context->in_packet, &properties); in handle__unsubscribe()
78 if(context->in_packet.pos == context->in_packet.remaining_length){ in handle__unsubscribe()
90 while(context->in_packet.pos < context->in_packet.remaining_length){ in handle__unsubscribe()
92 if(packet__read_string(&context->in_packet, &sub, &slen)){ in handle__unsubscribe()
|
| H A D | handle_subscribe.c | 55 if(context->in_packet.command != (CMD_SUBSCRIBE|2)){ in handle__subscribe()
62 if((context->in_packet.command&0x0F) != 0x02){ in handle__subscribe()
66 if(packet__read_uint16(&context->in_packet, &mid)) return MOSQ_ERR_MALFORMED_PACKET; in handle__subscribe()
70 rc = property__read_all(CMD_SUBSCRIBE, &context->in_packet, &properties); in handle__subscribe()
96 while(context->in_packet.pos < context->in_packet.remaining_length){ in handle__subscribe()
98 if(packet__read_string(&context->in_packet, &sub, &slen)){ in handle__subscribe()
121 if(packet__read_byte(&context->in_packet, &subscription_options)){ in handle__subscribe()
|
| /dports/www/domoticz/domoticz-2020.2/extern/mosquitto/src/ |
| H A D | websockets.c | 360 if(!mosq->in_packet.command){ in callback_mqtt()
384 mosq->in_packet.remaining_length += (byte & 127) * mosq->in_packet.remaining_mult; in callback_mqtt()
390 mosq->in_packet.payload = mosquitto__malloc(mosq->in_packet.remaining_length*sizeof(uint8_t)); in callback_mqtt()
391 if(!mosq->in_packet.payload){ in callback_mqtt()
394 mosq->in_packet.to_process = mosq->in_packet.remaining_length; in callback_mqtt()
397 if(mosq->in_packet.to_process>0){ in callback_mqtt()
399 memcpy(&mosq->in_packet.payload[mosq->in_packet.pos], &buf[pos], mosq->in_packet.to_process); in callback_mqtt()
400 mosq->in_packet.pos += mosq->in_packet.to_process; in callback_mqtt()
402 mosq->in_packet.to_process = 0; in callback_mqtt()
404 memcpy(&mosq->in_packet.payload[mosq->in_packet.pos], &buf[pos], len-pos); in callback_mqtt()
[all …]
|
| H A D | handle_disconnect.c | 38 if(context->protocol == mosq_p_mqtt5 && context->in_packet.remaining_length > 0){ in handle__disconnect()
40 rc = packet__read_byte(&context->in_packet, &reason_code); in handle__disconnect()
43 if(context->in_packet.remaining_length > 1){ in handle__disconnect()
44 rc = property__read_all(CMD_DISCONNECT, &context->in_packet, &properties); in handle__disconnect()
58 if(context->in_packet.pos != context->in_packet.remaining_length){ in handle__disconnect()
63 if((context->in_packet.command&0x0F) != 0x00){ in handle__disconnect()
|
| H A D | handle_unsubscribe.c | 48 if((context->in_packet.command&0x0F) != 0x02){ in handle__unsubscribe()
52 if(packet__read_uint16(&context->in_packet, &mid)) return 1; in handle__unsubscribe()
56 rc = property__read_all(CMD_UNSUBSCRIBE, &context->in_packet, &properties); in handle__unsubscribe()
63 if(context->in_packet.pos == context->in_packet.remaining_length){ in handle__unsubscribe()
75 while(context->in_packet.pos < context->in_packet.remaining_length){ in handle__unsubscribe()
77 if(packet__read_string(&context->in_packet, &sub, &slen)){ in handle__unsubscribe()
|
| H A D | handle_subscribe.c | 56 if((context->in_packet.command&0x0F) != 0x02){ in handle__subscribe()
60 if(packet__read_uint16(&context->in_packet, &mid)) return 1; in handle__subscribe()
64 rc = property__read_all(CMD_SUBSCRIBE, &context->in_packet, &properties); in handle__subscribe()
81 while(context->in_packet.pos < context->in_packet.remaining_length){ in handle__subscribe()
83 if(packet__read_string(&context->in_packet, &sub, &slen)){ in handle__subscribe()
106 if(packet__read_byte(&context->in_packet, &subscription_options)){ in handle__subscribe()
|
| /dports/devel/aws-c-mqtt/aws-c-mqtt-0.7.8/tests/ |
| H A D | packet_encoding_test.c | 54 void *in_packet; member
66 ASSERT_NOT_NULL(fixture->in_packet); in s_packet_test_before()
67 memset(fixture->in_packet, 0, fixture->size); in s_packet_test_before()
126 aws_mem_release(allocator, fixture->in_packet); in s_packet_test_after()
222 fixture->in_packet, in PACKET_TEST_ACK()
268 fixture->in_packet, in s_test_connect_will_init()
310 fixture->in_packet, in s_test_connect_password_init()
373 fixture->in_packet, in s_test_publish_qos0_dup_init()
408 fixture->in_packet, in s_test_publish_qos2_retain_init()
491 aws_mqtt_packet_subscribe_clean_up(fixture->in_packet); in s_test_subscribe_clean_up()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/net/ |
| H A D | probe_message_unittest.cc | 60 ProbePacket in_packet; in TEST_F() local
65 in_packet.mutable_header()->set_version(version); in TEST_F()
66 in_packet.mutable_header()->set_type(type); in TEST_F()
67 in_packet.set_number_probe_packets(number_probe_packets); in TEST_F()
68 in_packet.set_group_id(group_id); in TEST_F()
71 std::string output = pm.MakeEncodedPacket(in_packet); in TEST_F()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/chrome/browser/net/ |
| H A D | probe_message_unittest.cc | 60 ProbePacket in_packet; in TEST_F() local
65 in_packet.mutable_header()->set_version(version); in TEST_F()
66 in_packet.mutable_header()->set_type(type); in TEST_F()
67 in_packet.set_number_probe_packets(number_probe_packets); in TEST_F()
68 in_packet.set_group_id(group_id); in TEST_F()
71 std::string output = pm.MakeEncodedPacket(in_packet); in TEST_F()
|