diff options
author | Christian Grothoff <christian@grothoff.org> | 2013-03-21 14:45:09 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2013-03-21 14:45:09 +0000 |
commit | 4616bf9d016bcfb319954e52b5d24fc93c3cf1b2 (patch) | |
tree | 985713a4c9ccb003771f04da808fed7d3a74fe93 /src/consensus | |
parent | 75c121f5ae37d3c7ccd95f4449aea33ccb4200f0 (diff) | |
download | gnunet-4616bf9d016bcfb319954e52b5d24fc93c3cf1b2.tar.gz gnunet-4616bf9d016bcfb319954e52b5d24fc93c3cf1b2.zip |
-idea for improved allocator
Diffstat (limited to 'src/consensus')
-rw-r--r-- | src/consensus/consensus_api.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/consensus/consensus_api.c b/src/consensus/consensus_api.c index be5117730..25ace3a4d 100644 --- a/src/consensus/consensus_api.c +++ b/src/consensus/consensus_api.c | |||
@@ -201,7 +201,8 @@ transmit_queued (void *cls, size_t size, | |||
201 | { | 201 | { |
202 | qmsg->idc (qmsg->idc_cls, GNUNET_YES); | 202 | qmsg->idc (qmsg->idc_cls, GNUNET_YES); |
203 | } | 203 | } |
204 | 204 | GNUNET_free (qmsg->msg); | |
205 | GNUNET_free (qmsg); | ||
205 | /* FIXME: free the messages */ | 206 | /* FIXME: free the messages */ |
206 | 207 | ||
207 | send_next (consensus); | 208 | send_next (consensus); |
@@ -262,12 +263,12 @@ handle_new_element (struct GNUNET_CONSENSUS_Handle *consensus, | |||
262 | 263 | ||
263 | ret = consensus->new_element_cb (consensus->new_element_cls, &element); | 264 | ret = consensus->new_element_cb (consensus->new_element_cls, &element); |
264 | 265 | ||
265 | ack_msg = GNUNET_malloc (sizeof *ack_msg); | 266 | ack_msg = GNUNET_new (struct GNUNET_CONSENSUS_AckMessage); |
266 | ack_msg->header.size = htons (sizeof *ack_msg); | 267 | ack_msg->header.size = htons (sizeof *ack_msg); |
267 | ack_msg->header.type = htons (GNUNET_MESSAGE_TYPE_CONSENSUS_CLIENT_ACK); | 268 | ack_msg->header.type = htons (GNUNET_MESSAGE_TYPE_CONSENSUS_CLIENT_ACK); |
268 | ack_msg->keep = ret; | 269 | ack_msg->keep = ret; |
269 | 270 | ||
270 | queue_message (consensus, (struct GNUNET_MessageHeader *) ack_msg); | 271 | queue_message (consensus, &ack_msg->header); |
271 | 272 | ||
272 | send_next (consensus); | 273 | send_next (consensus); |
273 | } | 274 | } |