| line |
true |
false |
branch |
|
265
|
0 |
0 |
if (m == NULL) { |
|
268
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &m->version_major)) |
|
270
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &m->version_minor)) |
|
275
|
0 |
0 |
if (res < 0) return res; |
|
296
|
0 |
0 |
if (m == NULL) { |
|
302
|
0 |
0 |
if (res < 0) return res; |
|
328
|
0 |
0 |
if (m == NULL) { |
|
344
|
0 |
0 |
if (m == NULL) { |
|
359
|
0 |
0 |
if (m == NULL) { |
|
362
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->channel_max)) |
|
364
|
0 |
0 |
if (!amqp_decode_32(encoded, &offset, &m->frame_max)) |
|
366
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->heartbeat)) |
|
375
|
0 |
0 |
if (m == NULL) { |
|
378
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->channel_max)) |
|
380
|
0 |
0 |
if (!amqp_decode_32(encoded, &offset, &m->frame_max)) |
|
382
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->heartbeat)) |
|
390
|
0 |
0 |
if (m == NULL) { |
|
405
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
415
|
0 |
0 |
if (m == NULL) { |
|
430
|
0 |
0 |
if (m == NULL) { |
|
433
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->reply_code)) |
|
441
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->class_id)) |
|
443
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->method_id)) |
|
452
|
0 |
0 |
if (m == NULL) { |
|
462
|
0 |
0 |
if (m == NULL) { |
|
478
|
0 |
0 |
if (m == NULL) { |
|
488
|
0 |
0 |
if (m == NULL) { |
|
510
|
0 |
0 |
if (m == NULL) { |
|
519
|
0 |
0 |
if (m == NULL) { |
|
534
|
0 |
0 |
if (m == NULL) { |
|
549
|
0 |
0 |
if (m == NULL) { |
|
552
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
561
|
0 |
0 |
if (m == NULL) { |
|
564
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
573
|
0 |
0 |
if (m == NULL) { |
|
576
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->reply_code)) |
|
584
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->class_id)) |
|
586
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->method_id)) |
|
594
|
0 |
0 |
if (m == NULL) { |
|
603
|
0 |
0 |
if (m == NULL) { |
|
612
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
625
|
0 |
0 |
if (m == NULL) { |
|
628
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
636
|
0 |
0 |
if (m == NULL) { |
|
639
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
653
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
662
|
0 |
0 |
if (res < 0) return res; |
|
671
|
0 |
0 |
if (m == NULL) { |
|
680
|
0 |
0 |
if (m == NULL) { |
|
683
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
691
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
702
|
0 |
0 |
if (m == NULL) { |
|
711
|
0 |
0 |
if (m == NULL) { |
|
714
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
734
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
739
|
0 |
0 |
if (res < 0) return res; |
|
747
|
0 |
0 |
if (m == NULL) { |
|
756
|
0 |
0 |
if (m == NULL) { |
|
759
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
779
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
784
|
0 |
0 |
if (res < 0) return res; |
|
793
|
0 |
0 |
if (m == NULL) { |
|
802
|
0 |
0 |
if (m == NULL) { |
|
805
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
813
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
822
|
0 |
0 |
if (res < 0) return res; |
|
830
|
0 |
0 |
if (m == NULL) { |
|
839
|
0 |
0 |
if (!amqp_decode_32(encoded, &offset, &m->message_count)) |
|
841
|
0 |
0 |
if (!amqp_decode_32(encoded, &offset, &m->consumer_count)) |
|
849
|
0 |
0 |
if (m == NULL) { |
|
852
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
872
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
877
|
0 |
0 |
if (res < 0) return res; |
|
885
|
0 |
0 |
if (m == NULL) { |
|
894
|
0 |
0 |
if (m == NULL) { |
|
897
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
905
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
914
|
0 |
0 |
if (m == NULL) { |
|
917
|
0 |
0 |
if (!amqp_decode_32(encoded, &offset, &m->message_count)) |
|
925
|
0 |
0 |
if (m == NULL) { |
|
928
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
936
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
947
|
0 |
0 |
if (m == NULL) { |
|
950
|
0 |
0 |
if (!amqp_decode_32(encoded, &offset, &m->message_count)) |
|
958
|
0 |
0 |
if (m == NULL) { |
|
961
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
983
|
0 |
0 |
if (res < 0) return res; |
|
991
|
0 |
0 |
if (m == NULL) { |
|
1000
|
0 |
0 |
if (m == NULL) { |
|
1003
|
0 |
0 |
if (!amqp_decode_32(encoded, &offset, &m->prefetch_size)) |
|
1005
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->prefetch_count)) |
|
1007
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1016
|
0 |
0 |
if (m == NULL) { |
|
1025
|
0 |
0 |
if (m == NULL) { |
|
1028
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
1042
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1050
|
0 |
0 |
if (res < 0) return res; |
|
1058
|
0 |
0 |
if (m == NULL) { |
|
1073
|
0 |
0 |
if (m == NULL) { |
|
1082
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1091
|
0 |
0 |
if (m == NULL) { |
|
1106
|
0 |
0 |
if (m == NULL) { |
|
1109
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
1123
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1133
|
0 |
0 |
if (m == NULL) { |
|
1136
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->reply_code)) |
|
1162
|
0 |
0 |
if (m == NULL) { |
|
1171
|
0 |
0 |
if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) |
|
1173
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1194
|
0 |
0 |
if (m == NULL) { |
|
1197
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &m->ticket)) |
|
1205
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1214
|
0 |
0 |
if (m == NULL) { |
|
1217
|
0 |
0 |
if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) |
|
1219
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1234
|
0 |
0 |
if (!amqp_decode_32(encoded, &offset, &m->message_count)) |
|
1242
|
0 |
0 |
if (m == NULL) { |
|
1257
|
0 |
0 |
if (m == NULL) { |
|
1260
|
0 |
0 |
if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) |
|
1262
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1271
|
0 |
0 |
if (m == NULL) { |
|
1274
|
0 |
0 |
if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) |
|
1276
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1286
|
0 |
0 |
if (m == NULL) { |
|
1289
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1298
|
0 |
0 |
if (m == NULL) { |
|
1301
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1310
|
0 |
0 |
if (m == NULL) { |
|
1319
|
0 |
0 |
if (m == NULL) { |
|
1322
|
0 |
0 |
if (!amqp_decode_64(encoded, &offset, &m->delivery_tag)) |
|
1324
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1334
|
0 |
0 |
if (m == NULL) { |
|
1343
|
0 |
0 |
if (m == NULL) { |
|
1352
|
0 |
0 |
if (m == NULL) { |
|
1361
|
0 |
0 |
if (m == NULL) { |
|
1370
|
0 |
0 |
if (m == NULL) { |
|
1379
|
0 |
0 |
if (m == NULL) { |
|
1388
|
0 |
0 |
if (m == NULL) { |
|
1391
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &bit_buffer)) |
|
1400
|
0 |
0 |
if (m == NULL) { |
|
1420
|
0 |
0 |
if (!amqp_decode_16(encoded, &offset, &partial_flags)) |
|
1424
|
0 |
0 |
} while (partial_flags & 1); |
|
1431
|
0 |
0 |
if (p == NULL) { |
|
1442
|
0 |
0 |
if (p == NULL) { |
|
1452
|
0 |
0 |
if (p == NULL) { |
|
1463
|
0 |
0 |
if (p == NULL) { |
|
1473
|
0 |
0 |
if (p == NULL) { |
|
1483
|
0 |
0 |
if (p == NULL) { |
|
1487
|
0 |
0 |
if (flags & AMQP_BASIC_CONTENT_TYPE_FLAG) { |
|
1495
|
0 |
0 |
if (flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) { |
|
1503
|
0 |
0 |
if (flags & AMQP_BASIC_HEADERS_FLAG) { |
|
1506
|
0 |
0 |
if (res < 0) return res; |
|
1509
|
0 |
0 |
if (flags & AMQP_BASIC_DELIVERY_MODE_FLAG) { |
|
1510
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &p->delivery_mode)) |
|
1513
|
0 |
0 |
if (flags & AMQP_BASIC_PRIORITY_FLAG) { |
|
1514
|
0 |
0 |
if (!amqp_decode_8(encoded, &offset, &p->priority)) |
|
1517
|
0 |
0 |
if (flags & AMQP_BASIC_CORRELATION_ID_FLAG) { |
|
1525
|
0 |
0 |
if (flags & AMQP_BASIC_REPLY_TO_FLAG) { |
|
1533
|
0 |
0 |
if (flags & AMQP_BASIC_EXPIRATION_FLAG) { |
|
1541
|
0 |
0 |
if (flags & AMQP_BASIC_MESSAGE_ID_FLAG) { |
|
1549
|
0 |
0 |
if (flags & AMQP_BASIC_TIMESTAMP_FLAG) { |
|
1550
|
0 |
0 |
if (!amqp_decode_64(encoded, &offset, &p->timestamp)) |
|
1553
|
0 |
0 |
if (flags & AMQP_BASIC_TYPE_FLAG) { |
|
1561
|
0 |
0 |
if (flags & AMQP_BASIC_USER_ID_FLAG) { |
|
1569
|
0 |
0 |
if (flags & AMQP_BASIC_APP_ID_FLAG) { |
|
1577
|
0 |
0 |
if (flags & AMQP_BASIC_CLUSTER_ID_FLAG) { |
|
1591
|
0 |
0 |
if (p == NULL) { |
|
1602
|
0 |
0 |
if (p == NULL) { |
|
1622
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, m->version_major)) |
|
1624
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, m->version_minor)) |
|
1628
|
0 |
0 |
if (res < 0) return res; |
|
1631
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->mechanisms.len) || |
|
1635
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->locales.len) || |
|
1644
|
0 |
0 |
if (res < 0) return res; |
|
1647
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->mechanism.len) || |
|
1651
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->response.len) || |
|
1655
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->locale.len) || |
|
1663
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->challenge.len) || |
|
1671
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->response.len) || |
|
1678
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->channel_max)) |
|
1680
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->frame_max)) |
|
1682
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->heartbeat)) |
|
1688
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->channel_max)) |
|
1690
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->frame_max)) |
|
1692
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->heartbeat)) |
|
1699
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->virtual_host.len) || |
|
1703
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->capabilities.len) || |
|
1707
|
0 |
0 |
if (m->insist) bit_buffer |= (1 << 0); |
|
1708
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1715
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->known_hosts.len) || |
|
1722
|
0 |
1 |
if (!amqp_encode_16(encoded, &offset, m->reply_code)) |
|
1725
|
0 |
1 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->reply_text.len) || |
|
1728
|
0 |
1 |
if (!amqp_encode_16(encoded, &offset, m->class_id)) |
|
1730
|
0 |
1 |
if (!amqp_encode_16(encoded, &offset, m->method_id)) |
|
1740
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->reason.len) || |
|
1752
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->new_secret.len) || |
|
1756
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->reason.len) || |
|
1767
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->out_of_band.len) || |
|
1775
|
0 |
0 |
!amqp_encode_32(encoded, &offset, (uint32_t)m->channel_id.len) || |
|
1783
|
0 |
0 |
if (m->active) bit_buffer |= (1 << 0); |
|
1784
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1791
|
0 |
0 |
if (m->active) bit_buffer |= (1 << 0); |
|
1792
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1798
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->reply_code)) |
|
1801
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->reply_text.len) || |
|
1804
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->class_id)) |
|
1806
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->method_id)) |
|
1816
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->realm.len) || |
|
1820
|
0 |
0 |
if (m->exclusive) bit_buffer |= (1 << 0); |
|
1821
|
0 |
0 |
if (m->passive) bit_buffer |= (1 << 1); |
|
1822
|
0 |
0 |
if (m->active) bit_buffer |= (1 << 2); |
|
1823
|
0 |
0 |
if (m->write) bit_buffer |= (1 << 3); |
|
1824
|
0 |
0 |
if (m->read) bit_buffer |= (1 << 4); |
|
1825
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1831
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1837
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1840
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
1844
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->type.len) || |
|
1848
|
0 |
0 |
if (m->passive) bit_buffer |= (1 << 0); |
|
1849
|
0 |
0 |
if (m->durable) bit_buffer |= (1 << 1); |
|
1850
|
0 |
0 |
if (m->auto_delete) bit_buffer |= (1 << 2); |
|
1851
|
0 |
0 |
if (m->internal) bit_buffer |= (1 << 3); |
|
1852
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 4); |
|
1853
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1857
|
0 |
0 |
if (res < 0) return res; |
|
1866
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1869
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
1873
|
0 |
0 |
if (m->if_unused) bit_buffer |= (1 << 0); |
|
1874
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 1); |
|
1875
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1884
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1887
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->destination.len) || |
|
1891
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->source.len) || |
|
1895
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
1899
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
1900
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1904
|
0 |
0 |
if (res < 0) return res; |
|
1913
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1916
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->destination.len) || |
|
1920
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->source.len) || |
|
1924
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
1928
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
1929
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1933
|
0 |
0 |
if (res < 0) return res; |
|
1942
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1945
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
1949
|
0 |
0 |
if (m->passive) bit_buffer |= (1 << 0); |
|
1950
|
0 |
0 |
if (m->durable) bit_buffer |= (1 << 1); |
|
1951
|
0 |
0 |
if (m->exclusive) bit_buffer |= (1 << 2); |
|
1952
|
0 |
0 |
if (m->auto_delete) bit_buffer |= (1 << 3); |
|
1953
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 4); |
|
1954
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1958
|
0 |
0 |
if (res < 0) return res; |
|
1965
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
1968
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->message_count)) |
|
1970
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->consumer_count)) |
|
1976
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
1979
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
1983
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
1987
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
1991
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
1992
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
1996
|
0 |
0 |
if (res < 0) return res; |
|
2005
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2008
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
2012
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
2013
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2019
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->message_count)) |
|
2025
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2028
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
2032
|
0 |
0 |
if (m->if_unused) bit_buffer |= (1 << 0); |
|
2033
|
0 |
0 |
if (m->if_empty) bit_buffer |= (1 << 1); |
|
2034
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 2); |
|
2035
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2041
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->message_count)) |
|
2047
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2050
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
2054
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
2058
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
2063
|
0 |
0 |
if (res < 0) return res; |
|
2072
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->prefetch_size)) |
|
2074
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->prefetch_count)) |
|
2077
|
0 |
0 |
if (m->global) bit_buffer |= (1 << 0); |
|
2078
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2087
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2090
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
2094
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) || |
|
2098
|
0 |
0 |
if (m->no_local) bit_buffer |= (1 << 0); |
|
2099
|
0 |
0 |
if (m->no_ack) bit_buffer |= (1 << 1); |
|
2100
|
0 |
0 |
if (m->exclusive) bit_buffer |= (1 << 2); |
|
2101
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 3); |
|
2102
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2106
|
0 |
0 |
if (res < 0) return res; |
|
2113
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) || |
|
2121
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) || |
|
2125
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
2126
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2133
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) || |
|
2140
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2143
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
2147
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
2151
|
0 |
0 |
if (m->mandatory) bit_buffer |= (1 << 0); |
|
2152
|
0 |
0 |
if (m->immediate) bit_buffer |= (1 << 1); |
|
2153
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2159
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->reply_code)) |
|
2162
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->reply_text.len) || |
|
2166
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
2170
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
2178
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) || |
|
2181
|
0 |
0 |
if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) |
|
2184
|
0 |
0 |
if (m->redelivered) bit_buffer |= (1 << 0); |
|
2185
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2188
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
2192
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
2199
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, m->ticket)) |
|
2202
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) || |
|
2206
|
0 |
0 |
if (m->no_ack) bit_buffer |= (1 << 0); |
|
2207
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2213
|
0 |
0 |
if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) |
|
2216
|
0 |
0 |
if (m->redelivered) bit_buffer |= (1 << 0); |
|
2217
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2220
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) || |
|
2224
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) || |
|
2227
|
0 |
0 |
if (!amqp_encode_32(encoded, &offset, m->message_count)) |
|
2234
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)m->cluster_id.len) || |
|
2241
|
0 |
0 |
if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) |
|
2244
|
0 |
0 |
if (m->multiple) bit_buffer |= (1 << 0); |
|
2245
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2251
|
0 |
0 |
if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) |
|
2254
|
0 |
0 |
if (m->requeue) bit_buffer |= (1 << 0); |
|
2255
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2262
|
0 |
0 |
if (m->requeue) bit_buffer |= (1 << 0); |
|
2263
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2270
|
0 |
0 |
if (m->requeue) bit_buffer |= (1 << 0); |
|
2271
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2280
|
0 |
0 |
if (!amqp_encode_64(encoded, &offset, m->delivery_tag)) |
|
2283
|
0 |
0 |
if (m->multiple) bit_buffer |= (1 << 0); |
|
2284
|
0 |
0 |
if (m->requeue) bit_buffer |= (1 << 1); |
|
2285
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2310
|
0 |
0 |
if (m->nowait) bit_buffer |= (1 << 0); |
|
2311
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, bit_buffer)) |
|
2338
|
0 |
0 |
if (remainder != 0) { |
|
2341
|
0 |
0 |
if (!amqp_encode_16(encoded, &offset, partial_flags)) |
|
2344
|
0 |
0 |
} while (remaining_flags != 0); |
|
2365
|
0 |
0 |
if (flags & AMQP_BASIC_CONTENT_TYPE_FLAG) { |
|
2367
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->content_type.len) || |
|
2371
|
0 |
0 |
if (flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) { |
|
2374
|
0 |
0 |
(uint8_t)p->content_encoding.len) || |
|
2378
|
0 |
0 |
if (flags & AMQP_BASIC_HEADERS_FLAG) { |
|
2381
|
0 |
0 |
if (res < 0) return res; |
|
2384
|
0 |
0 |
if (flags & AMQP_BASIC_DELIVERY_MODE_FLAG) { |
|
2385
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, p->delivery_mode)) |
|
2388
|
0 |
0 |
if (flags & AMQP_BASIC_PRIORITY_FLAG) { |
|
2389
|
0 |
0 |
if (!amqp_encode_8(encoded, &offset, p->priority)) |
|
2392
|
0 |
0 |
if (flags & AMQP_BASIC_CORRELATION_ID_FLAG) { |
|
2394
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->correlation_id.len) || |
|
2398
|
0 |
0 |
if (flags & AMQP_BASIC_REPLY_TO_FLAG) { |
|
2400
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->reply_to.len) || |
|
2404
|
0 |
0 |
if (flags & AMQP_BASIC_EXPIRATION_FLAG) { |
|
2406
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->expiration.len) || |
|
2410
|
0 |
0 |
if (flags & AMQP_BASIC_MESSAGE_ID_FLAG) { |
|
2412
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->message_id.len) || |
|
2416
|
0 |
0 |
if (flags & AMQP_BASIC_TIMESTAMP_FLAG) { |
|
2417
|
0 |
0 |
if (!amqp_encode_64(encoded, &offset, p->timestamp)) |
|
2420
|
0 |
0 |
if (flags & AMQP_BASIC_TYPE_FLAG) { |
|
2422
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->type.len) || |
|
2426
|
0 |
0 |
if (flags & AMQP_BASIC_USER_ID_FLAG) { |
|
2428
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->user_id.len) || |
|
2432
|
0 |
0 |
if (flags & AMQP_BASIC_APP_ID_FLAG) { |
|
2434
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->app_id.len) || |
|
2438
|
0 |
0 |
if (flags & AMQP_BASIC_CLUSTER_ID_FLAG) { |
|
2440
|
0 |
0 |
!amqp_encode_8(encoded, &offset, (uint8_t)p->cluster_id.len) || |