X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/7737fe83b6997840d056ade87e2775333e5f620f..5b547799240cfe5d60c1c4161e3fc8849095e2ca:/examples/c/app-chainsend/peer.c diff --git a/examples/c/app-chainsend/peer.c b/examples/c/app-chainsend/peer.c index d49e9f7f5a..022e851b30 100644 --- a/examples/c/app-chainsend/peer.c +++ b/examples/c/app-chainsend/peer.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2012-2020. The SimGrid Team. +/* Copyright (c) 2012-2021. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -30,7 +30,7 @@ static void peer_forward_file(peer_t p) p->pending_recvs[nb_pending_recvs] = sg_mailbox_get_async(p->me, &received); nb_pending_recvs++; - int idx = sg_comm_wait_any(p->pending_recvs, nb_pending_recvs); + ssize_t idx = sg_comm_wait_any(p->pending_recvs, nb_pending_recvs); if (idx != -1) { XBT_DEBUG("Peer %s got a 'SEND_DATA' message", sg_mailbox_get_name(p->me)); /* move the last pending comm where the finished one was, and decrement */ @@ -56,15 +56,15 @@ static void peer_forward_file(peer_t p) sg_comm_wait_all(p->pending_sends, nb_pending_sends); } -static peer_t peer_init(XBT_ATTRIB_UNUSED int argc, XBT_ATTRIB_UNUSED char* argv[]) +static peer_t peer_init(int argc, char* argv[]) { - peer_t p = (peer_t)malloc(sizeof(s_peer_t)); + peer_t p = xbt_malloc(sizeof(s_peer_t)); p->prev = NULL; p->next = NULL; p->received_pieces = 0; p->received_bytes = 0; - p->pending_recvs = (sg_comm_t*)malloc(sizeof(sg_comm_t) * MAX_PENDING_COMMS); - p->pending_sends = (sg_comm_t*)malloc(sizeof(sg_comm_t) * MAX_PENDING_COMMS); + p->pending_recvs = xbt_malloc(sizeof(sg_comm_t) * MAX_PENDING_COMMS); + p->pending_sends = xbt_malloc(sizeof(sg_comm_t) * MAX_PENDING_COMMS); p->me = sg_mailbox_by_name(sg_host_self_get_name());