ra_data 143 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = connection_rsc->remote_ra_data; ra_data 145 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = g_list_remove(ra_data->recurring_cmds, cmd); ra_data 147 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); ra_data 148 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 162 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = connection_rsc->remote_ra_data; ra_data 164 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 321 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state? lrm_state->remote_ra_data : NULL; ra_data 323 daemons/controld/controld_remote_ra.c if (ra_data) { ra_data 324 daemons/controld/controld_remote_ra.c if (ra_data->migrate_status != takeover_complete) { ra_data 411 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 415 daemons/controld/controld_remote_ra.c if (!ra_data || !ra_data->cur_cmd) { ra_data 418 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; ra_data 433 daemons/controld/controld_remote_ra.c if (ra_data->cmds) { ra_data 434 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 436 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = NULL; ra_data 478 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 480 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd == cmd) { ra_data 481 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = NULL; ra_data 483 daemons/controld/controld_remote_ra.c if (ra_data->cmds) { ra_data 484 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 524 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = NULL; ra_data 539 daemons/controld/controld_remote_ra.c ra_data = lrm_state->remote_ra_data; ra_data 544 daemons/controld/controld_remote_ra.c if (ra_data->migrate_status == expect_takeover) { ra_data 546 daemons/controld/controld_remote_ra.c ra_data->migrate_status = takeover_complete; ra_data 560 daemons/controld/controld_remote_ra.c if (ra_data->migrate_status == takeover_complete) { ra_data 568 daemons/controld/controld_remote_ra.c if ((op->type == lrmd_event_disconnect) && (ra_data->cur_cmd == NULL)) { ra_data 570 daemons/controld/controld_remote_ra.c if (ra_data->active == FALSE) { ra_data 577 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = fail_all_monitor_cmds(ra_data->recurring_cmds); ra_data 578 daemons/controld/controld_remote_ra.c ra_data->cmds = fail_all_monitor_cmds(ra_data->cmds); ra_data 592 daemons/controld/controld_remote_ra.c if (!ra_data->cur_cmd) { ra_data 597 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; ra_data 628 daemons/controld/controld_remote_ra.c ra_data->active = TRUE; ra_data 656 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = g_list_append(ra_data->recurring_cmds, cmd); ra_data 664 daemons/controld/controld_remote_ra.c if (ra_data->active == TRUE && (cmd->cancel == FALSE)) { ra_data 679 daemons/controld/controld_remote_ra.c crm_debug("Event did not match %s action", ra_data->cur_cmd->action); ra_data 683 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = NULL; ra_data 684 daemons/controld/controld_remote_ra.c if (ra_data->cmds) { ra_data 685 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 694 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = NULL; ra_data 697 daemons/controld/controld_remote_ra.c ra_data = lrm_state->remote_ra_data; ra_data 699 daemons/controld/controld_remote_ra.c if (ra_data->migrate_status != takeover_complete) { ra_data 708 daemons/controld/controld_remote_ra.c ra_data->active = FALSE; ra_data 711 daemons/controld/controld_remote_ra.c if (ra_data->cmds) { ra_data 712 daemons/controld/controld_remote_ra.c g_list_free_full(ra_data->cmds, free_cmd); ra_data 714 daemons/controld/controld_remote_ra.c if (ra_data->recurring_cmds) { ra_data 715 daemons/controld/controld_remote_ra.c g_list_free_full(ra_data->recurring_cmds, free_cmd); ra_data 717 daemons/controld/controld_remote_ra.c ra_data->cmds = NULL; ra_data 718 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = NULL; ra_data 719 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = NULL; ra_data 735 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 745 daemons/controld/controld_remote_ra.c ra_data->controlling_guest = TRUE; ra_data 757 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 761 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd) { ra_data 766 daemons/controld/controld_remote_ra.c while (ra_data->cmds) { ra_data 767 daemons/controld/controld_remote_ra.c first = ra_data->cmds; ra_data 774 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_remove_link(ra_data->cmds, first); ra_data 778 daemons/controld/controld_remote_ra.c ra_data->migrate_status = 0; ra_data 784 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; ra_data 811 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; ra_data 819 daemons/controld/controld_remote_ra.c if (ra_data->migrate_status == expect_takeover) { ra_data 827 daemons/controld/controld_remote_ra.c ra_data->cur_cmd = cmd; ra_data 834 daemons/controld/controld_remote_ra.c ra_data->migrate_status = expect_takeover; ra_data 854 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = NULL; ra_data 860 daemons/controld/controld_remote_ra.c ra_data = calloc(1, sizeof(remote_ra_data_t)); ra_data 861 daemons/controld/controld_remote_ra.c ra_data->work = mainloop_add_trigger(G_PRIORITY_HIGH, handle_remote_ra_exec, lrm_state); ra_data 862 daemons/controld/controld_remote_ra.c lrm_state->remote_ra_data = ra_data; ra_data 868 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 870 daemons/controld/controld_remote_ra.c if (!ra_data) { ra_data 874 daemons/controld/controld_remote_ra.c if (ra_data->cmds) { ra_data 875 daemons/controld/controld_remote_ra.c g_list_free_full(ra_data->cmds, free_cmd); ra_data 878 daemons/controld/controld_remote_ra.c if (ra_data->recurring_cmds) { ra_data 879 daemons/controld/controld_remote_ra.c g_list_free_full(ra_data->recurring_cmds, free_cmd); ra_data 881 daemons/controld/controld_remote_ra.c mainloop_destroy_trigger(ra_data->work); ra_data 882 daemons/controld/controld_remote_ra.c free(ra_data); ra_data 990 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = NULL; ra_data 997 daemons/controld/controld_remote_ra.c ra_data = connection_rsc->remote_ra_data; ra_data 998 daemons/controld/controld_remote_ra.c ra_data->cmds = remove_cmd(ra_data->cmds, action, interval_ms); ra_data 999 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = remove_cmd(ra_data->recurring_cmds, action, ra_data 1001 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd && ra_data 1002 daemons/controld/controld_remote_ra.c (ra_data->cur_cmd->interval_ms == interval_ms) && ra_data 1003 daemons/controld/controld_remote_ra.c (pcmk__str_eq(ra_data->cur_cmd->action, action, pcmk__str_casei))) { ra_data 1005 daemons/controld/controld_remote_ra.c ra_data->cur_cmd->cancel = TRUE; ra_data 1012 daemons/controld/controld_remote_ra.c handle_dup_monitor(remote_ra_data_t *ra_data, guint interval_ms, ra_data 1028 daemons/controld/controld_remote_ra.c if (ra_data->cur_cmd && ra_data 1029 daemons/controld/controld_remote_ra.c ra_data->cur_cmd->cancel == FALSE && ra_data 1030 daemons/controld/controld_remote_ra.c (ra_data->cur_cmd->interval_ms == interval_ms) && ra_data 1031 daemons/controld/controld_remote_ra.c pcmk__str_eq(ra_data->cur_cmd->action, "monitor", pcmk__str_casei)) { ra_data 1033 daemons/controld/controld_remote_ra.c cmd = ra_data->cur_cmd; ra_data 1037 daemons/controld/controld_remote_ra.c for (gIter = ra_data->recurring_cmds; gIter != NULL; gIter = gIter->next) { ra_data 1045 daemons/controld/controld_remote_ra.c for (gIter = ra_data->cmds; gIter != NULL; gIter = gIter->next) { ra_data 1095 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = NULL; ra_data 1109 daemons/controld/controld_remote_ra.c ra_data = connection_rsc->remote_ra_data; ra_data 1111 daemons/controld/controld_remote_ra.c cmd = handle_dup_monitor(ra_data, interval_ms, userdata); ra_data 1134 daemons/controld/controld_remote_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); ra_data 1135 daemons/controld/controld_remote_ra.c mainloop_set_trigger(ra_data->work); ra_data 1156 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1159 daemons/controld/controld_remote_ra.c ra_data->recurring_cmds = fail_all_monitor_cmds(ra_data->recurring_cmds); ra_data 1160 daemons/controld/controld_remote_ra.c ra_data->cmds = fail_all_monitor_cmds(ra_data->cmds); ra_data 1222 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1239 daemons/controld/controld_remote_ra.c ra_data->is_maintenance = maintenance; ra_data 1288 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1290 daemons/controld/controld_remote_ra.c return ra_data->is_maintenance; ra_data 1296 daemons/controld/controld_remote_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1298 daemons/controld/controld_remote_ra.c return ra_data->controlling_guest;