Branch Coverage

amqp_framing.c
Criterion Covered Total %
branch 243 736 33.0


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) ||