| line |
true |
false |
branch |
|
28
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_CONTENT_TYPE_FLAG) { |
|
29
|
0 |
0 |
CLONE_BYTES_POOL(original->content_type, clone->content_type, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->content_type, clone->content_type, pool) |
|
32
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) { |
|
33
|
0 |
0 |
CLONE_BYTES_POOL(original->content_encoding, clone->content_encoding, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->content_encoding, clone->content_encoding, pool) |
|
36
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_HEADERS_FLAG) { |
|
38
|
0 |
0 |
if (AMQP_STATUS_OK != res) { |
|
43
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_DELIVERY_MODE_FLAG) { |
|
47
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_PRIORITY_FLAG) { |
|
51
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_CORRELATION_ID_FLAG) { |
|
52
|
0 |
0 |
CLONE_BYTES_POOL(original->correlation_id, clone->correlation_id, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->correlation_id, clone->correlation_id, pool) |
|
55
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_REPLY_TO_FLAG) { |
|
56
|
0 |
0 |
CLONE_BYTES_POOL(original->reply_to, clone->reply_to, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->reply_to, clone->reply_to, pool) |
|
59
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_EXPIRATION_FLAG) { |
|
60
|
0 |
0 |
CLONE_BYTES_POOL(original->expiration, clone->expiration, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->expiration, clone->expiration, pool) |
|
63
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_MESSAGE_ID_FLAG) { |
|
64
|
0 |
0 |
CLONE_BYTES_POOL(original->message_id, clone->message_id, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->message_id, clone->message_id, pool) |
|
67
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_TIMESTAMP_FLAG) { |
|
71
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_TYPE_FLAG) { |
|
72
|
0 |
0 |
CLONE_BYTES_POOL(original->type, clone->type, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->type, clone->type, pool) |
|
75
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_USER_ID_FLAG) { |
|
76
|
0 |
0 |
CLONE_BYTES_POOL(original->user_id, clone->user_id, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->user_id, clone->user_id, pool) |
|
79
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_APP_ID_FLAG) { |
|
80
|
0 |
0 |
CLONE_BYTES_POOL(original->app_id, clone->app_id, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->app_id, clone->app_id, pool) |
|
83
|
0 |
0 |
if (clone->_flags & AMQP_BASIC_CLUSTER_ID_FLAG) { |
|
84
|
0 |
0 |
CLONE_BYTES_POOL(original->cluster_id, clone->cluster_id, pool) |
|
|
0 |
0 |
CLONE_BYTES_POOL(original->cluster_id, clone->cluster_id, pool) |
|
104
|
0 |
0 |
if (bytes.len != 0 && bytes.bytes == NULL) { |
|
|
0 |
0 |
if (bytes.len != 0 && bytes.bytes == NULL) { |
|
123
|
0 |
0 |
if (AMQP_STATUS_OK != res) { |
|
129
|
0 |
0 |
if (AMQP_FRAME_METHOD != frame.frame_type || |
|
130
|
0 |
0 |
AMQP_BASIC_DELIVER_METHOD != frame.payload.method.id) { |
|
147
|
0 |
0 |
amqp_bytes_malloc_dup_failed(envelope->exchange) || |
|
155
|
0 |
0 |
if (AMQP_RESPONSE_NORMAL != ret.reply_type) { |
|
185
|
0 |
0 |
if (AMQP_STATUS_OK != res) { |
|
192
|
0 |
0 |
if (AMQP_FRAME_HEADER != frame.frame_type) { |
|
193
|
0 |
0 |
if (AMQP_FRAME_METHOD == frame.frame_type && |
|
194
|
0 |
0 |
(AMQP_CHANNEL_CLOSE_METHOD == frame.payload.method.id || |
|
195
|
0 |
0 |
AMQP_CONNECTION_CLOSE_METHOD == frame.payload.method.id)) { |
|
213
|
0 |
0 |
if (AMQP_STATUS_OK != res) { |
|
219
|
0 |
0 |
if (0 == frame.payload.properties.body_size) { |
|
229
|
0 |
0 |
if (NULL == message->body.bytes) { |
|
239
|
0 |
0 |
while (body_read < message->body.len) { |
|
241
|
0 |
0 |
if (AMQP_STATUS_OK != res) { |
|
246
|
0 |
0 |
if (AMQP_FRAME_BODY != frame.frame_type) { |
|
247
|
0 |
0 |
if (AMQP_FRAME_METHOD == frame.frame_type && |
|
248
|
0 |
0 |
(AMQP_CHANNEL_CLOSE_METHOD == frame.payload.method.id || |
|
249
|
0 |
0 |
AMQP_CONNECTION_CLOSE_METHOD == frame.payload.method.id)) { |
|
260
|
0 |
0 |
if (body_read + frame.payload.body_fragment.len > message->body.len) { |