- gras_socket_t exp = gras_msg_cb_ctx_from(ctx);
- xbt_peer_t dude = xbt_peer_new(gras_socket_peer_name(exp),
- gras_socket_peer_port(exp));
+ xbt_socket_t exp = gras_msg_cb_ctx_from(ctx);
+ xbt_peer_t dude = xbt_peer_new(xbt_socket_peer_name(exp),
+ xbt_socket_peer_port(exp));
rank = xbt_dynar_length(group);
xbt_dynar_push(group, &dude);
rank = xbt_dynar_length(group);
xbt_dynar_push(group, &dude);
char *name = *(void **) payload;
xbt_dynar_t group = xbt_dict_get(g->groups, name);
char *name = *(void **) payload;
xbt_dynar_t group = xbt_dict_get(g->groups, name);
- gras_socket_t exp = gras_msg_cb_ctx_from(ctx);
- xbt_peer_t dude = xbt_peer_new(gras_socket_peer_name(exp),
- gras_socket_peer_port(exp));
+ xbt_socket_t exp = gras_msg_cb_ctx_from(ctx);
+ xbt_peer_t dude = xbt_peer_new(xbt_socket_peer_name(exp),
+ xbt_socket_peer_port(exp));
/** \brief kill a buddy identified by its peername and port. Note that it is not removed from any group it may belong to. */
void amok_pm_kill_hp(char *name, int port)
{
/** \brief kill a buddy identified by its peername and port. Note that it is not removed from any group it may belong to. */
void amok_pm_kill_hp(char *name, int port)
{
{
gras_msg_send(buddy, "amok_pm_kill", NULL);
}
/** \brief kill syncronously a buddy (do not return before its death). Note that it is not removed from any group it may belong to. */
{
gras_msg_send(buddy, "amok_pm_kill", NULL);
}
/** \brief kill syncronously a buddy (do not return before its death). Note that it is not removed from any group it may belong to. */
{
gras_msg_rpccall(buddy, 30, "amok_pm_killrpc", NULL, NULL);
}
{
gras_msg_rpccall(buddy, 30, "amok_pm_killrpc", NULL, NULL);
}
- group_name, gras_socket_peer_name(master),
- gras_socket_peer_port(master));
+ group_name, xbt_socket_peer_name(master),
+ xbt_socket_peer_port(master));
gras_msg_rpccall(master, 30, "amok_pm_join", &group_name, &rank);
XBT_VERB("Joined group '%s' on %s:%d. Got rank %d",
gras_msg_rpccall(master, 30, "amok_pm_join", &group_name, &rank);
XBT_VERB("Joined group '%s' on %s:%d. Got rank %d",
- group_name, gras_socket_peer_name(master),
- gras_socket_peer_port(master), rank);
+ group_name, xbt_socket_peer_name(master),
+ xbt_socket_peer_port(master), rank);
{
gras_msg_rpccall(master, 30, "amok_pm_leave", &group_name, NULL);
XBT_VERB("Leaved group '%s' on %s:%d",
{
gras_msg_rpccall(master, 30, "amok_pm_leave", &group_name, NULL);
XBT_VERB("Leaved group '%s' on %s:%d",
- group_name, gras_socket_peer_name(master),
- gras_socket_peer_port(master));
+ group_name, xbt_socket_peer_name(master),
+ xbt_socket_peer_port(master));
const char *group_name)
{
gras_msg_rpccall(master, 30, "amok_pm_shutdown", &group_name, NULL);
const char *group_name)
{
gras_msg_rpccall(master, 30, "amok_pm_shutdown", &group_name, NULL);
- gras_datadesc_type_t pm_group_type =
- gras_datadesc_dynar(gras_datadesc_by_name("xbt_peer_t"),
+ xbt_datadesc_type_t pm_group_type =
+ xbt_datadesc_dynar(xbt_datadesc_by_name("xbt_peer_t"),
xbt_peer_free_voidp);
gras_msgtype_declare("amok_pm_kill", NULL);
gras_msgtype_declare_rpc("amok_pm_killrpc", NULL, NULL);
gras_msgtype_declare_rpc("amok_pm_get",
xbt_peer_free_voidp);
gras_msgtype_declare("amok_pm_kill", NULL);
gras_msgtype_declare_rpc("amok_pm_killrpc", NULL, NULL);
gras_msgtype_declare_rpc("amok_pm_get",
- gras_datadesc_by_name("string"), pm_group_type);
- gras_msgtype_declare_rpc("amok_pm_join", gras_datadesc_by_name("string"),
- gras_datadesc_by_name("int"));
+ xbt_datadesc_by_name("string"), pm_group_type);
+ gras_msgtype_declare_rpc("amok_pm_join", xbt_datadesc_by_name("string"),
+ xbt_datadesc_by_name("int"));