volatile bw_request_t request = *(bw_request_t *) payload;
bw_request_t answer;
xbt_ex_t e;
- int port;
- int tooshort = 1;
+ volatile int port;
+ volatile int tooshort = 1;
gras_msg_cb_ctx_t ctx_reask;
static xbt_dynar_t msgtwaited = NULL;
}
while (tooshort) {
- void *payload;
+ void *payloadgot;
int msggot;
TRY {
xbt_socket_meas_recv(measIn, 120, request->msg_size,
/* FIXME: tell error to remote ? */
RETHROWF("Error encountered while receiving the experiment: %s");
}
- gras_msg_wait_or(60, msgtwaited, &ctx_reask, &msggot, &payload);
+ gras_msg_wait_or(60, msgtwaited, &ctx_reask, &msggot, &payloadgot);
switch (msggot) {
case 0: /* BW stop */
tooshort = 0;
case 1: /* BW reask */
tooshort = 1;
free(request);
- request = (bw_request_t) payload;
+ request = (bw_request_t) payloadgot;
XBT_VERB("Return the reasking RPC");
gras_msg_rpcreturn(60, ctx_reask, NULL);
}