rcm_daemon/common/aggr_rcm.c

36 #include <sys/aggr.h>
72 	CACHE_AGGR_PORT_OFFLINED	= 0x08,	/* aggr port offlined */
243  * aggr_list_insert - Insert an aggr in the global aggr list
246 aggr_list_insert(dl_aggr_t *aggr)
251 	aggr->da_next = aggr_head.da_next;
252 	aggr->da_prev = &aggr_head;
254 	aggr->da_next->da_prev = aggr;
255 	aggr->da_prev->da_next = aggr;
259  * aggr_list_remove - Remove an aggr from the global aggr list
262 aggr_list_remove(dl_aggr_t *aggr)
265 	aggr->da_next->da_prev = aggr->da_prev;
266 	aggr->da_prev->da_next = aggr->da_next;
267 	aggr->da_next = NULL;
268 	aggr->da_prev = NULL;
274 	dl_aggr_t *aggr;
277 	aggr = aggr_head.da_next;
278 	while (aggr != &aggr_tail) {
279 		aggr_list_remove(aggr);
280 		free(aggr);
281 		aggr = aggr_head.da_next;
489 	dl_aggr_t *aggr;
497 	aggr = node->vc_aggr;
502 	if (aggr->da_lastport == node->vc_linkid) {
504 		    aggr->da_aggrid);
505 		status = dladm_aggr_delete(dld_handle, aggr->da_aggrid,
510 		    node->vc_resource, aggr->da_aggrid);
512 		status = dladm_aggr_remove(dld_handle, aggr->da_aggrid, 1,
518 		    aggr->da_aggrid, dladm_status2str(status, errmsg));
523 		    aggr->da_aggrid);
532 	dl_aggr_t *aggr;
548 	aggr = node->vc_aggr;
549 	if (aggr->da_lastport == node->vc_linkid) {
551 		    aggr->da_aggrid);
552 		status = dladm_aggr_up(dld_handle, aggr->da_aggrid);
557 		    node->vc_resource, aggr->da_aggrid);
559 		status = dladm_aggr_add(dld_handle, aggr->da_aggrid, 1, &port,
565 		    aggr->da_aggrid, dladm_status2str(status, errmsg));
651 	dl_aggr_t *aggr;
675 		aggr = node->vc_aggr;
678 		    RCM_LINK_PREFIX, aggr->da_aggrid);
810 		    _("AGGR: usage(%s) get aggr %u name failure(%s)\n"),
903 aggr_port_update(rcm_handle_t *hd, dl_aggr_t *aggr, datalink_id_t portid)
910 	    "AGGR: aggr_port_update aggr:%u port:%u\n",
911 	    aggr->da_aggrid, portid);
928 		    rsrc, aggr->da_aggrid);
938 		node->vc_aggr = aggr;
942 		    rsrc, aggr->da_aggrid);
953 		node->vc_aggr = aggr;
980 	dl_aggr_t *aggr;
994 		    "AGGR: cannot get aggr information for %u error(%s)\n",
1000 	 * Try to find the aggr from the aggr list.
1002 	for (aggr = aggr_head.da_next; aggr != &aggr_tail; aggr = aggr->da_next)
1003 		if (aggr->da_aggrid == aggr_attr.lg_linkid)
1006 	if (aggr != NULL) {
1009 		if ((aggr = calloc(1, sizeof (dl_aggr_t))) == NULL) {
1018 		aggr->da_lastport = aggr_attr.lg_ports[0].lp_linkid;
1020 		aggr->da_lastport = DATALINK_INVALID_LINKID;
1021 	aggr->da_aggrid = aggr_attr.lg_linkid;
1026 		if (aggr_port_update(hd, aggr, portid) != 0)
1031 		aggr_list_insert(aggr);
1033 	aggr->da_stale = B_FALSE;
1040 		free(aggr);
1070 	dl_aggr_t *aggr;
1077 	/* first we walk the entire aggr list, marking each entry stale */
1078 	for (aggr = aggr_head.da_next; aggr != &aggr_tail; aggr = aggr->da_next)
1079 		aggr->da_stale = B_TRUE;
1124 	aggr = aggr_head.da_next;
1125 	while (aggr != &aggr_tail) {
1126 		dl_aggr_t *next = aggr->da_next;
1129 		if (aggr->da_stale) {
1130 			aggr_list_remove(aggr);
1131 			free(aggr);
1133 		aggr = next;
1264 	dl_aggr_t *aggr;
1289 	aggr = node->vc_aggr;
1290 	is_only_port = (aggr->da_lastport == node->vc_linkid);
1295 		    aggr->da_aggrid);
1297 		id = aggr->da_aggrid;