}
void amok_bw_sat_join(void) {
- gras_cb_register(gras_msgtype_by_name("amok_bw_sat start"),
- &amok_bw_cb_sat_start);
- gras_cb_register(gras_msgtype_by_name("amok_bw_sat begin"),
- &amok_bw_cb_sat_begin);
+ gras_cb_register("amok_bw_sat start", &amok_bw_cb_sat_start);
+ gras_cb_register("amok_bw_sat begin", &amok_bw_cb_sat_begin);
}
void amok_bw_sat_leave(void) {
- gras_cb_unregister(gras_msgtype_by_name("amok_bw_sat start"),
- &amok_bw_cb_sat_start);
- gras_cb_unregister(gras_msgtype_by_name("amok_bw_sat begin"),
- &amok_bw_cb_sat_begin);
+ gras_cb_unregister("amok_bw_sat start", &amok_bw_cb_sat_start);
+ gras_cb_unregister("amok_bw_sat begin", &amok_bw_cb_sat_begin);
}
/* ***************************************************************************
request->duration=duration;
request->msg_size=msg_size;
- gras_msg_rpccall(sock,60,gras_msgtype_by_name("amok_bw_sat start"),&request, NULL);
+ gras_msg_rpccall(sock,60,"amok_bw_sat start",&request, NULL);
free(request);
gras_socket_close(sock);
free(request->peer.name);
free(request);
- return 1;
+ return 0;
}
/**
double bw;
double sec;
amok_bw_test(peer_cmd,
- 0,512*1024, 512*1024, /* 512k as first guess */
+ 0, /* check buffsize yourself */
+ 512*1024, /* 512k as first guess */
+ 1, /* One packet only */
1, /* at least one sec */
&sec, &bw);
msg_size = request->msg_size = (int)bw;
/* Launch the saturation */
- ctx = gras_msg_rpc_async_call(peer_cmd, 60,
- gras_msgtype_by_name("amok_bw_sat begin"),
- &request);
+ ctx = gras_msg_rpc_async_call(peer_cmd, 60, "amok_bw_sat begin", &request);
free(request);
gras_msg_rpc_async_wait(ctx,&request);
meas=gras_socket_client_ext( to_name, request->peer.port,
/* Check whether someone asked us to stop saturation */
saturate_further = 0;
TRY {
- gras_msg_wait_ext(0/*no wait*/,gras_msgtype_by_name("amok_bw_sat stop"),
+ gras_msg_wait_ext(0/*no wait*/,"amok_bw_sat stop",
NULL /* accept any sender */,
NULL, NULL, /* No specific filter */
&msg_got);
if (gras_if_RL()) /* On SG, accepted=master */
gras_socket_close(measMaster);
free(request);
- return 1;
+ return 0;
}
/**
bw_res_t answer;
VERB2("Ask %s:%d to stop the saturation",from_name,from_port);
TRY {
- gras_msg_rpccall(sock,60,gras_msgtype_by_name("amok_bw_sat stop"),NULL,&answer);
+ gras_msg_rpccall(sock,60,"amok_bw_sat stop",NULL,&answer);
} CATCH(e) {
RETHROW2("Cannot ask %s:%d to stop saturation: %s",from_name, from_port);
}