ra_data 145 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = connection_rsc->remote_ra_data; ra_data 147 crmd/remote_lrmd_ra.c ra_data->recurring_cmds = g_list_remove(ra_data->recurring_cmds, cmd); ra_data 149 crmd/remote_lrmd_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); ra_data 150 crmd/remote_lrmd_ra.c mainloop_set_trigger(ra_data->work); ra_data 164 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = connection_rsc->remote_ra_data; ra_data 166 crmd/remote_lrmd_ra.c mainloop_set_trigger(ra_data->work); ra_data 319 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = lrm_state? lrm_state->remote_ra_data : NULL; ra_data 321 crmd/remote_lrmd_ra.c if (ra_data) { ra_data 322 crmd/remote_lrmd_ra.c if (ra_data->migrate_status != takeover_complete) { ra_data 409 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 413 crmd/remote_lrmd_ra.c if (!ra_data || !ra_data->cur_cmd) { ra_data 416 crmd/remote_lrmd_ra.c cmd = ra_data->cur_cmd; ra_data 431 crmd/remote_lrmd_ra.c if (ra_data->cmds) { ra_data 432 crmd/remote_lrmd_ra.c mainloop_set_trigger(ra_data->work); ra_data 434 crmd/remote_lrmd_ra.c ra_data->cur_cmd = NULL; ra_data 475 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 477 crmd/remote_lrmd_ra.c if (ra_data->cur_cmd == cmd) { ra_data 478 crmd/remote_lrmd_ra.c ra_data->cur_cmd = NULL; ra_data 480 crmd/remote_lrmd_ra.c if (ra_data->cmds) { ra_data 481 crmd/remote_lrmd_ra.c mainloop_set_trigger(ra_data->work); ra_data 521 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = NULL; ra_data 535 crmd/remote_lrmd_ra.c ra_data = lrm_state->remote_ra_data; ra_data 541 crmd/remote_lrmd_ra.c if (ra_data->migrate_status == expect_takeover) { ra_data 542 crmd/remote_lrmd_ra.c ra_data->migrate_status = takeover_complete; ra_data 555 crmd/remote_lrmd_ra.c if (ra_data->migrate_status == takeover_complete) { ra_data 564 crmd/remote_lrmd_ra.c (ra_data->cur_cmd == NULL) && ra_data 565 crmd/remote_lrmd_ra.c (ra_data->active == TRUE)) { ra_data 569 crmd/remote_lrmd_ra.c ra_data->recurring_cmds = fail_all_monitor_cmds(ra_data->recurring_cmds); ra_data 570 crmd/remote_lrmd_ra.c ra_data->cmds = fail_all_monitor_cmds(ra_data->cmds); ra_data 582 crmd/remote_lrmd_ra.c if (!ra_data->cur_cmd) { ra_data 587 crmd/remote_lrmd_ra.c cmd = ra_data->cur_cmd; ra_data 619 crmd/remote_lrmd_ra.c ra_data->active = TRUE; ra_data 647 crmd/remote_lrmd_ra.c ra_data->recurring_cmds = g_list_append(ra_data->recurring_cmds, cmd); ra_data 654 crmd/remote_lrmd_ra.c if (ra_data->active == TRUE && (cmd->cancel == FALSE)) { ra_data 668 crmd/remote_lrmd_ra.c crm_debug("Event did not match %s action", ra_data->cur_cmd->action); ra_data 672 crmd/remote_lrmd_ra.c ra_data->cur_cmd = NULL; ra_data 673 crmd/remote_lrmd_ra.c if (ra_data->cmds) { ra_data 674 crmd/remote_lrmd_ra.c mainloop_set_trigger(ra_data->work); ra_data 683 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = NULL; ra_data 686 crmd/remote_lrmd_ra.c ra_data = lrm_state->remote_ra_data; ra_data 688 crmd/remote_lrmd_ra.c if (ra_data->migrate_status != takeover_complete) { ra_data 697 crmd/remote_lrmd_ra.c ra_data->active = FALSE; ra_data 700 crmd/remote_lrmd_ra.c if (ra_data->cmds) { ra_data 701 crmd/remote_lrmd_ra.c g_list_free_full(ra_data->cmds, free_cmd); ra_data 703 crmd/remote_lrmd_ra.c if (ra_data->recurring_cmds) { ra_data 704 crmd/remote_lrmd_ra.c g_list_free_full(ra_data->recurring_cmds, free_cmd); ra_data 706 crmd/remote_lrmd_ra.c ra_data->cmds = NULL; ra_data 707 crmd/remote_lrmd_ra.c ra_data->recurring_cmds = NULL; ra_data 708 crmd/remote_lrmd_ra.c ra_data->cur_cmd = NULL; ra_data 743 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 747 crmd/remote_lrmd_ra.c if (ra_data->cur_cmd) { ra_data 752 crmd/remote_lrmd_ra.c while (ra_data->cmds) { ra_data 753 crmd/remote_lrmd_ra.c first = ra_data->cmds; ra_data 760 crmd/remote_lrmd_ra.c ra_data->cmds = g_list_remove_link(ra_data->cmds, first); ra_data 764 crmd/remote_lrmd_ra.c ra_data->migrate_status = 0; ra_data 769 crmd/remote_lrmd_ra.c ra_data->cur_cmd = cmd; ra_data 794 crmd/remote_lrmd_ra.c ra_data->cur_cmd = cmd; ra_data 802 crmd/remote_lrmd_ra.c if (ra_data->migrate_status == expect_takeover) { ra_data 810 crmd/remote_lrmd_ra.c ra_data->cur_cmd = cmd; ra_data 817 crmd/remote_lrmd_ra.c ra_data->migrate_status = expect_takeover; ra_data 837 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = NULL; ra_data 843 crmd/remote_lrmd_ra.c ra_data = calloc(1, sizeof(remote_ra_data_t)); ra_data 844 crmd/remote_lrmd_ra.c ra_data->work = mainloop_add_trigger(G_PRIORITY_HIGH, handle_remote_ra_exec, lrm_state); ra_data 845 crmd/remote_lrmd_ra.c lrm_state->remote_ra_data = ra_data; ra_data 851 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 853 crmd/remote_lrmd_ra.c if (!ra_data) { ra_data 857 crmd/remote_lrmd_ra.c if (ra_data->cmds) { ra_data 858 crmd/remote_lrmd_ra.c g_list_free_full(ra_data->cmds, free_cmd); ra_data 861 crmd/remote_lrmd_ra.c if (ra_data->recurring_cmds) { ra_data 862 crmd/remote_lrmd_ra.c g_list_free_full(ra_data->recurring_cmds, free_cmd); ra_data 864 crmd/remote_lrmd_ra.c mainloop_destroy_trigger(ra_data->work); ra_data 865 crmd/remote_lrmd_ra.c free(ra_data); ra_data 970 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = NULL; ra_data 977 crmd/remote_lrmd_ra.c ra_data = connection_rsc->remote_ra_data; ra_data 978 crmd/remote_lrmd_ra.c ra_data->cmds = remove_cmd(ra_data->cmds, action, interval); ra_data 979 crmd/remote_lrmd_ra.c ra_data->recurring_cmds = remove_cmd(ra_data->recurring_cmds, action, interval); ra_data 980 crmd/remote_lrmd_ra.c if (ra_data->cur_cmd && ra_data 981 crmd/remote_lrmd_ra.c (ra_data->cur_cmd->interval == interval) && ra_data 982 crmd/remote_lrmd_ra.c (safe_str_eq(ra_data->cur_cmd->action, action))) { ra_data 984 crmd/remote_lrmd_ra.c ra_data->cur_cmd->cancel = TRUE; ra_data 991 crmd/remote_lrmd_ra.c handle_dup_monitor(remote_ra_data_t *ra_data, int interval, const char *userdata) ra_data 1006 crmd/remote_lrmd_ra.c if (ra_data->cur_cmd && ra_data 1007 crmd/remote_lrmd_ra.c ra_data->cur_cmd->cancel == FALSE && ra_data 1008 crmd/remote_lrmd_ra.c ra_data->cur_cmd->interval == interval && ra_data 1009 crmd/remote_lrmd_ra.c safe_str_eq(ra_data->cur_cmd->action, "monitor")) { ra_data 1011 crmd/remote_lrmd_ra.c cmd = ra_data->cur_cmd; ra_data 1015 crmd/remote_lrmd_ra.c for (gIter = ra_data->recurring_cmds; gIter != NULL; gIter = gIter->next) { ra_data 1022 crmd/remote_lrmd_ra.c for (gIter = ra_data->cmds; gIter != NULL; gIter = gIter->next) { ra_data 1069 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = NULL; ra_data 1083 crmd/remote_lrmd_ra.c ra_data = connection_rsc->remote_ra_data; ra_data 1085 crmd/remote_lrmd_ra.c cmd = handle_dup_monitor(ra_data, interval, userdata); ra_data 1107 crmd/remote_lrmd_ra.c ra_data->cmds = g_list_append(ra_data->cmds, cmd); ra_data 1108 crmd/remote_lrmd_ra.c mainloop_set_trigger(ra_data->work); ra_data 1129 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1132 crmd/remote_lrmd_ra.c ra_data->recurring_cmds = fail_all_monitor_cmds(ra_data->recurring_cmds); ra_data 1133 crmd/remote_lrmd_ra.c ra_data->cmds = fail_all_monitor_cmds(ra_data->cmds); ra_data 1195 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1212 crmd/remote_lrmd_ra.c ra_data->is_maintenance = maintenance; ra_data 1261 crmd/remote_lrmd_ra.c remote_ra_data_t *ra_data = lrm_state->remote_ra_data; ra_data 1263 crmd/remote_lrmd_ra.c return ra_data->is_maintenance;