| line |
true |
false |
branch |
|
292
|
0 |
38 |
if (m == NULL) { |
|
295
|
0 |
38 |
if (!amqp_decode_8(encoded, &offset, &m->version_major)) |
|
297
|
0 |
38 |
if (!amqp_decode_8(encoded, &offset, &m->version_minor)) |
|
302
|
0 |
38 |
if (res < 0) return res; |
|
323
|
0 |
0 |
if (m == NULL) { |
|
329
|
0 |
0 |
if (res < 0) return res; |
|
355
|
0 |
0 |
if (m == NULL) { |
|
371
|
0 |
0 |
if (m == NULL) { |
|
386
|
0 |
38 |
if (m == NULL) { |
|
389
|
0 |
38 |
if (!amqp_decode_16(encoded, &offset, &m->channel_max)) |
|
391
|
0 |
38 |
if (!amqp_decode_32(encoded, &offset, &m->frame_max)) |
|
393
|
0 |
38 |
if (!amqp_decode_16(encoded, &offset, &m->heartbeat)) |
|
402
|
0 |
0 |
if (m == NULL) { |
|
405
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->channel_max)) |
|
407
|
0 |
0 |
if (!amqp_decode_32(encoded, &offset, &m->frame_max)) |
|
409
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->heartbeat)) |
|
417
|
0 |
0 |
if (m == NULL) { |
|
432
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
442
|
0 |
38 |
if (m == NULL) { |
|
457
|
0 |
0 |
if (m == NULL) { |
|
460
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->reply_code)) |
|
468
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->class_id)) |
|
470
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->method_id)) |
|
479
|
0 |
30 |
if (m == NULL) { |
|
489
|
0 |
0 |
if (m == NULL) { |
|
505
|
0 |
0 |
if (m == NULL) { |
|
514
|
0 |
0 |
if (m == NULL) { |
|
529
|
0 |
36 |
if (m == NULL) { |
|
544
|
0 |
0 |
if (m == NULL) { |
|
547
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
556
|
0 |
0 |
if (m == NULL) { |
|
559
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
568
|
0 |
5 |
if (m == NULL) { |
|
571
|
0 |
5 |
if (!amqp_decode_16(encoded, &offset, &m->reply_code)) |
|
579
|
0 |
5 |
if (!amqp_decode_16(encoded, &offset, &m->class_id)) |
|
581
|
0 |
5 |
if (!amqp_decode_16(encoded, &offset, &m->method_id)) |
|
589
|
0 |
1 |
if (m == NULL) { |
|
598
|
0 |
0 |
if (m == NULL) { |
|
607
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
620
|
0 |
0 |
if (m == NULL) { |
|
623
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
631
|
0 |
0 |
if (m == NULL) { |
|
634
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
648
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
657
|
0 |
0 |
if (res < 0) return res; |
|
666
|
0 |
26 |
if (m == NULL) { |
|
675
|
0 |
0 |
if (m == NULL) { |
|
678
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
686
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
697
|
0 |
27 |
if (m == NULL) { |
|
706
|
0 |
0 |
if (m == NULL) { |
|
709
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
729
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
734
|
0 |
0 |
if (res < 0) return res; |
|
742
|
0 |
1 |
if (m == NULL) { |
|
751
|
0 |
0 |
if (m == NULL) { |
|
754
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
774
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
779
|
0 |
0 |
if (res < 0) return res; |
|
788
|
0 |
1 |
if (m == NULL) { |
|
797
|
0 |
0 |
if (m == NULL) { |
|
800
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
808
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
817
|
0 |
0 |
if (res < 0) return res; |
|
825
|
0 |
19 |
if (m == NULL) { |
|
834
|
0 |
19 |
if (!amqp_decode_32(encoded, &offset, &m->message_count)) |
|
836
|
0 |
19 |
if (!amqp_decode_32(encoded, &offset, &m->consumer_count)) |
|
844
|
0 |
0 |
if (m == NULL) { |
|
847
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
867
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
872
|
0 |
0 |
if (res < 0) return res; |
|
880
|
0 |
17 |
if (m == NULL) { |
|
889
|
0 |
0 |
if (m == NULL) { |
|
892
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
900
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
909
|
0 |
18 |
if (m == NULL) { |
|
912
|
0 |
18 |
if (!amqp_decode_32(encoded, &offset, &m->message_count)) |
|
920
|
0 |
0 |
if (m == NULL) { |
|
923
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
931
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
942
|
0 |
20 |
if (m == NULL) { |
|
945
|
0 |
20 |
if (!amqp_decode_32(encoded, &offset, &m->message_count)) |
|
953
|
0 |
0 |
if (m == NULL) { |
|
956
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
978
|
0 |
0 |
if (res < 0) return res; |
|
986
|
0 |
21 |
if (m == NULL) { |
|
995
|
0 |
0 |
if (m == NULL) { |
|
998
|
0 |
0 |
if (!amqp_decode_32(encoded, &offset, &m->prefetch_size)) |
|
1000
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->prefetch_count)) |
|
1002
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1011
|
0 |
1 |
if (m == NULL) { |
|
1020
|
0 |
0 |
if (m == NULL) { |
|
1023
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
1037
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1045
|
0 |
0 |
if (res < 0) return res; |
|
1053
|
0 |
16 |
if (m == NULL) { |
|
1068
|
0 |
0 |
if (m == NULL) { |
|
1077
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1086
|
0 |
1 |
if (m == NULL) { |
|
1101
|
0 |
0 |
if (m == NULL) { |
|
1104
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
1118
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1128
|
0 |
0 |
if (m == NULL) { |
|
1131
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->reply_code)) |
|
1157
|
0 |
21 |
if (m == NULL) { |
|
1166
|
0 |
21 |
if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) |
|
1168
|
0 |
21 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1189
|
0 |
0 |
if (m == NULL) { |
|
1192
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
1200
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1209
|
0 |
4 |
if (m == NULL) { |
|
1212
|
0 |
4 |
if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) |
|
1214
|
0 |
4 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1229
|
0 |
4 |
if (!amqp_decode_32(encoded, &offset, &m->message_count)) |
|
1237
|
0 |
18 |
if (m == NULL) { |
|
1252
|
0 |
0 |
if (m == NULL) { |
|
1255
|
0 |
0 |
if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) |
|
1257
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1266
|
0 |
0 |
if (m == NULL) { |
|
1269
|
0 |
0 |
if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) |
|
1271
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1281
|
0 |
0 |
if (m == NULL) { |
|
1284
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1293
|
0 |
0 |
if (m == NULL) { |
|
1296
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1305
|
0 |
0 |
if (m == NULL) { |
|
1314
|
0 |
0 |
if (m == NULL) { |
|
1317
|
0 |
0 |
if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) |
|
1319
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1329
|
0 |
0 |
if (m == NULL) { |
|
1338
|
0 |
1 |
if (m == NULL) { |
|
1347
|
0 |
0 |
if (m == NULL) { |
|
1356
|
0 |
1 |
if (m == NULL) { |
|
1365
|
0 |
0 |
if (m == NULL) { |
|
1374
|
0 |
1 |
if (m == NULL) { |
|
1383
|
0 |
0 |
if (m == NULL) { |
|
1386
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1395
|
0 |
0 |
if (m == NULL) { |
|
1415
|
0 |
25 |
if (!amqp_decode_16(encoded, &offset, &partial_flags)) |
|
1419
|
0 |
25 |
} while (partial_flags & 1); |
|
1426
|
0 |
0 |
if (p == NULL) { |
|
1437
|
0 |
0 |
if (p == NULL) { |
|
1447
|
0 |
0 |
if (p == NULL) { |
|
1458
|
0 |
0 |
if (p == NULL) { |
|
1468
|
0 |
0 |
if (p == NULL) { |
|
1478
|
0 |
25 |
if (p == NULL) { |
|
1482
|
4 |
21 |
if (flags & AMQP_BASIC_CONTENT_TYPE_FLAG) { |
|
1490
|
7 |
18 |
if (flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) { |
|
1498
|
9 |
16 |
if (flags & AMQP_BASIC_HEADERS_FLAG) { |
|
1501
|
0 |
9 |
if (res < 0) return res; |
|
1504
|
4 |
21 |
if (flags & AMQP_BASIC_DELIVERY_MODE_FLAG) { |
|
1505
|
0 |
4 |
if (!amqp_decode_8(encoded, &offset, &p->delivery_mode)) |
|
1508
|
4 |
21 |
if (flags & AMQP_BASIC_PRIORITY_FLAG) { |
|
1509
|
0 |
4 |
if (!amqp_decode_8(encoded, &offset, &p->priority)) |
|
1512
|
4 |
21 |
if (flags & AMQP_BASIC_CORRELATION_ID_FLAG) { |
|
1520
|
4 |
21 |
if (flags & AMQP_BASIC_REPLY_TO_FLAG) { |
|
1528
|
4 |
21 |
if (flags & AMQP_BASIC_EXPIRATION_FLAG) { |
|
1536
|
4 |
21 |
if (flags & AMQP_BASIC_MESSAGE_ID_FLAG) { |
|
1544
|
4 |
21 |
if (flags & AMQP_BASIC_TIMESTAMP_FLAG) { |
|
1545
|
0 |
4 |
if (!amqp_decode_64(encoded, &offset, &p->timestamp)) |
|
1548
|
4 |
21 |
if (flags & AMQP_BASIC_TYPE_FLAG) { |
|
1556
|
4 |
21 |
if (flags & AMQP_BASIC_USER_ID_FLAG) { |
|
1564
|
4 |
21 |
if (flags & AMQP_BASIC_APP_ID_FLAG) { |
|
1572
|
0 |
25 |
if (flags & AMQP_BASIC_CLUSTER_ID_FLAG) { |
|
1586
|
0 |
0 |
if (p == NULL) { |
|
1597
|
0 |
0 |
if (p == NULL) { |
|
1617
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, m->version_major)) |
|
1619
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, m->version_minor)) |
|
1623
|
0 |
0 |
if (res < 0) return res; |
|
1626
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->mechanisms.len) || |
|
1630
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->locales.len) || |
|
1639
|
0 |
38 |
if (res < 0) return res; |
|
1642
|
0 |
38 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->mechanism.len) || |
|
1646
|
0 |
38 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->response.len) || |
|
1650
|
0 |
38 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->locale.len) || |
|
1658
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->challenge.len) || |
|
1666
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->response.len) || |
|
1673
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->channel_max)) |
|
1675
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->frame_max)) |
|
1677
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->heartbeat)) |
|
1683
|
0 |
38 |
if (!amqp_encode_16(encoded, &offset, m->channel_max)) |
|
1685
|
0 |
38 |
if (!amqp_encode_32(encoded, &offset, m->frame_max)) |
|
1687
|
0 |
38 |
if (!amqp_encode_16(encoded, &offset, m->heartbeat)) |
|
1694
|
0 |
38 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->virtual_host.len) || |
|
1698
|
0 |
38 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->capabilities.len) || |
|
1702
|
38 |
0 |
if (m->insist) bit_buffer |= (1 << 0); |
|
1703
|
0 |
38 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1710
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->known_hosts.len) || |
|
1717
|
0 |
33 |
if (!amqp_encode_16(encoded, &offset, m->reply_code)) |
|
1720
|
0 |
33 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->reply_text.len) || |
|
1723
|
0 |
33 |
if (!amqp_encode_16(encoded, &offset, m->class_id)) |
|
1725
|
0 |
33 |
if (!amqp_encode_16(encoded, &offset, m->method_id)) |
|
1735
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->reason.len) || |
|
1746
|
0 |
36 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->out_of_band.len) || |
|
1754
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->channel_id.len) || |
|
1762
|
0 |
0 |
if (m->active) bit_buffer |= (1 << 0); |
|
1763
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1770
|
0 |
0 |
if (m->active) bit_buffer |= (1 << 0); |
|
1771
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1777
|
0 |
1 |
if (!amqp_encode_16(encoded, &offset, m->reply_code)) |
|
1780
|
0 |
1 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->reply_text.len) || |
|
1783
|
0 |
1 |
if (!amqp_encode_16(encoded, &offset, m->class_id)) |
|
1785
|
0 |
1 |
if (!amqp_encode_16(encoded, &offset, m->method_id)) |
|
1795
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->realm.len) || |
|
1799
|
0 |
0 |
if (m->exclusive) bit_buffer |= (1 << 0); |
|
1800
|
0 |
0 |
if (m->passive) bit_buffer |= (1 << 1); |
|
1801
|
0 |
0 |
if (m->active) bit_buffer |= (1 << 2); |
|
1802
|
0 |
0 |
if (m->write) bit_buffer |= (1 << 3); |
|
1803
|
0 |
0 |
if (m->read) bit_buffer |= (1 << 4); |
|
1804
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1810
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1816
|
0 |
26 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1819
|
0 |
26 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
1823
|
0 |
26 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->type.len) || |
|
1827
|
0 |
26 |
if (m->passive) bit_buffer |= (1 << 0); |
|
1828
|
23 |
3 |
if (m->durable) bit_buffer |= (1 << 1); |
|
1829
|
4 |
22 |
if (m->auto_delete) bit_buffer |= (1 << 2); |
|
1830
|
2 |
24 |
if (m->internal) bit_buffer |= (1 << 3); |
|
1831
|
0 |
26 |
if (m->nowait) bit_buffer |= (1 << 4); |
|
1832
|
0 |
26 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1836
|
0 |
26 |
if (res < 0) return res; |
|
1845
|
0 |
27 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1848
|
0 |
27 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
1852
|
0 |
27 |
if (m->if_unused) bit_buffer |= (1 << 0); |
|
1853
|
0 |
27 |
if (m->nowait) bit_buffer |= (1 << 1); |
|
1854
|
0 |
27 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1863
|
0 |
1 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1866
|
0 |
1 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->destination.len) || |
|
1870
|
0 |
1 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->source.len) || |
|
1874
|
0 |
1 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
1878
|
0 |
1 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
1879
|
0 |
1 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1883
|
0 |
1 |
if (res < 0) return res; |
|
1892
|
0 |
1 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1895
|
0 |
1 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->destination.len) || |
|
1899
|
0 |
1 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->source.len) || |
|
1903
|
0 |
1 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
1907
|
0 |
1 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
1908
|
0 |
1 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1912
|
0 |
1 |
if (res < 0) return res; |
|
1921
|
0 |
20 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1924
|
0 |
20 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
1928
|
0 |
20 |
if (m->passive) bit_buffer |= (1 << 0); |
|
1929
|
16 |
4 |
if (m->durable) bit_buffer |= (1 << 1); |
|
1930
|
0 |
20 |
if (m->exclusive) bit_buffer |= (1 << 2); |
|
1931
|
3 |
17 |
if (m->auto_delete) bit_buffer |= (1 << 3); |
|
1932
|
0 |
20 |
if (m->nowait) bit_buffer |= (1 << 4); |
|
1933
|
0 |
20 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1937
|
0 |
20 |
if (res < 0) return res; |
|
1944
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
1947
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->message_count)) |
|
1949
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->consumer_count)) |
|
1955
|
0 |
18 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1958
|
0 |
18 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
1962
|
0 |
18 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
1966
|
0 |
18 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
1970
|
0 |
18 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
1971
|
0 |
18 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1975
|
0 |
18 |
if (res < 0) return res; |
|
1984
|
0 |
19 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1987
|
0 |
19 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
1991
|
0 |
19 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
1992
|
0 |
19 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1998
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->message_count)) |
|
2004
|
0 |
20 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2007
|
0 |
20 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
2011
|
0 |
20 |
if (m->if_unused) bit_buffer |= (1 << 0); |
|
2012
|
0 |
20 |
if (m->if_empty) bit_buffer |= (1 << 1); |
|
2013
|
0 |
20 |
if (m->nowait) bit_buffer |= (1 << 2); |
|
2014
|
0 |
20 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2020
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->message_count)) |
|
2026
|
0 |
21 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2029
|
0 |
21 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
2033
|
0 |
21 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
2037
|
0 |
21 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
2042
|
0 |
21 |
if (res < 0) return res; |
|
2051
|
0 |
1 |
if (!amqp_encode_32(encoded, &offset, m->prefetch_size)) |
|
2053
|
0 |
1 |
if (!amqp_encode_16(encoded, &offset, m->prefetch_count)) |
|
2056
|
0 |
1 |
if (m->global) bit_buffer |= (1 << 0); |
|
2057
|
0 |
1 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2066
|
0 |
16 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2069
|
0 |
16 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
2073
|
0 |
16 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) || |
|
2077
|
0 |
16 |
if (m->no_local) bit_buffer |= (1 << 0); |
|
2078
|
12 |
4 |
if (m->no_ack) bit_buffer |= (1 << 1); |
|
2079
|
0 |
16 |
if (m->exclusive) bit_buffer |= (1 << 2); |
|
2080
|
0 |
16 |
if (m->nowait) bit_buffer |= (1 << 3); |
|
2081
|
0 |
16 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2085
|
0 |
16 |
if (res < 0) return res; |
|
2092
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) || |
|
2100
|
0 |
2 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) || |
|
2104
|
0 |
2 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
2105
|
0 |
2 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2112
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) || |
|
2119
|
0 |
29 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2122
|
0 |
29 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
2126
|
0 |
29 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
2130
|
0 |
29 |
if (m->mandatory) bit_buffer |= (1 << 0); |
|
2131
|
0 |
29 |
if (m->immediate) bit_buffer |= (1 << 1); |
|
2132
|
0 |
29 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2138
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->reply_code)) |
|
2141
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->reply_text.len) || |
|
2145
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
2149
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
2157
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) || |
|
2160
|
0 |
0 |
if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) |
|
2163
|
0 |
0 |
if (m->redelivered) bit_buffer |= (1 << 0); |
|
2164
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2167
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
2171
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
2178
|
0 |
22 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2181
|
0 |
22 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
2185
|
21 |
1 |
if (m->no_ack) bit_buffer |= (1 << 0); |
|
2186
|
0 |
22 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2192
|
0 |
0 |
if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) |
|
2195
|
0 |
0 |
if (m->redelivered) bit_buffer |= (1 << 0); |
|
2196
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2199
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
2203
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
2206
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->message_count)) |
|
2213
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->cluster_id.len) || |
|
2220
|
0 |
2 |
if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) |
|
2223
|
0 |
2 |
if (m->multiple) bit_buffer |= (1 << 0); |
|
2224
|
0 |
2 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2230
|
0 |
1 |
if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) |
|
2233
|
0 |
1 |
if (m->requeue) bit_buffer |= (1 << 0); |
|
2234
|
0 |
1 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2241
|
0 |
0 |
if (m->requeue) bit_buffer |= (1 << 0); |
|
2242
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2249
|
0 |
0 |
if (m->requeue) bit_buffer |= (1 << 0); |
|
2250
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2259
|
0 |
1 |
if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) |
|
2262
|
0 |
1 |
if (m->multiple) bit_buffer |= (1 << 0); |
|
2263
|
0 |
1 |
if (m->requeue) bit_buffer |= (1 << 1); |
|
2264
|
0 |
1 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2289
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
2290
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2317
|
0 |
28 |
if (remainder != 0) { |
|
2320
|
0 |
28 |
if (!amqp_encode_16(encoded, &offset, partial_flags)) |
|
2323
|
0 |
28 |
} while (remaining_flags != 0); |
|
2344
|
5 |
23 |
if (flags & AMQP_BASIC_CONTENT_TYPE_FLAG) { |
|
2346
|
0 |
5 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->content_type.len) || |
|
2350
|
8 |
20 |
if (flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) { |
|
2353
|
0 |
8 |
(uint8_t)p->content_encoding.len) || |
|
2357
|
9 |
19 |
if (flags & AMQP_BASIC_HEADERS_FLAG) { |
|
2360
|
0 |
9 |
if (res < 0) return res; |
|
2363
|
5 |
23 |
if (flags & AMQP_BASIC_DELIVERY_MODE_FLAG) { |
|
2364
|
0 |
5 |
if (!amqp_encode_8(encoded, &offset, p->delivery_mode)) |
|
2367
|
5 |
23 |
if (flags & AMQP_BASIC_PRIORITY_FLAG) { |
|
2368
|
0 |
5 |
if (!amqp_encode_8(encoded, &offset, p->priority)) |
|
2371
|
5 |
23 |
if (flags & AMQP_BASIC_CORRELATION_ID_FLAG) { |
|
2373
|
0 |
5 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->correlation_id.len) || |
|
2377
|
5 |
23 |
if (flags & AMQP_BASIC_REPLY_TO_FLAG) { |
|
2379
|
0 |
5 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->reply_to.len) || |
|
2383
|
5 |
23 |
if (flags & AMQP_BASIC_EXPIRATION_FLAG) { |
|
2385
|
0 |
5 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->expiration.len) || |
|
2389
|
5 |
23 |
if (flags & AMQP_BASIC_MESSAGE_ID_FLAG) { |
|
2391
|
0 |
5 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->message_id.len) || |
|
2395
|
5 |
23 |
if (flags & AMQP_BASIC_TIMESTAMP_FLAG) { |
|
2396
|
0 |
5 |
if (!amqp_encode_64(encoded, &offset, p->timestamp)) |
|
2399
|
5 |
23 |
if (flags & AMQP_BASIC_TYPE_FLAG) { |
|
2401
|
0 |
5 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->type.len) || |
|
2405
|
5 |
23 |
if (flags & AMQP_BASIC_USER_ID_FLAG) { |
|
2407
|
0 |
5 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->user_id.len) || |
|
2411
|
5 |
23 |
if (flags & AMQP_BASIC_APP_ID_FLAG) { |
|
2413
|
0 |
5 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->app_id.len) || |
|
2417
|
0 |
28 |
if (flags & AMQP_BASIC_CLUSTER_ID_FLAG) { |
|
2419
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->cluster_id.len) || |