static void peer_join_chain(peer_t p)
{
- const chain_message_t msg = (chain_message_t)sg_mailbox_get(p->me);
- p->prev = msg->prev_;
- p->next = msg->next_;
- p->total_pieces = msg->num_pieces;
+ chain_message_t msg = (chain_message_t)sg_mailbox_get(p->me);
+ p->prev = msg->prev_;
+ p->next = msg->next_;
+ p->total_pieces = msg->num_pieces;
XBT_DEBUG("Peer %s got a 'BUILD_CHAIN' message (prev: %s / next: %s)", sg_mailbox_get_name(p->me),
p->prev ? sg_mailbox_get_name(p->prev) : NULL, p->next ? sg_mailbox_get_name(p->next) : NULL);
free(msg);
}
-static void peer_forward_file(const peer_t p)
+static void peer_forward_file(peer_t p)
{
void* received;
int done = 0;
SG_BEGIN_DECL
XBT_PUBLIC void sg_exec_set_bound(sg_exec_t exec, double bound);
-XBT_PUBLIC double sg_exec_get_remaining(sg_exec_t exec);
+XBT_PUBLIC double sg_exec_get_remaining(const_sg_exec_t exec);
XBT_PUBLIC void sg_exec_start(sg_exec_t exec);
XBT_PUBLIC void sg_exec_wait(sg_exec_t exec);
static void worker()
{
- std::string* payload;
+ const std::string* payload;
simgrid::s4u::Mailbox* mailbox = simgrid::s4u::Mailbox::by_name("jupi");
while (1) {
try {
payload = static_cast<std::string*>(mailbox->get());
- } catch (simgrid::HostFailureException&) {
+ } catch (const simgrid::HostFailureException&) {
XBT_DEBUG("The host has been turned off, this was expected");
return;
}
payload = new std::string("task off");
try {
mailbox->put_async(payload, 1E6)->wait_for(1);
- } catch (simgrid::TimeoutException&) {
+ } catch (const simgrid::TimeoutException&) {
delete payload;
}
payload = new std::string("task on without actor");
try {
mailbox->put_async(payload, 1E6)->wait_for(1);
- } catch (simgrid::TimeoutException&) {
+ } catch (const simgrid::TimeoutException&) {
delete payload;
}
payload = new std::string("task on with actor");
try {
mailbox->put_async(payload, 1E6)->wait_for(1);
- } catch (simgrid::TimeoutException&) {
+ } catch (const simgrid::TimeoutException&) {
delete payload;
}
payload = new std::string("finalize");
try {
mailbox->put_async(payload, 0)->wait_for(1);
- } catch (simgrid::TimeoutException&) {
+ } catch (const simgrid::TimeoutException&) {
delete payload;
}