xref: /titanic_50/usr/src/cmd/isns/isnsd/scn.c (revision fcf3ce441efd61da9bb2884968af01cb7c1452cc)

/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License (the "License").
 * You may not use this file except in compliance with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */

/*
 * Copyright 2008 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 */

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#include "isns_server.h"
#include "isns_msgq.h"
#include "isns_cache.h"
#include "isns_cfg.h"
#include "isns_obj.h"
#include "isns_dseng.h"
#include "isns_log.h"
#include "isns_scn.h"
#include "isns_pdu.h"

/*
 * global variables.
 */

/*
 * local variables.
 */
static scn_registry_t *scn_registry = NULL;
static int scn_dispatched = 0;

/*
 * external variables.
 */
extern uint8_t mgmt_scn;
extern msg_queue_t *sys_q;
extern msg_queue_t *scn_q;
extern const int UID_ATTR_INDEX[MAX_OBJ_TYPE_FOR_SIZE];

#ifdef DEBUG
extern void dump_pdu1(isns_pdu_t *);
#endif

static int sf_gen(scn_raw_t *);
static int sf_error(scn_raw_t *);

static scn_raw_t *make_raw_entity(isns_obj_t *);
static scn_raw_t *make_raw_iscsi(isns_obj_t *);
static scn_raw_t *make_raw_portal(isns_obj_t *);
static scn_raw_t *make_raw_assoc_iscsi(isns_obj_t *);
static scn_raw_t *make_raw_assoc_dd(isns_obj_t *);
static scn_raw_t *(*const make_raw[MAX_OBJ_TYPE_FOR_SIZE])(isns_obj_t *) = {
	NULL,
	&make_raw_entity,
	&make_raw_iscsi,
	&make_raw_portal,
	NULL,			/* OBJ_PG */
	NULL,			/* OBJ_DD */
	NULL,			/* OBJ_DDS */
	NULL,			/* MAX_OBJ_TYPE */
	NULL,			/* OBJ_DUMMY1 */
	NULL,			/* OBJ_DUMMY2 */
	NULL,			/* OBJ_DUMMY3 */
	NULL,			/* OBJ_DUMMY4 */
	&make_raw_assoc_iscsi,
	&make_raw_assoc_dd
};

static scn_text_t *scn_gen_entity(scn_raw_t *);
static scn_text_t *scn_gen_iscsi(scn_raw_t *);
static scn_text_t *scn_gen_portal(scn_raw_t *);
static scn_text_t *scn_gen_assoc_dd(scn_raw_t *);
static scn_text_t *(*const scn_gen[MAX_OBJ_TYPE_FOR_SIZE])(scn_raw_t *) = {
	NULL,
	&scn_gen_entity,
	&scn_gen_iscsi,
	&scn_gen_portal,
	NULL,			/* OBJ_PG */
	NULL,			/* OBJ_DD */
	NULL,			/* OBJ_DDS */
	NULL,			/* MAX_OBJ_TYPE */
	NULL,			/* OBJ_DUMMY1 */
	NULL,			/* OBJ_DUMMY2 */
	NULL,			/* OBJ_DUMMY3 */
	NULL,			/* OBJ_DUMMY4 */
	&scn_gen_iscsi,
	&scn_gen_assoc_dd
};

#define	SCN_TEST(E, BITMAP, UID1, UID2, NT) \
	(((E) & (BITMAP)) && \
	(!((BITMAP) & (ISNS_INIT_SELF_INFO_ONLY | \
			ISNS_TARGET_SELF_INFO_ONLY)) || \
		((UID1) == (UID2)) || \
		(((BITMAP) & ISNS_INIT_SELF_INFO_ONLY) && \
			((NT) & ISNS_INITIATOR_NODE_TYPE)) || \
		(((BITMAP) & ISNS_TARGET_SELF_INFO_ONLY) && \
			((NT) & ISNS_TARGET_NODE_TYPE))))

/*
 * local functions.
 */

/*
 * ****************************************************************************
 *
 * free_portal_1:
 *	Free one SCN portal or decrease the reference count if the portal
 *	is referenced by other SCN entry(s).
 *
 * p	- the portal.
 *
 * ****************************************************************************
 */
static void
free_portal_1(
	scn_portal_t *p
)
{
	if (p->ref <= 1) {
		if (p->sz == sizeof (in6_addr_t)) {
			free(p->ip.in6);
		}
		free(p);
	} else {
		p->ref --;
	}
}

/*
 * ****************************************************************************
 *
 * free_portal:
 *	Free the unused portals, which are extracted for new SCN entry,
 *	after the new SCN entry is added.
 *
 * p	- the portal.
 *
 * ****************************************************************************
 */
static void
free_portal(
	scn_portal_t *p
)
{
	scn_portal_t *n;

	while (p != NULL) {
		n = p->next;
		free_portal_1(p);
		p = n;
	}
}

/*
 * ****************************************************************************
 *
 * free_portal_list:
 *	Free the list of portals while a SCN entry is being destroyed.
 *
 * l	- the portal list.
 *
 * ****************************************************************************
 */
static void
free_portal_list(
	scn_list_t *l
)
{
	scn_list_t *n;
	scn_portal_t *p;

	while (l != NULL) {
		n = l->next;
		p = l->data.portal;
		free_portal_1(p);
		free(l);
		l = n;
	}
}

/*
 * ****************************************************************************
 *
 * free_scn_text:
 *	Free one SCN or decrease the ref count after the SCN is emitted.
 *
 * text	- the SCN.
 *
 * ****************************************************************************
 */
static void
free_scn_text(
	scn_text_t *text
)
{
	if (text->ref <= 1) {
		free(text->iscsi);
		free(text);
	} else {
		text->ref --;
	}
}

/*
 * ****************************************************************************
 *
 * free_scn_list:
 *	Free the the list of SCN.
 *
 * scn	- the list.
 *
 * ****************************************************************************
 */
static void
free_scn_list(
	scn_t *scn
)
{
	scn_t *next_scn;
	scn_list_t *list;
	scn_list_t *next_list;

	while (scn != NULL) {
		next_scn = scn->next;
		list = scn->data.list;
		while (list != NULL) {
			next_list = list->next;
			free_scn_text(list->data.text);
			free(list);
			list = next_list;
		}
		free(scn);
		scn = next_scn;
	}
}

/*
 * ****************************************************************************
 *
 * free_scn:
 *	Free all of SCNs which are dispatched to every entry.
 *
 * ****************************************************************************
 */
static void
free_scn(
)
{
	scn_registry_t *p;

	p = scn_registry;

	while (p != NULL) {
		free_scn_list(p->scn);
		p->scn = NULL;
		p = p->next;
	}
}

/*
 * ****************************************************************************
 *
 * free_entry:
 *	Free one SCN entry.
 *
 * e	- the SCN entry.
 *
 * ****************************************************************************
 */
static void
free_entry(
	scn_registry_t *e
)
{
	free_scn_list(e->scn);
	free_portal_list(e->portal.l);
	free(e->name);
	free(e);
}

/*
 * ****************************************************************************
 *
 * free_raw:
 *	Free the raw data after the SCN is generated from it.
 *
 * raw	- the raw SCN data.
 *
 * ****************************************************************************
 */
static void
free_raw(
	scn_raw_t *raw
)
{
	if (raw->ref == 0) {
		free(raw->iscsi);
	}
	if (raw->ip != NULL) {
		free(raw->ip);
	}
	free(raw);
}

/*
 * ****************************************************************************
 *
 * scn_add_portal:
 *	Add portals to the portal list of a SCN entry.
 *
 * e	- the SCN entry.
 * p	- the portals.
 * return - 0: successful, otherwise failed.
 *
 * ****************************************************************************
 */
static int
scn_add_portal(
	scn_registry_t *e,
	scn_portal_t *p
)
{
	scn_portal_t *x;
	scn_list_t *l, *m;

	scn_list_t **lp;

	int found_it;

	lp = &e->portal.l;
	while (p != NULL) {
		m = (scn_list_t *)malloc(sizeof (scn_list_t));
		if (m == NULL) {
			return (1);
		}
		found_it = 0;
		e = scn_registry;
		while (e && !found_it) {
			l = e->portal.l;
			while (l && !found_it) {
				x = l->data.portal;
				if (x->uid == p->uid) {
					found_it = 1;
				}
				l = l->next;
			}
			e = e->next;
		}

		if (!found_it) {
			x = p;
		}
		m->data.portal = x;
		x->ref ++;
		m->next = *lp;
		*lp = m;

		p = p->next;
	}

	return (0);
}

/*
 * ****************************************************************************
 *
 * scn_remove_portal:
 *	Remove a portal from the portal list of every SCN entry.
 *
 * uid	- the portal object uid.
 * return - always successful (0).
 *
 * ****************************************************************************
 */
static int
scn_remove_portal(
	uint32_t uid
)
{
	scn_registry_t **ep, *e;

	scn_portal_t *x;
	scn_list_t **lp, *l;

	ep = &scn_registry;
	e = *ep;

	while (e != NULL) {
		lp = &e->portal.l;
		l = *lp;
		while (l != NULL) {
			x = l->data.portal;
			if (x->uid == uid) {
				/* remove it */
				*lp = l->next;
				free_portal_1(x);
				free(l);
			} else {
				lp = &l->next;
			}
			l = *lp;
		}

		if (e->portal.l == NULL) {
			/* no portal for this entry, destroy it */
			*ep = e->next;
			free_entry(e);
		} else {
			ep = &e->next;
		}
		e = *ep;
	}

	return (0);
}

/*
 * ****************************************************************************
 *
 * scn_list_add:
 *	Add one SCN entry to the SCN entry list.
 *
 * e	- the SCN entry.
 * return - always successful (0).
 *
 * ****************************************************************************
 */
static int
scn_list_add(
	scn_registry_t *e
)
{
	scn_registry_t **pp;
	scn_portal_t *p;

	p = e->portal.p;
	e->portal.l = NULL;

	pp = &scn_registry;
	while (*pp) {
		if ((*pp)->uid == e->uid) {
			/* replace the bitmap */
			(*pp)->bitmap = e->bitmap;
			free_portal(p);
			free_entry(e);
			return (0);
		} else if ((*pp)->uid < e->uid) {
			break;
		}
		pp = &(*pp)->next;
	}

	(void) scn_add_portal(e, p);

	if (e->portal.l != NULL || sys_q == NULL) {
		/* insert it to the list */
		e->next = *pp;
		*pp = e;
	} else {
		/* no portal, ignore it */
		free_entry(e);
	}

	/* free the unused portal(s) */
	free_portal(p);

	return (0);
}

/*
 * ****************************************************************************
 *
 * scn_list_remove:
 *	Remove one SCN entry from the SCN entry list.
 *
 * uid	- the SCN entry unique ID.
 * return - always successful (0).
 *
 * ****************************************************************************
 */
static int
scn_list_remove(
	uint32_t uid
)
{
	scn_registry_t **ep, *e;

	ep = &scn_registry;
	e = *ep;
	while (e) {
		if (e->uid == uid) {
			/* destroy it */
			*ep = e->next;
			free_entry(e);
			break;
		} else if (e->uid < uid) {
			break;
		}
		ep = &e->next;
		e = *ep;
	}

	return (0);
}

/*
 * ****************************************************************************
 *
 * cb_get_scn_port:
 *	The callback function which returns the SCN port of a portal object.
 *
 * p1	- the portal object.
 * p2	- the lookup control data.
 * return - the SCN port number.
 *
 * ****************************************************************************
 */
static int
cb_get_scn_port(
	void *p1,
	/*ARGSUSED*/
	void *p2
)
{
	isns_obj_t *obj = (isns_obj_t *)p1;

	isns_attr_t *attr = &obj->attrs[
	    ATTR_INDEX_PORTAL(ISNS_SCN_PORT_ATTR_ID)];

	int port = 0;

	if (attr->tag != 0 && attr->value.ui != 0) {
		port = (int)attr->value.ui;
	}

	return (port);
}

/*
 * ****************************************************************************
 *
 * new_scn_portal:
 *	Make a new SCN portal.
 *
 * ref	- the ref count.
 * uid	- the portal object UID.
 * ip	- the ip address.
 * port	- the port number.
 * return - the SCN portal.
 *
 * ****************************************************************************
 */
static scn_portal_t *
new_scn_portal(
	uint32_t ref,
	uint32_t uid,
	in6_addr_t *ip,
	uint32_t port
)
{
	scn_portal_t *p;

	p = (scn_portal_t *)malloc(sizeof (scn_portal_t));
	if (p != NULL) {
		p->uid = uid;
		/* convert the ipv6 to ipv4 */
		if (((int *)ip)[0] == 0x00 &&
		    ((int *)ip)[1] == 0x00 &&
		    ((uchar_t *)ip)[8] == 0x00 &&
		    ((uchar_t *)ip)[9] == 0x00 &&
		    ((uchar_t *)ip)[10] == 0xFF &&
		    ((uchar_t *)ip)[11] == 0xFF) {
			p->sz = sizeof (in_addr_t);
			p->ip.in = ((uint32_t *)ip)[3];
			free(ip);
		} else {
			p->sz = sizeof (in6_addr_t);
			p->ip.in6 = ip;
		}
		p->port = port;
		p->ref = ref;
		p->so = 0;
		p->next = NULL;
	}

	return (p);
}

/*
 * ****************************************************************************
 *
 * extract scn_portal:
 *	Extract the SCN portal(s) for a storage node.
 *
 * name	- the storage node name.
 * return - the SCN portal list.
 *
 * ****************************************************************************
 */
static scn_portal_t *
extract_scn_portal(
	uchar_t *name
)
{
	scn_portal_t *list = NULL;
	scn_portal_t *p;

	lookup_ctrl_t lc_pg, lc_p;
	uint32_t pg_uid, uid;

	in6_addr_t *ip;
	uint32_t port;

	lc_pg.type = OBJ_PG;
	lc_pg.curr_uid = 0;
	lc_pg.id[0] = ATTR_INDEX_PG(ISNS_PG_ISCSI_NAME_ATTR_ID);
	lc_pg.op[0] = OP_STRING;
	lc_pg.data[0].ptr = name;
	lc_pg.op[1] = 0;

	lc_pg.id[1] = ISNS_PG_PORTAL_IP_ADDR_ATTR_ID;
	lc_pg.id[2] = ISNS_PG_PORTAL_PORT_ATTR_ID;

	lc_p.type = OBJ_PORTAL;
	lc_p.curr_uid = 0;
	lc_p.id[0] = ATTR_INDEX_PORTAL(ISNS_PORTAL_IP_ADDR_ATTR_ID);
	lc_p.op[0] = OP_MEMORY_IP6;
	lc_p.id[1] = ATTR_INDEX_PORTAL(ISNS_PORTAL_PORT_ATTR_ID);
	lc_p.op[1] = OP_INTEGER;
	lc_p.op[2] = 0;

	while (cache_lookup(&lc_pg, &pg_uid, cb_clone_attrs) == 0 &&
	    pg_uid != 0) {
		ip = lc_pg.data[1].ip;
		port = lc_pg.data[2].ui;
		if (ip != NULL) {
			lc_p.data[0].ip = ip;
			lc_p.data[1].ui = port;
			port = cache_lookup(&lc_p, &uid, cb_get_scn_port);
			if (port != 0 && uid != 0) {
				/* ref starts from 1 */
				p = new_scn_portal(1, uid, ip, port);
				if (p != NULL) {
					p->next = list;
					list = p;
				} else {
					free(ip);
					free(p);
				}
			} else {
				/* portal not registered or no scn port */
				free(ip);
			}
		}
		lc_pg.curr_uid = pg_uid;
	}

	return (list);
}

/*
 * ****************************************************************************
 *
 * cb_update_scn_bitmap:
 *	The callback function which updates the SCN Bitmap attribute of
 *	a storage node object.
 *
 * p1	- the storage node object.
 * p2	- the lookup control data.
 * return - error code.
 *
 * ****************************************************************************
 */
static int
cb_update_scn_bitmap(
	void *p1,
	void *p2
)
{
	int ec = 0;

	isns_obj_t *obj = (isns_obj_t *)p1;
	lookup_ctrl_t *lcp = (lookup_ctrl_t *)p2;

	int id = ATTR_INDEX_ISCSI(ISNS_ISCSI_SCN_BITMAP_ATTR_ID);
	isns_attr_t *attr = &obj->attrs[id];

	uint32_t bitmap = lcp->data[2].ui;

	if (bitmap != 0) {
		attr->tag = ISNS_ISCSI_SCN_BITMAP_ATTR_ID;
		attr->len = 4;
	} else if (attr->tag == 0) {
		return (ec);
	} else {
		attr->tag = 0;
		attr->len = 0;
	}
	attr->value.ui = bitmap;

	if (sys_q != NULL) {
		ec = write_data(DATA_UPDATE, obj);
	}

	return (ec);
}

/*
 * ****************************************************************************
 *
 * cb_get_node_type:
 *	The callback function which returns the node type attribute of
 *	a storage node object.
 *
 * p1	- the storage node object.
 * p2	- the lookup control data.
 * return - error code.
 *
 * ****************************************************************************
 */
static int
cb_get_node_type(
	void *p1,
	/* LINTED E_FUNC_ARG_UNUSED */
	void *p2
)
{
	isns_obj_t *obj = (isns_obj_t *)p1;
	isns_attr_t *attr = &obj->attrs[
	    ATTR_INDEX_ISCSI(ISNS_ISCSI_NODE_TYPE_ATTR_ID)];
	int nt = (int)attr->value.ui;

	return (nt);
}

/*
 * ****************************************************************************
 *
 * cb_get_node_type:
 *	The callback function which returns the storage node object UID
 *	from a portal group object.
 *
 * p1	- the pg object.
 * p2	- the lookup control data.
 * return - the storage node object UID.
 *
 * ****************************************************************************
 */
static int
cb_pg_node(
	void *p1,
	/* LINTED E_FUNC_ARG_UNUSED */
	void *p2
)
{
	uint32_t ref;

	ref = get_ref_t(p1, OBJ_ISCSI);

	return ((int)ref);
}

/*
 * ****************************************************************************
 *
 * make_raw_entity:
 *	Make raw SCN data with a Network Entity object.
 *
 * obj	- the network entity object.
 * return - the raw SCN data.
 *
 * ****************************************************************************
 */
static scn_raw_t *
make_raw_entity(
	/*ARGSUSED*/
	isns_obj_t *obj
)
{
	scn_raw_t *raw;

	raw = (scn_raw_t *)malloc(sizeof (scn_raw_t));
	if (raw != NULL) {
		raw->type = obj->type;
		raw->uid = get_obj_uid(obj);
		raw->iscsi = NULL;
		raw->ref = 0;
		raw->ilen = 0;
		raw->nt = 0;
		raw->ip = NULL;
		raw->dd_id = 0;
		raw->dds_id = 0;
	} else {
		isnslog(LOG_DEBUG, "make_raw_entity", "malloc failed.");
	}

	return (raw);
}

/*
 * ****************************************************************************
 *
 * make_raw_iscsi:
 *	Make raw SCN data with a Storage Node object.
 *
 * obj	- the storage node object.
 * return - the raw SCN data.
 *
 * ****************************************************************************
 */
static scn_raw_t *
make_raw_iscsi(
	isns_obj_t *obj
)
{
	uint32_t uid;
	uint32_t nt;
	uchar_t *iscsi;
	uint32_t ilen;

	isns_attr_t *attr;

	scn_raw_t *raw;

	uid = get_obj_uid(obj);
	attr = &obj->attrs[ATTR_INDEX_ISCSI(ISNS_ISCSI_NODE_TYPE_ATTR_ID)];
	nt = attr->value.ui;
	attr = &obj->attrs[ATTR_INDEX_ISCSI(ISNS_ISCSI_NAME_ATTR_ID)];

	raw = (scn_raw_t *)malloc(sizeof (scn_raw_t));
	ilen = attr->len;
	iscsi = (uchar_t *)malloc(ilen);
	if (raw != NULL && iscsi != NULL) {
		/* copy the iscsi storage node name */
		(void) strcpy((char *)iscsi, (char *)attr->value.ptr);

		raw->type = obj->type;
		raw->uid = uid;
		raw->iscsi = iscsi;
		raw->ref = 0;
		raw->ilen = ilen;
		raw->nt = nt;
		raw->ip = NULL;
		raw->dd_id = 0;
		raw->dds_id = 0;
	} else {
		free(raw);
		free(iscsi);
		raw = NULL;
		isnslog(LOG_DEBUG, "make_raw_iscsi", "malloc failed.");
	}

	return (raw);
}

/*
 * ****************************************************************************
 *
 * make_raw_portal:
 *	Make raw SCN data with a Portal object.
 *
 * obj	- the portal object.
 * return - the raw SCN data.
 *
 * ****************************************************************************
 */
static scn_raw_t *
make_raw_portal(
	isns_obj_t *obj
)
{
	isns_attr_t *attr;
	in6_addr_t *ip;
	uint32_t port;

	scn_raw_t *raw;

	raw = (scn_raw_t *)malloc(sizeof (scn_raw_t));
	ip = (in6_addr_t *)malloc(sizeof (in6_addr_t));
	if (raw != NULL && ip != NULL) {
		attr = &obj->attrs[
		    ATTR_INDEX_PORTAL(ISNS_PORTAL_IP_ADDR_ATTR_ID)];
		(void) memcpy(ip, attr->value.ip, sizeof (in6_addr_t));
		attr = &obj->attrs[
		    ATTR_INDEX_PORTAL(ISNS_PORTAL_PORT_ATTR_ID)];
		port = attr->value.ui;

		raw->type = obj->type;
		raw->uid = 0;
		raw->iscsi = NULL;
		raw->ref = 0;
		raw->ilen = 0;
		raw->nt = 0;
		raw->ip = ip;
		raw->port = port;
		raw->dd_id = 0;
		raw->dds_id = 0;
	} else {
		free(ip);
		free(raw);
		raw = NULL;
		isnslog(LOG_DEBUG, "make_raw_portal", "malloc failed.");
	}

	return (raw);
}

/*
 * ****************************************************************************
 *
 * make_raw_assoc_iscsi:
 *	Make raw SCN data with a Discovery Domain member association.
 *
 * obj	- the member association object.
 * return - the raw SCN data.
 *
 * ****************************************************************************
 */
static scn_raw_t *
make_raw_assoc_iscsi(
	isns_obj_t *obj
)
{
	uint32_t uid;
	uint32_t dd_id;
	uint32_t nt;

	lookup_ctrl_t lc;
	isns_attr_t *attr;

	scn_raw_t *raw;
	uchar_t *iscsi;
	uint32_t ilen;

	uid = get_obj_uid(obj);
	dd_id = get_parent_uid(obj);

	SET_UID_LCP(&lc, OBJ_ISCSI, uid);

	nt = cache_lookup(&lc, NULL, cb_get_node_type);

	attr = &obj->attrs[ATTR_INDEX_ASSOC_ISCSI(ISNS_DD_ISCSI_NAME_ATTR_ID)];

	raw = (scn_raw_t *)malloc(sizeof (scn_raw_t));
	ilen = attr->len;
	iscsi = (uchar_t *)malloc(ilen);
	if (raw != NULL && iscsi != NULL) {
		/* copy the iscsi storage node name */
		(void) strcpy((char *)iscsi, (char *)attr->value.ptr);

		raw->type = obj->type;
		raw->uid = uid;
		raw->iscsi = iscsi;
		raw->ref = 0;
		raw->ilen = ilen;
		raw->nt = nt;
		raw->ip = NULL;
		raw->dd_id = dd_id;
		raw->dds_id = 0;
	} else {
		free(raw);
		free(iscsi);
		raw = NULL;
		isnslog(LOG_DEBUG, "make_raw_assoc_iscsi", "malloc failed.");
	}

	return (raw);
}

/*
 * ****************************************************************************
 *
 * make_raw_assoc_dd:
 *	Make raw SCN data with a Discovery Domain Set member association.
 *
 * obj	- the member association object.
 * return - the raw SCN data.
 *
 * ****************************************************************************
 */
static scn_raw_t *
make_raw_assoc_dd(
	isns_obj_t *obj
)
{
	scn_raw_t *raw;

	raw = (scn_raw_t *)malloc(sizeof (scn_raw_t));
	if (raw != NULL) {
		raw->type = obj->type;
		raw->uid = 0;
		raw->iscsi = NULL;
		raw->ref = 0;
		raw->ilen = 0;
		raw->nt = 0;
		raw->ip = NULL;
		raw->dd_id = get_obj_uid(obj);
		raw->dds_id = get_parent_uid(obj);
	} else {
		isnslog(LOG_DEBUG, "make_raw_assoc_dd", "malloc failed.");
	}

	return (raw);
}

/*
 * ****************************************************************************
 *
 * scn_gen_entity:
 *	Generate SCN with the raw SCN data from a Network Entity object.
 *
 * raw	- the raw SCN data.
 * return - the SCN.
 *
 * ****************************************************************************
 */
static scn_text_t *
scn_gen_entity(
	/* LINTED E_FUNC_ARG_UNUSED */
	scn_raw_t *raw
)
{
	return (NULL);
}

/*
 * ****************************************************************************
 *
 * scn_gen_iscsi:
 *	Generate SCN with the raw SCN data from a Storage Node object.
 *
 * raw	- the raw SCN data.
 * return - the SCN.
 *
 * ****************************************************************************
 */
static scn_text_t *
scn_gen_iscsi(
	scn_raw_t *raw
)
{
	scn_text_t *text;

	text = (scn_text_t *)malloc(sizeof (scn_text_t));
	if (text != NULL) {
		text->flag = 0;
		text->ref = 1; /* start with 1 */
		text->uid = raw->uid;
		text->iscsi = raw->iscsi;
		raw->ref ++;
		text->ilen = raw->ilen;
		text->nt = raw->nt;
		text->dd_id = raw->dd_id;
		text->dds_id = raw->dds_id;
		text->next = NULL;
	} else {
		isnslog(LOG_DEBUG, "scn_gen_iscsi", "malloc failed.");
	}
	return (text);
}

/*
 * ****************************************************************************
 *
 * scn_gen_portal:
 *	Generate SCN with the raw SCN data from a Portal object.
 *
 * raw	- the raw SCN data.
 * return - the SCN.
 *
 * ****************************************************************************
 */
static scn_text_t *
scn_gen_portal(
	scn_raw_t *raw
)
{
	in6_addr_t *ip;
	uint32_t port;

	uint32_t pg_uid, uid;
	lookup_ctrl_t pg_lc, lc;

	uint32_t nt;
	uchar_t *name;
	int ilen;

	scn_text_t *text, *l = NULL;

	ip = raw->ip;
	port = raw->port;

	pg_lc.curr_uid = 0;
	pg_lc.type = OBJ_PG;
	pg_lc.id[0] = ATTR_INDEX_PG(ISNS_PG_PORTAL_IP_ADDR_ATTR_ID);
	pg_lc.op[0] = OP_MEMORY_IP6;
	pg_lc.data[0].ip = ip;
	pg_lc.id[1] = ATTR_INDEX_PG(ISNS_PG_PORTAL_PORT_ATTR_ID);
	pg_lc.op[1] = OP_INTEGER;
	pg_lc.data[1].ui = port;
	pg_lc.op[2] = 0;

	SET_UID_LCP(&lc, OBJ_ISCSI, 0);

	lc.id[1] = ISNS_ISCSI_NAME_ATTR_ID;
	lc.id[2] = ISNS_ISCSI_NODE_TYPE_ATTR_ID;
	lc.data[1].ptr = NULL;

	/* get a pg which is associated to the portal */
	uid = cache_lookup(&pg_lc, &pg_uid, cb_pg_node);
	while (pg_uid != 0) {
		if (uid != 0) {
			lc.data[0].ui = uid;
			(void) cache_lookup(&lc, NULL, cb_clone_attrs);
			name = lc.data[1].ptr;
			if (name != NULL) {
				nt = lc.data[2].ui;
				text = (scn_text_t *)malloc(
				    sizeof (scn_text_t));
				if (text != NULL) {
					text->flag = 0;
					text->ref = 1; /* start with 1 */
					text->uid = uid;
					text->iscsi = name;
					ilen = strlen((char *)name);
					ilen += 4 - (ilen % 4);
					text->ilen = ilen;
					text->nt = nt;
					text->dd_id = 0;
					text->dds_id = 0;
					text->next = l;
					l = text;
				} else {
					free(name);
					isnslog(LOG_DEBUG, "scn_gen_portal",
					    "malloc failed.");
				}
				lc.data[1].ptr = NULL;
			} else {
				isnslog(LOG_WARNING, "scn_gen_portal",
				    "cannot get node name.");
			}
		}

		/* get the next pg */
		pg_lc.curr_uid = pg_uid;
		uid = cache_lookup(&pg_lc, &pg_uid, cb_pg_node);
	}

	/* update the iscsi storage node object */
	raw->event = ISNS_OBJECT_UPDATED;

	return (l);
}

/*
 * ****************************************************************************
 *
 * scn_gen_assoc_dd:
 *	Generate SCN with the raw SCN data from a DD membership object.
 *
 * raw	- the raw SCN data.
 * return - the SCN.
 *
 * ****************************************************************************
 */
static scn_text_t *
scn_gen_assoc_dd(
	/* LINTED E_FUNC_ARG_UNUSED */
	scn_raw_t *raw
)
{
	return (NULL);
}

/*
 * ****************************************************************************
 *
 * make_scn:
 *	Make a SCN with an event and an object.
 *
 * event - the event.
 * obj	 - the object.
 * return - always successful (0).
 *
 * ****************************************************************************
 */
int
make_scn(
	uint32_t event,
	isns_obj_t *obj
)
{
	scn_raw_t *raw = NULL;

	scn_raw_t *(*f)(isns_obj_t *) = make_raw[obj->type];

	if (f != NULL) {
		/* make raw scn data */
		raw = f(obj);
	}
	if (raw != NULL) {
		/* trigger an scn event */
		raw->event = event;
		(void) queue_msg_set(scn_q, SCN_SET, (void *)raw);
	}

	return (0);
}

/*
 * data structure of the SCN state transition table.
 */
typedef struct scn_tbl {
	int state;
	uint32_t event;
	isns_type_t type;
	int (*sf)(scn_raw_t *);
	int next_state;
} scn_tbl_t;

/*
 * the SCN state transition table.
 */
static const scn_tbl_t stbl[] = {
	{ -1, 0, OBJ_PG, NULL, 0 },
	{ -1, 0, OBJ_DD, NULL, 0 },
	{ -1, 0, OBJ_DDS, NULL, 0 },

	{ 0, ISNS_OBJECT_ADDED, OBJ_ENTITY, NULL, 1 },
	{ 1, ISNS_OBJECT_ADDED, OBJ_ISCSI, sf_gen, 1 },
	{ 1, ISNS_OBJECT_ADDED, 0, NULL, 1 },

	{ 0, ISNS_OBJECT_UPDATED, OBJ_ENTITY, sf_gen, 2 },
	{ 2, ISNS_OBJECT_UPDATED, 0, NULL, 2 },
	{ 2, ISNS_OBJECT_ADDED, OBJ_ISCSI, sf_gen, 2 },
	{ 2, ISNS_OBJECT_ADDED, 0, NULL, 2 },

	{ 0, ISNS_OBJECT_REMOVED, OBJ_ENTITY, NULL, 3 },
	{ 0, ISNS_OBJECT_REMOVED, 0, sf_gen, 4 },
	{ 3, ISNS_OBJECT_REMOVED, OBJ_ISCSI, sf_gen, 3 },
	{ 3, ISNS_OBJECT_REMOVED, 0, NULL, 3 },
	{ 4, ISNS_OBJECT_REMOVED, 0, sf_gen, 4 },

	{ 0, ISNS_MEMBER_ADDED, OBJ_ASSOC_ISCSI, sf_gen, 5 },
	{ 5, ISNS_MEMBER_ADDED, OBJ_ASSOC_ISCSI, sf_gen, 5 },

	{ 0, ISNS_MEMBER_ADDED, OBJ_ASSOC_DD, sf_gen, 6 },
	{ 6, ISNS_MEMBER_ADDED, OBJ_ASSOC_DD, sf_gen, 6 },

	{ 0, ISNS_MEMBER_REMOVED, OBJ_ASSOC_ISCSI, sf_gen, 7 },
	{ 7, ISNS_MEMBER_REMOVED, OBJ_ASSOC_ISCSI, sf_gen, 7 },

	{ 0, ISNS_MEMBER_REMOVED, OBJ_ASSOC_DD, sf_gen, 8 },
	{ 8, ISNS_MEMBER_REMOVED, OBJ_ASSOC_DD, sf_gen, 8 },

	{ -1, 0, 0, sf_error, -1 }
};

/*
 * ****************************************************************************
 *
 * scn_disp1:
 *	Dispatch one SCN to one SCN entry.
 *
 * event - the event.
 * p	 - the SCN entry.
 * t	 - the SCN.
 * return - always successful (0).
 *
 * ****************************************************************************
 */
static int
scn_disp1(
	uint32_t event,
	scn_registry_t *p,
	scn_text_t *t
)
{
	scn_t *s, *r = NULL;
	scn_list_t *l, **lp;

	s = p->scn;

	while (s != NULL) {
		if (s->event == event) {
			l = s->data.list;
			do {
				if (l->data.text->uid == t->uid) {
					/* duplicated */
					return (0);
				}
				lp = &l->next;
				l = *lp;
			} while (l != NULL);
			break;
		}
		r = s;
		s = s->next;
	}

	l = (scn_list_t *)malloc(sizeof (scn_list_t));
	if (l != NULL) {
		if (s == NULL) {
			s = (scn_t *)malloc(sizeof (scn_t));
			if (s != NULL) {
				s->event = event;
				s->next = NULL;
				if (r != NULL) {
					r->next = s;
				} else {
					p->scn = s;
				}
				lp = &s->data.list;
			} else {
				free(l);
				isnslog(LOG_DEBUG, "scn_disp1",
				    "malloc scn failed.\n");
				return (0);
			}
		}

		t->ref ++;
		l->data.text = t;
		l->next = NULL;
		*lp = l;
	} else {
		isnslog(LOG_DEBUG, "scn_disp1",
		    "malloc list failed.\n");
	}

	return (0);
}

/*
 * ****************************************************************************
 *
 * scn_disp1:
 *	Dispatch one SCN to every SCN entry and update the dispatch status.
 *
 * event - the event.
 * text	 - the SCN.
 * return - always successful (0).
 *
 * ****************************************************************************
 */
static int
scn_disp(
	uint32_t event,
	scn_text_t *text
)
{
	scn_registry_t *registry, *p;
	uint32_t dd_id = 0;

	scn_text_t *t;

	uint32_t e;

	registry = scn_registry;

	t = text;
	while (t != NULL) {
		e = event;
		if (t->flag == 0) {
			if (e & ISNS_MEMBER_ADDED) {
				e |= ISNS_OBJECT_ADDED;
			} else if (e & ISNS_MEMBER_REMOVED) {
				e |= ISNS_OBJECT_REMOVED;
			}
		}
		p = registry;
		while (p != NULL) {
			if (SCN_TEST(e, p->bitmap, p->uid, t->uid, t->nt)) {
				if (p->bitmap & ISNS_MGMT_REG) {
					/* management scn are not bound */
					/* by discovery domain service. */
					dd_id = 1;
				} else {
					dd_id = 0;
					/* lock the cache for reading */
					(void) cache_lock_read();
					/* verify common dd */
					do {
						dd_id = get_common_dd(
						    p->uid,
						    t->uid,
						    dd_id);
					} while (dd_id > 0 &&
					    is_dd_active(dd_id) == 0);
					/* unlock the cache */
					(void) cache_unlock_nosync();
				}
				if (dd_id != 0) {
					(void) scn_disp1(e, p, t);
				}
			}
			p = p->next;
		}
		t = t->next;
	}

	while (text != NULL) {
		t = text->next;
		/* clean up the scn text(s) which nobody cares about. */
		free_scn_text(text);
		text = t;
	}

	if (dd_id != 0) {
		/* scn(s) are dispatched. */
		scn_dispatched = 1;
	}

	return (0);
}

/*
 * ****************************************************************************
 *
 * sf_gen:
 *	State transition function which generates and dispatches SCN(s).
 *
 * raw	- the raw SCN data.
 * return - always successful (0).
 *
 * ****************************************************************************
 */
static int
sf_gen(
	scn_raw_t *raw
)
{
	uint32_t event;

	scn_text_t *(*gen)(scn_raw_t *);
	scn_text_t *text = NULL;

	gen = scn_gen[raw->type];
	if (gen != NULL) {
		text = gen(raw);
	}

	event = raw->event;
	if (text != NULL) {
		(void) scn_disp(event, text);
	}

	return (0);
}

/*
 * ****************************************************************************
 *
 * sf_error:
 *	State transition function for an error state. It free any SCN(s)
 *	which have been generated and dispatched previously.
 *
 * raw	- the raw SCN data.
 * return - always successful (0).
 *
 * ****************************************************************************
 */
static int
sf_error(
	/* LINTED E_FUNC_ARG_UNUSED */
	scn_raw_t *raw
)
{
	free_scn();

	return (0);
}

/*
 * ****************************************************************************
 *
 * scn_transition:
 *	Performs the state transition when a SCN event occurs.
 *
 * state - the previous state.
 * raw	 - the raw SCN data.
 * return - the next state.
 *
 * ****************************************************************************
 */
static int
scn_transition(
	int state,
	scn_raw_t *raw
)
{
	uint32_t event = raw->event;
	isns_type_t type = raw->type;

	int new_state = state;

	const scn_tbl_t *tbl;

	tbl = &stbl[0];
	for (;;) {
		if ((tbl->state == -1 || tbl->state == state) &&
		    (tbl->event == 0 || tbl->event == event) &&
		    (tbl->type == 0 || tbl->type == type)) {
			if (tbl->next_state != 0) {
				new_state = tbl->next_state;
			}
			if (tbl->sf != NULL) {
				tbl->sf(raw);
			}
			break;
		}
		tbl ++;
	}

	if (new_state == -1) {
		isnslog(LOG_DEBUG, "scn_transition",
		    "prev state: %d new event: 0x%x new object: %d.\n",
		    state, event, type);
		new_state = 0;
	}

	state = new_state;

	return (state);
}

/*
 * ****************************************************************************
 *
 * connect_to:
 *	Create socket connection with peer network portal.
 *
 * sz	- the size of the ip addr.
 * in	- the ipv4 address.
 * in6	- the ipv6 address.
 * port2- the port info.
 * return - the socket descriptor.
 *
 * ****************************************************************************
 */
int
connect_to(
	int sz,
	in_addr_t in,
	/* LINTED E_FUNC_ARG_UNUSED */
	in6_addr_t *in6,
	uint32_t port2
)
{
	int so = -1;

	union {
		struct sockaddr sin;
		struct sockaddr_in in;
		struct sockaddr_in6 in6;
	} ca = { 0 };

	int tcp;
	uint16_t port;

	tcp = (port2 & 0x10000) == 0 ? 1 : 0;
	port = (uint16_t)(port2 & 0xFFFF);
	if (sz == sizeof (in_addr_t)) {
		if (tcp != 0) {
			so = socket(AF_INET, SOCK_STREAM, 0);
			if (so != -1) {
				ca.in.sin_family = AF_INET;
				ca.in.sin_port = htons(port);
				ca.in.sin_addr.s_addr = in;
				if (connect(so, &ca.sin, sizeof (ca.in)) !=
				    0) {
					isnslog(LOG_DEBUG, "connect_to",
					    "connect() failed %%m.");
					(void) close(so);
					so = -1;
				}
			} else {
				isnslog(LOG_DEBUG, "connect_to",
				    "socket() failed %%m.");
			}
		} else {
			/* FIXME: UDP support */
			isnslog(LOG_DEBUG, "connect_to", "No UDP support.");
		}
	} else {
		/* FIXME: IPv6 support */
		isnslog(LOG_DEBUG, "connect_to", "No IPv6 support.");
	}

	return (so);
}

/*
 * ****************************************************************************
 *
 * emit_scn:
 *	Emit the SCN to any portal of the peer storage node.
 *
 * list	- the list of portal.
 * pdu	- the SCN packet.
 * pl	- the SCN packet payload length.
 * return - always successful (0).
 *
 * ****************************************************************************
 */
static int
emit_scn(
	scn_list_t *list,
	isns_pdu_t *pdu,
	size_t pl
)
{
	int so = 0;
	scn_list_t *l;
	scn_portal_t *p;

	isns_pdu_t *rsp = NULL;
	size_t rsp_sz;

	pdu->version = htons((uint16_t)ISNSP_VERSION);
	pdu->func_id = htons((uint16_t)ISNS_SCN);
	pdu->xid = htons(get_server_xid());

	l = list;
	while (l != NULL) {
		p = l->data.portal;
		so = connect_to(p->sz, p->ip.in, p->ip.in6, p->port);
		if (so != -1) {
			if (isns_send_pdu(so, pdu, pl) == 0) {
				/* This may help Solaris iSCSI Initiator */
				/* not to panic frequently. */
				(void) isns_rcv_pdu(so, &rsp, &rsp_sz,
				    ISNS_RCV_SHORT_TIMEOUT);
			} else {
				isnslog(LOG_DEBUG, "emit_scn",
				    "sending packet failed.");
			}
			(void) close(so);
			/* p->so = so; */
			break;
		}
		l = l->next;
	}

	if (rsp != NULL) {
#ifdef DEBUG
		dump_pdu1(rsp);
#endif
		free(rsp);
	}

	return (0);
}

/*
 * ****************************************************************************
 *
 * scn_trigger1:
 *	Trigger one SCN for one SCN entry.
 *
 * t	- the time that SCN is being triggered.
 * p	- the SCN entry.
 * return - always successful (0).
 *
 * ****************************************************************************
 */
static int
scn_trigger1(
	time_t t,
	scn_registry_t *p
)
{
	int ec;

	isns_pdu_t *pdu = NULL;
	size_t sz;
	size_t pl;

	scn_t *s;
	scn_list_t *l;
	scn_text_t *x;

	union {
		uint32_t i32;
		uint64_t i64;
	} u;

#ifdef DEBUG
	char buff[1024] = { 0 };
	char *logbuff = buff;
#endif

	ec = pdu_reset_scn(&pdu, &pl, &sz);
	if (pdu == NULL) {
		goto scn_done;
	}

	/* add destination attribute */
	ec = pdu_add_tlv(&pdu, &pl, &sz,
	    ISNS_ISCSI_NAME_ATTR_ID,
	    p->nlen,
	    (void *)p->name, 0);
	if (ec != 0) {
		goto scn_done;
	}

#ifdef DEBUG
	sprintf(logbuff, "==>%s ", p->name);
	logbuff += strlen(logbuff);
#endif

	/* add timestamp */
	u.i64 = BE_64((uint64_t)t);
	ec = pdu_add_tlv(&pdu, &pl, &sz,
	    ISNS_TIMESTAMP_ATTR_ID,
	    8,
	    (void *)&u.i64, 1);

	s = p->scn;
	while (s != NULL && ec == 0) {
		u.i32 = htonl(s->event);
		ec = pdu_add_tlv(&pdu, &pl, &sz,
		    ISNS_ISCSI_SCN_BITMAP_ATTR_ID,
		    4,
		    (void *)&u.i32, 1);
#ifdef DEBUG
		sprintf(logbuff, "EVENT [%d] ", s->event);
		logbuff += strlen(logbuff);
#endif
		l = s->data.list;
		while (l != NULL && ec == 0) {
			x = l->data.text;
			if (x->flag == 0) {
				ec = pdu_add_tlv(&pdu, &pl, &sz,
				    ISNS_ISCSI_NAME_ATTR_ID,
				    x->ilen, (void *)x->iscsi, 0);
#ifdef DEBUG
				sprintf(logbuff, "FROM [%s] ", x->iscsi);
				logbuff += strlen(logbuff);
#endif
				if (ec == 0 &&
				    (p->bitmap &
				    (ISNS_MEMBER_ADDED |
				    ISNS_MEMBER_REMOVED))) {
					/* management SCN */
					u.i32 = htonl(x->dd_id);
					ec = pdu_add_tlv(&pdu, &pl, &sz,
					    ISNS_DD_ID_ATTR_ID,
					    4, (void *)&u.i32, 1);
#ifdef DEBUG
					sprintf(logbuff, "IN DD [%d] ",
					    x->dd_id);
					logbuff += strlen(logbuff);
#endif
				}
			} else {
				/* add(remove) dd to(from) dd-set */
				u.i32 = htonl(x->dd_id);
				ec = pdu_add_tlv(&pdu, &pl, &sz,
				    ISNS_DD_ID_ATTR_ID,
				    4, (void *)&u.i32, 1);
				u.i32 = htonl(x->dds_id);
				if (ec == 0) {
					ec = pdu_add_tlv(&pdu, &pl, &sz,
					    ISNS_DD_ID_ATTR_ID,
					    4, (void *)&u.i32, 1);
				}
#ifdef DEBUG
				sprintf(logbuff, "FROM [%d] ", x->dd_id);
				logbuff += strlen(logbuff);
				sprintf(logbuff, "IN [%d] ", x->dds_id);
				logbuff += strlen(logbuff);
#endif
			}
			l = l->next;
		}
		s = s->next;
	}

scn_done:
	if (ec == 0) {
#ifdef DEBUG
		isnslog(LOG_DEBUG, "scn_trigger1", buff);
#endif
		ec = emit_scn(p->portal.l, pdu, pl);
	} else {
		isnslog(LOG_DEBUG, "scn_trigger1", " failed.\n");
	}

	free(pdu);

	return (0);
}

/*
 * ****************************************************************************
 *
 * scn_trigger:
 *	Trigger one SCN for every SCN entry.
 *
 * return - always successful (0).
 *
 * ****************************************************************************
 */
static int
scn_trigger(
)
{
	time_t t;
	scn_registry_t *p;

	t = time(NULL);

	p = scn_registry;
	while (p != NULL) {
		if (p->scn != NULL) {
			(void) scn_trigger1(t, p);
		}
		p = p->next;
	}

	return (0);
}

/*
 * global functions.
 */

/*
 * ****************************************************************************
 *
 * scn_list_load:
 *	Load one SCN entry and add it to the SCN entry list.
 *
 * uid	- the Storage Node object UID.
 * node	- the Storage Node name.
 * nlen	- the length of the name.
 * bitmap - the SCN bitmap.
 * return - error code.
 *
 * ****************************************************************************
 */
int
scn_list_load(
	uint32_t uid,
	uchar_t *node,
	uint32_t nlen,
	uint32_t bitmap
)
{
	int ec = 0;

	scn_registry_t *list;
	uchar_t *name;

	list = (scn_registry_t *)malloc(sizeof (scn_registry_t));
	name = (uchar_t *)malloc(nlen);

	if (list != NULL && name != NULL) {
		list->uid = uid;
		(void) strcpy((char *)name, (char *)node);
		list->name = name;
		list->nlen = nlen;
		list->bitmap = bitmap;
		list->portal.l = NULL;
		list->scn = NULL;
		list->next = NULL;
		ASSERT(scn_q == NULL);
		(void) scn_list_add(list);
	} else {
		free(list);
		free(name);
		ec = ISNS_RSP_INTERNAL_ERROR;
	}

	return (ec);
}

/*
 * ****************************************************************************
 *
 * verify_scn_portal:
 *	Extract and verify portals for every SCN entry(s) after they are
 *	loaded from data store, for those which do not have a SCN portal,
 *	remove it from the SCN entry list.
 *
 * return - 1: error occurs, otherwise 0.
 *
 * ****************************************************************************
 */
int
verify_scn_portal(
)
{
	scn_registry_t **pp, *e;
	scn_portal_t *p;

	pp = &scn_registry;
	while (*pp != NULL) {
		e = *pp;
		p = extract_scn_portal(e->name);
		if (p != NULL) {
			if (scn_add_portal(e, p) != 0) {
				return (1);
			}
		}
		if (e->portal.l != NULL) {
			pp = &e->next;
		} else {
			/* remove this entry */
			*pp = e->next;
			free_entry(e);
		}
		/* free the unused portal(s) */
		free_portal(p);
	}

	return (0);
}

/*
 * ****************************************************************************
 *
 * add_scn_entry:
 *	Add a SCN entry.
 *
 * node	- the Storage Node name.
 * nlen	- the length of the name.
 * bitmap - the SCN bitmap.
 * return - error code.
 *
 * ****************************************************************************
 */
int
add_scn_entry(
	uchar_t *node,
	uint32_t nlen,
	uint32_t bitmap
)
{
	int ec = 0;

	uint32_t mgmt;
	scn_portal_t *p;

	lookup_ctrl_t lc;
	uint32_t uid;
	scn_registry_t *e;
	uchar_t *name;

	mgmt = bitmap & (
	    ISNS_MGMT_REG |
	    ISNS_MEMBER_REMOVED |
	    ISNS_MEMBER_ADDED);

	if ((mgmt > 0 &&
	    (mgmt_scn == 0 ||
	    mgmt < ISNS_MGMT_REG ||
	    is_control_node(node) == 0)) ||
	    (p = extract_scn_portal(node)) == NULL) {
		return (ISNS_RSP_SCN_REGIS_REJECTED);
	}

	e = (scn_registry_t *)malloc(sizeof (scn_registry_t));
	name = (uchar_t *)malloc(nlen);
	if (e != NULL && name != NULL) {
		lc.type = OBJ_ISCSI;
		lc.curr_uid = 0;
		lc.id[0] = ATTR_INDEX_ISCSI(ISNS_ISCSI_NAME_ATTR_ID);
		lc.data[0].ptr = node;
		lc.op[0] = OP_STRING;
		lc.op[1] = 0;
		lc.data[2].ui = bitmap;
		ec = cache_lookup(&lc, &uid, cb_update_scn_bitmap);
		if (uid == 0) {
			ec = ISNS_RSP_SCN_REGIS_REJECTED;
		}
		if (ec == 0) {
			e->uid = uid;
			(void) strcpy((char *)name, (char *)node);
			e->name = name;
			e->nlen = nlen;
			e->bitmap = bitmap;
			e->portal.p = p;
			e->scn = NULL;
			e->next = NULL;
			(void) queue_msg_set(scn_q, SCN_ADD, (void *)e);
		}
	} else {
		ec = ISNS_RSP_INTERNAL_ERROR;
	}

	if (ec != 0) {
		free(e);
		free(name);
		free_portal(p);
	}

	return (ec);
}

/*
 * ****************************************************************************
 *
 * remove_scn_entry:
 *	Remove a SCN entry.
 *
 * node	- the Storage Node name.
 * return - error code.
 *
 * ****************************************************************************
 */
int
remove_scn_entry(
	uchar_t *node
)
{
	int ec = 0;

	lookup_ctrl_t lc;
	uint32_t uid;

	lc.type = OBJ_ISCSI;
	lc.curr_uid = 0;
	lc.id[0] = ATTR_INDEX_ISCSI(ISNS_ISCSI_NAME_ATTR_ID);
	lc.data[0].ptr = node;
	lc.op[0] = OP_STRING;
	lc.op[1] = 0;
	lc.data[2].ui = 0;
	ec = cache_lookup(&lc, &uid, cb_update_scn_bitmap);
	if (ec == 0 && uid != 0) {
		(void) queue_msg_set(scn_q, SCN_REMOVE, (void *)uid);
	}

	return (ec);
}

/*
 * ****************************************************************************
 *
 * remove_scn_portal:
 *	Remove a portal from every SCN entry.
 *
 * uid	- the Portal object UID.
 * return - alrays successful (0).
 *
 * ****************************************************************************
 */
int
remove_scn_portal(
	uint32_t uid
)
{
	(void) queue_msg_set(scn_q, SCN_REMOVE_P, (void *)uid);

	return (0);
}

/*
 * ****************************************************************************
 *
 * scn_proc:
 *	The entry point of the SCN thread. It listens on the SCN message
 *	queue and process every SCN related stuff.
 *
 * arg	- nothing.
 * return - NULL.
 *
 * ****************************************************************************
 */
void *
scn_proc(
	/* LINTED E_FUNC_ARG_UNUSED */
	void *arg
)
{
	int state = 0;

	scn_raw_t *raw;
	msg_text_t *msg;

	for (;;) {
		msg = queue_msg_get(scn_q);
		switch (msg->id) {
		case SCN_ADD:
			(void) scn_list_add((scn_registry_t *)msg->data);
			break;
		case SCN_REMOVE:
			(void) scn_list_remove((uint32_t)msg->data);
			break;
		case SCN_REMOVE_P:
			(void) scn_remove_portal((uint32_t)msg->data);
			break;
		case SCN_SET:
			raw = (scn_raw_t *)msg->data;
			state = scn_transition(state, raw);
			/* free the raw data */
			free_raw(raw);
			break;
		case SCN_TRIGGER:
			if (scn_dispatched != 0) {
				(void) scn_trigger();
			}
		case SCN_IGNORE:
			/* clean the scn(s) */
			free_scn();
			/* reset the state */
			state = 0;
			/* reset the scn_dispatched flag */
			scn_dispatched = 0;
			break;
		case SCN_STOP:
			queue_msg_free(msg);
			return (NULL);
		default:
			break;
		}
		queue_msg_free(msg);
	}
}