MCPcopy Create free account
hub / github.com/ClusterLabs/pacemaker / do_started

Function do_started

crmd/control.c:648–728  ·  view source on GitHub ↗

A_STARTED */

Source from the content-addressed store, hash-verified

646
647/* A_STARTED */
648void
649do_started(long long action,
650 enum crmd_fsa_cause cause,
651 enum crmd_fsa_state cur_state, enum crmd_fsa_input current_input, fsa_data_t * msg_data)
652{
653 static struct qb_ipcs_service_handlers crmd_callbacks =
654 {
655 .connection_accept = crmd_ipc_accept,
656 .connection_created = crmd_ipc_created,
657 .msg_process = crmd_ipc_dispatch,
658 .connection_closed = crmd_ipc_closed,
659 .connection_destroyed = crmd_ipc_destroy
660 };
661
662 if (cur_state != S_STARTING) {
663 crm_err("Start cancelled... %s", fsa_state2string(cur_state));
664 return;
665
666 } else if (is_set(fsa_input_register, R_MEMBERSHIP) == FALSE) {
667 crm_info("Delaying start, no membership data (%.16llx)", R_MEMBERSHIP);
668
669 crmd_fsa_stall(NULL);
670 return;
671
672 } else if (is_set(fsa_input_register, R_LRM_CONNECTED) == FALSE) {
673 crm_info("Delaying start, LRM not connected (%.16llx)", R_LRM_CONNECTED);
674
675 crmd_fsa_stall(NULL);
676 return;
677
678 } else if (is_set(fsa_input_register, R_CIB_CONNECTED) == FALSE) {
679 crm_info("Delaying start, CIB not connected (%.16llx)", R_CIB_CONNECTED);
680
681 crmd_fsa_stall(NULL);
682 return;
683
684 } else if (is_set(fsa_input_register, R_READ_CONFIG) == FALSE) {
685 crm_info("Delaying start, Config not read (%.16llx)", R_READ_CONFIG);
686
687 crmd_fsa_stall(NULL);
688 return;
689
690 } else if (is_set(fsa_input_register, R_PEER_DATA) == FALSE) {
691
692 /* try reading from HA */
693 crm_info("Delaying start, No peer data (%.16llx)", R_PEER_DATA);
694
695#if SUPPORT_HEARTBEAT
696 if (is_heartbeat_cluster()) {
697 HA_Message *msg = NULL;
698 crm_trace("Looking for a HA message");
699 msg = fsa_cluster_conn->llc_ops->readmsg(fsa_cluster_conn, 0);
700 if (msg != NULL) {
701 crm_trace("There was a HA message");
702 ha_msg_del(msg);
703 }
704 }
705#endif

Callers

nothing calls this directly

Calls 6

fsa_state2stringFunction · 0.85
is_setFunction · 0.85
is_heartbeat_clusterFunction · 0.85
mainloop_add_ipc_serverFunction · 0.85
mainloop_add_triggerFunction · 0.85
mainloop_set_triggerFunction · 0.85

Tested by

no test coverage detected