ra_data 141 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = connection_rsc->remote_ra_data; ra_data 143 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = g_list_remove(ra_data->recurring_cmds, cmd); ra_data 145 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); ra_data 146 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 160 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = connection_rsc->remote_ra_data; ra_data 162 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 322 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state? lrm_state->remote_ra_data : NULL; ra_data 324 daemons/controld/controld_remote_ra.c if (ra_data) { ra_data 325 daemons/controld/controld_remote_ra.c if (ra_data->migrate_status != takeover_complete) { ra_data 414 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 418 daemons/controld/controld_remote_ra.c if (!ra_data || !ra_data->cur_cmd) { ra_data 421 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; ra_data 438 daemons/controld/controld_remote_ra.c if (ra_data->cmds) { ra_data 439 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 441 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = NULL; ra_data 483 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 485 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd == cmd) { ra_data 486 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = NULL; ra_data 488 daemons/controld/controld_remote_ra.c if (ra_data->cmds) { ra_data 489 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 528 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = NULL; ra_data 543 daemons/controld/controld_remote_ra.c ra_data = lrm_state->remote_ra_data; ra_data 548 daemons/controld/controld_remote_ra.c if (ra_data->migrate_status == expect_takeover) { ra_data 550 daemons/controld/controld_remote_ra.c ra_data->migrate_status = takeover_complete; ra_data 565 daemons/controld/controld_remote_ra.c if (ra_data->migrate_status == takeover_complete) { ra_data 573 daemons/controld/controld_remote_ra.c if ((op->type == lrmd_event_disconnect) && (ra_data->cur_cmd == NULL)) { ra_data 575 daemons/controld/controld_remote_ra.c if (ra_data->active == FALSE) { ra_data 582 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = fail_all_monitor_cmds(ra_data->recurring_cmds); ra_data 583 daemons/controld/controld_remote_ra.c ra_data->cmds = fail_all_monitor_cmds(ra_data->cmds); ra_data 597 daemons/controld/controld_remote_ra.c if (!ra_data->cur_cmd) { ra_data 602 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; ra_data 633 daemons/controld/controld_remote_ra.c ra_data->active = TRUE; ra_data 660 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = g_list_append(ra_data->recurring_cmds, cmd); ra_data 668 daemons/controld/controld_remote_ra.c if (ra_data->active == TRUE && (cmd->cancel == FALSE)) { ra_data 685 daemons/controld/controld_remote_ra.c crm_debug("Event did not match %s action", ra_data->cur_cmd->action); ra_data 689 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = NULL; ra_data 690 daemons/controld/controld_remote_ra.c if (ra_data->cmds) { ra_data 691 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 700 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = NULL; ra_data 703 daemons/controld/controld_remote_ra.c ra_data = lrm_state->remote_ra_data; ra_data 705 daemons/controld/controld_remote_ra.c if (ra_data->migrate_status != takeover_complete) { ra_data 714 daemons/controld/controld_remote_ra.c ra_data->active = FALSE; ra_data 717 daemons/controld/controld_remote_ra.c if (ra_data->cmds) { ra_data 718 daemons/controld/controld_remote_ra.c g_list_free_full(ra_data->cmds, free_cmd); ra_data 720 daemons/controld/controld_remote_ra.c if (ra_data->recurring_cmds) { ra_data 721 daemons/controld/controld_remote_ra.c g_list_free_full(ra_data->recurring_cmds, free_cmd); ra_data 723 daemons/controld/controld_remote_ra.c ra_data->cmds = NULL; ra_data 724 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = NULL; ra_data 725 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = NULL; ra_data 740 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 751 daemons/controld/controld_remote_ra.c ra_data->controlling_guest = TRUE; ra_data 769 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 773 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd) { ra_data 778 daemons/controld/controld_remote_ra.c while (ra_data->cmds) { ra_data 779 daemons/controld/controld_remote_ra.c first = ra_data->cmds; ra_data 786 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_remove_link(ra_data->cmds, first); ra_data 790 daemons/controld/controld_remote_ra.c ra_data->migrate_status = 0; ra_data 796 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; ra_data 818 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; ra_data 826 daemons/controld/controld_remote_ra.c if (ra_data->migrate_status == expect_takeover) { ra_data 834 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; ra_data 841 daemons/controld/controld_remote_ra.c ra_data->migrate_status = expect_takeover; ra_data 868 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = NULL; ra_data 874 daemons/controld/controld_remote_ra.c ra_data = calloc(1, sizeof(remote_ra_data_t)); ra_data 875 daemons/controld/controld_remote_ra.c ra_data->work = mainloop_add_trigger(G_PRIORITY_HIGH, handle_remote_ra_exec, lrm_state); ra_data 876 daemons/controld/controld_remote_ra.c lrm_state->remote_ra_data = ra_data; ra_data 882 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 884 daemons/controld/controld_remote_ra.c if (!ra_data) { ra_data 888 daemons/controld/controld_remote_ra.c if (ra_data->cmds) { ra_data 889 daemons/controld/controld_remote_ra.c g_list_free_full(ra_data->cmds, free_cmd); ra_data 892 daemons/controld/controld_remote_ra.c if (ra_data->recurring_cmds) { ra_data 893 daemons/controld/controld_remote_ra.c g_list_free_full(ra_data->recurring_cmds, free_cmd); ra_data 895 daemons/controld/controld_remote_ra.c mainloop_destroy_trigger(ra_data->work); ra_data 896 daemons/controld/controld_remote_ra.c free(ra_data); ra_data 1002 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = NULL; ra_data 1009 daemons/controld/controld_remote_ra.c ra_data = connection_rsc->remote_ra_data; ra_data 1010 daemons/controld/controld_remote_ra.c ra_data->cmds = remove_cmd(ra_data->cmds, action, interval_ms); ra_data 1011 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = remove_cmd(ra_data->recurring_cmds, action, ra_data 1013 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd && ra_data 1014 daemons/controld/controld_remote_ra.c (ra_data->cur_cmd->interval_ms == interval_ms) && ra_data 1015 daemons/controld/controld_remote_ra.c (pcmk__str_eq(ra_data->cur_cmd->action, action, pcmk__str_casei))) { ra_data 1017 daemons/controld/controld_remote_ra.c ra_data->cur_cmd->cancel = TRUE; ra_data 1024 daemons/controld/controld_remote_ra.c handle_dup_monitor(remote_ra_data_t *ra_data, guint interval_ms, ra_data 1040 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd && ra_data 1041 daemons/controld/controld_remote_ra.c ra_data->cur_cmd->cancel == FALSE && ra_data 1042 daemons/controld/controld_remote_ra.c (ra_data->cur_cmd->interval_ms == interval_ms) && ra_data 1043 daemons/controld/controld_remote_ra.c pcmk__str_eq(ra_data->cur_cmd->action, "monitor", pcmk__str_casei)) { ra_data 1045 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; ra_data 1049 daemons/controld/controld_remote_ra.c for (gIter = ra_data->recurring_cmds; gIter != NULL; gIter = gIter->next) { ra_data 1057 daemons/controld/controld_remote_ra.c for (gIter = ra_data->cmds; gIter != NULL; gIter = gIter->next) { ra_data 1124 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = NULL; ra_data 1144 daemons/controld/controld_remote_ra.c ra_data = connection_rsc->remote_ra_data; ra_data 1146 daemons/controld/controld_remote_ra.c cmd = handle_dup_monitor(ra_data, interval_ms, userdata); ra_data 1182 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); ra_data 1183 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 1201 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1204 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = fail_all_monitor_cmds(ra_data->recurring_cmds); ra_data 1205 daemons/controld/controld_remote_ra.c ra_data->cmds = fail_all_monitor_cmds(ra_data->cmds); ra_data 1266 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1283 daemons/controld/controld_remote_ra.c ra_data->is_maintenance = maintenance; ra_data 1333 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1335 daemons/controld/controld_remote_ra.c return ra_data->is_maintenance; ra_data 1341 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1343 daemons/controld/controld_remote_ra.c return ra_data->controlling_guest;