cl_log(LOG_INFO, "Sign up for \"ccmjoin\" messages"); if (hb_cluster->llc_ops->set_msg_callback( hb_cluster, "ccmjoin", msg_ccm_join, hb_cluster) != HA_OK) { cl_log(LOG_ERR, "Cannot set msg_ipfail_join callback"); }
G_main_add_fd(G_PRIORITY_LOW, fsa_ev_fd, FALSE, ccm_dispatch, fsa_ev_token, default_ipc_input_destroy);
register_with_ccm(ll_cluster_t *hb_cluster){	int ret;	fd_set rset;    	cl_log(LOG_INFO, "Registering with CCM");	oc_ev_register(&fsa_ev_token);    	cl_log(LOG_INFO, "Setting up CCM callbacks");	oc_ev_set_callback(fsa_ev_token, OC_EV_MEMB_CLASS,			   crmd_ccm_input_callback,			   NULL);	oc_ev_special(fsa_ev_token, OC_EV_MEMB_CLASS, 0/*don't care*/);    	cl_log(LOG_INFO, "Activating CCM token");	ret = oc_ev_activate(fsa_ev_token, &fsa_ev_fd);	if (ret){		cl_log(LOG_INFO, "CCM Activation failed... unregistering");		oc_ev_unregister(fsa_ev_token);		return(1);	}	cl_log(LOG_INFO, "CCM Activation passed... all set to go!");    	FD_ZERO(&rset);	FD_SET(fsa_ev_fd, &rset);    	if (oc_ev_handle_event(fsa_ev_token)){		cl_log(LOG_ERR,"CCM Activation: terminating");		return(1);	}    	cl_log(LOG_INFO, "Sign up for \"ccmjoin\" messages");	if (hb_cluster->llc_ops->set_msg_callback(		    hb_cluster,		    "ccmjoin",		    msg_ccm_join,		    hb_cluster) != HA_OK)	{		cl_log(LOG_ERR, "Cannot set msg_ipfail_join callback");	}    	FNRET(0);}