aboutsummaryrefslogtreecommitdiff
path: root/src/consensus
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2013-03-21 14:45:09 +0000
committerChristian Grothoff <christian@grothoff.org>2013-03-21 14:45:09 +0000
commit4616bf9d016bcfb319954e52b5d24fc93c3cf1b2 (patch)
tree985713a4c9ccb003771f04da808fed7d3a74fe93 /src/consensus
parent75c121f5ae37d3c7ccd95f4449aea33ccb4200f0 (diff)
downloadgnunet-4616bf9d016bcfb319954e52b5d24fc93c3cf1b2.tar.gz
gnunet-4616bf9d016bcfb319954e52b5d24fc93c3cf1b2.zip
-idea for improved allocator
Diffstat (limited to 'src/consensus')
-rw-r--r--src/consensus/consensus_api.c7
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}