Skip to content

Commit dcfb426

Browse files
committed
Lib: memset based on size of argument.
1 parent fbfbc7b commit dcfb426

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

librabbitmq/amqp_consumer.c

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ int amqp_basic_properties_clone(amqp_basic_properties_t *original,
3939
amqp_basic_properties_t *clone,
4040
amqp_pool_t *pool)
4141
{
42-
memset(clone, 0, sizeof(amqp_basic_properties_t));
42+
memset(clone, 0, sizeof(*clone));
4343
clone->_flags = original->_flags;
4444

4545
#define CLONE_BYTES_POOL(original, clone, pool) \
@@ -148,8 +148,8 @@ amqp_consume_message(amqp_connection_state_t state, amqp_envelope_t *envelope,
148148
amqp_basic_deliver_t *delivery_method;
149149
amqp_rpc_reply_t ret;
150150

151-
memset(&ret, 0, sizeof(amqp_rpc_reply_t));
152-
memset(envelope, 0, sizeof(amqp_envelope_t));
151+
memset(&ret, 0, sizeof(ret));
152+
memset(envelope, 0, sizeof(*envelope));
153153

154154
res = amqp_simple_wait_frame_noblock(state, &frame, timeout);
155155
if (AMQP_STATUS_OK != res) {
@@ -211,8 +211,8 @@ amqp_rpc_reply_t amqp_read_message(amqp_connection_state_t state,
211211
char *body_read_ptr;
212212
int res;
213213

214-
memset(&ret, 0, sizeof(amqp_rpc_reply_t));
215-
memset(message, 0, sizeof(amqp_message_t));
214+
memset(&ret, 0, sizeof(ret));
215+
memset(message, 0, sizeof(*message));
216216

217217
res = amqp_simple_wait_frame_on_channel(state, channel, &frame);
218218
if (AMQP_STATUS_OK != res) {

0 commit comments

Comments
 (0)