Function cluster_remove_node

modules/clusterer/clusterer_mod.c:1139–1225

}

static mi_response_t *cluster_remove_node(const mi_params_t *params,
								struct mi_handler *async_hdl)
{
	int cluster_id, node_id;
	int rc;
	cluster_info_t *cl;
	node_info_t *node;
	mi_response_t *resp;

	if (db_mode)
		return init_mi_error(400, MI_SSTR("Running in DB mode"));

	if (get_mi_int_param(params, "cluster_id", &cluster_id) < 0)
		return init_mi_param_error();
	if (cluster_id < 1)
		return init_mi_error(400, MI_SSTR("Bad value for 'cluster_id'"));

	lock_start_read(cl_list_lock);

	cl = get_cluster_by_id(cluster_id);
	if (!cl) {
		LM_ERR("Unknown cluster id [%d]\n", cluster_id);
		resp = init_mi_error(400, MI_SSTR("Unknown cluster id"));
		goto error;
	}

	if (get_mi_int_param(params, "node_id", &node_id) < 0) {
		resp = init_mi_param_error();
		goto error;
	}
	if (node_id < 1) {
		resp = init_mi_error(400, MI_SSTR("Bad value for 'node_id'"));
		goto error;
	}

	node = get_node_by_id(cl, node_id);
	if (!node) {
		LM_ERR("Unknown node id [%d]\n", node_id);
		resp = init_mi_error(400, MI_SSTR("Unknown node id"));
		goto error;
	}

	lock_stop_read(cl_list_lock);

	rc = bcast_remove_node(cluster_id, node_id);
	switch (rc) {
		case CLUSTERER_SEND_SUCCESS:
			LM_DBG("Remove node <%d> command sent\n", node_id);
			break;
		case CLUSTERER_CURR_DISABLED:
			LM_INFO("Local node disabled, remove node <%d> command not sent\n",
				node_id);
			break;
		case CLUSTERER_DEST_DOWN:
			LM_ERR("All nodes down, remove node <%d> command not sent\n",
				node_id);
			break;
		case CLUSTERER_SEND_ERR: