| line |
true |
false |
branch |
|
53
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_CONTENT_TYPE_FLAG) { |
|
54
|
0 |
0 |
CLONE_BYTES_POOL(original->content_type, clone->content_type, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->content_type, clone->content_type, pool) |
|
57
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) { |
|
58
|
0 |
0 |
CLONE_BYTES_POOL(original->content_encoding, clone->content_encoding, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->content_encoding, clone->content_encoding, pool) |
|
61
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_HEADERS_FLAG) { |
|
63
|
0 |
0 |
if (AMQP_STATUS_OK != res) { |
|
68
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_DELIVERY_MODE_FLAG) { |
|
72
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_PRIORITY_FLAG) { |
|
76
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_CORRELATION_ID_FLAG) { |
|
77
|
0 |
0 |
CLONE_BYTES_POOL(original->correlation_id, clone->correlation_id, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->correlation_id, clone->correlation_id, pool) |
|
80
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_REPLY_TO_FLAG) { |
|
81
|
0 |
0 |
CLONE_BYTES_POOL(original->reply_to, clone->reply_to, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->reply_to, clone->reply_to, pool) |
|
84
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_EXPIRATION_FLAG) { |
|
85
|
0 |
0 |
CLONE_BYTES_POOL(original->expiration, clone->expiration, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->expiration, clone->expiration, pool) |
|
88
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_MESSAGE_ID_FLAG) { |
|
89
|
0 |
0 |
CLONE_BYTES_POOL(original->message_id, clone->message_id, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->message_id, clone->message_id, pool) |
|
92
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_TIMESTAMP_FLAG) { |
|
96
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_TYPE_FLAG) { |
|
97
|
0 |
0 |
CLONE_BYTES_POOL(original->type, clone->type, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->type, clone->type, pool) |
|
100
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_USER_ID_FLAG) { |
|
101
|
0 |
0 |
CLONE_BYTES_POOL(original->user_id, clone->user_id, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->user_id, clone->user_id, pool) |
|
104
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_APP_ID_FLAG) { |
|
105
|
0 |
0 |
CLONE_BYTES_POOL(original->app_id, clone->app_id, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->app_id, clone->app_id, pool) |
|
108
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_CLUSTER_ID_FLAG) { |
|
109
|
0 |
0 |
CLONE_BYTES_POOL(original->cluster_id, clone->cluster_id, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->cluster_id, clone->cluster_id, pool) |
|
129
|
0 |
0 |
if (bytes.len != 0 && bytes.bytes == NULL) { |
|
|
0 |
0 |
if (bytes.len != 0 && bytes.bytes == NULL) { |
|
148
|
0 |
0 |
if (AMQP_STATUS_OK != res) { |
|
154
|
0 |
0 |
if (AMQP_FRAME_METHOD != frame.frame_type || |
|
|
0 |
0 |
if (AMQP_FRAME_METHOD != frame.frame_type || |
|
172
|
0 |
0 |
amqp_bytes_malloc_dup_failed(envelope->exchange) || |
|
180
|
0 |
0 |
if (AMQP_RESPONSE_NORMAL != ret.reply_type) { |
|
210
|
0 |
0 |
if (AMQP_STATUS_OK != res) { |
|
217
|
0 |
0 |
if (AMQP_FRAME_HEADER != frame.frame_type) { |
|
218
|
0 |
0 |
if (AMQP_FRAME_METHOD == frame.frame_type && |
|
|
0 |
0 |
if (AMQP_FRAME_METHOD == frame.frame_type && |
|
219
|
0 |
0 |
(AMQP_CHANNEL_CLOSE_METHOD == frame.payload.method.id || |
|
238
|
0 |
0 |
if (AMQP_STATUS_OK != res) { |
|
244
|
0 |
0 |
if (0 == frame.payload.properties.body_size) { |
|
254
|
0 |
0 |
if (NULL == message->body.bytes) { |
|
264
|
0 |
0 |
while (body_read < message->body.len) { |
|
266
|
0 |
0 |
if (AMQP_STATUS_OK != res) { |
|
271
|
0 |
0 |
if (AMQP_FRAME_BODY != frame.frame_type) { |
|
272
|
0 |
0 |
if (AMQP_FRAME_METHOD == frame.frame_type && |
|
|
0 |
0 |
if (AMQP_FRAME_METHOD == frame.frame_type && |
|
273
|
0 |
0 |
(AMQP_CHANNEL_CLOSE_METHOD == frame.payload.method.id || |
|
285
|
0 |
0 |
if (body_read + frame.payload.body_fragment.len > message->body.len) { |