1d62bc4baSyz /*
2d62bc4baSyz * CDDL HEADER START
3d62bc4baSyz *
4d62bc4baSyz * The contents of this file are subject to the terms of the
5d62bc4baSyz * Common Development and Distribution License (the "License").
6d62bc4baSyz * You may not use this file except in compliance with the License.
7d62bc4baSyz *
8d62bc4baSyz * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9d62bc4baSyz * or http://www.opensolaris.org/os/licensing.
10d62bc4baSyz * See the License for the specific language governing permissions
11d62bc4baSyz * and limitations under the License.
12d62bc4baSyz *
13d62bc4baSyz * When distributing Covered Code, include this CDDL HEADER in each
14d62bc4baSyz * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15d62bc4baSyz * If applicable, add the following below this CDDL HEADER, with the
16d62bc4baSyz * fields enclosed by brackets "[]" replaced with your own identifying
17d62bc4baSyz * information: Portions Copyright [yyyy] [name of copyright owner]
18d62bc4baSyz *
19d62bc4baSyz * CDDL HEADER END
20d62bc4baSyz */
21d62bc4baSyz /*
2232715170SCathy Zhou * Copyright (c) 2005, 2010, Oracle and/or its affiliates. All rights reserved.
23d62bc4baSyz */
24d62bc4baSyz
25d62bc4baSyz /*
26d62bc4baSyz * This RCM module adds support to the RCM framework for VLAN links
27d62bc4baSyz */
28d62bc4baSyz
29d62bc4baSyz #include <stdio.h>
30d62bc4baSyz #include <stdlib.h>
31d62bc4baSyz #include <string.h>
32d62bc4baSyz #include <errno.h>
33d62bc4baSyz #include <sys/types.h>
34d62bc4baSyz #include <synch.h>
35d62bc4baSyz #include <assert.h>
36d62bc4baSyz #include <strings.h>
37d62bc4baSyz #include "rcm_module.h"
38d62bc4baSyz #include <libintl.h>
39d62bc4baSyz #include <libdllink.h>
40d62bc4baSyz #include <libdlvlan.h>
41d62bc4baSyz #include <libdlpi.h>
42d62bc4baSyz
43d62bc4baSyz /*
44d62bc4baSyz * Definitions
45d62bc4baSyz */
46d62bc4baSyz #ifndef lint
47d62bc4baSyz #define _(x) gettext(x)
48d62bc4baSyz #else
49d62bc4baSyz #define _(x) x
50d62bc4baSyz #endif
51d62bc4baSyz
52d62bc4baSyz /* Some generic well-knowns and defaults used in this module */
53d62bc4baSyz #define RCM_LINK_PREFIX "SUNW_datalink" /* RCM datalink name prefix */
54d62bc4baSyz #define RCM_LINK_RESOURCE_MAX (13 + LINKID_STR_WIDTH)
55d62bc4baSyz
56d62bc4baSyz /* VLAN link flags */
57d62bc4baSyz typedef enum {
58d62bc4baSyz VLAN_OFFLINED = 0x1,
59d62bc4baSyz VLAN_CONSUMER_OFFLINED = 0x2,
60d62bc4baSyz VLAN_STALE = 0x4
61d62bc4baSyz } vlan_flag_t;
62d62bc4baSyz
63d62bc4baSyz /* link representation */
64d62bc4baSyz typedef struct dl_vlan {
65d62bc4baSyz struct dl_vlan *dv_next; /* next VLAN on the same link */
66d62bc4baSyz struct dl_vlan *dv_prev; /* prev VLAN on the same link */
67d62bc4baSyz datalink_id_t dv_vlanid;
68d62bc4baSyz vlan_flag_t dv_flags; /* VLAN link flags */
69d62bc4baSyz } dl_vlan_t;
70d62bc4baSyz
71d62bc4baSyz /* VLAN Cache state flags */
72d62bc4baSyz typedef enum {
73d62bc4baSyz CACHE_NODE_STALE = 0x1, /* stale cached data */
74d62bc4baSyz CACHE_NODE_NEW = 0x2, /* new cached nodes */
75d62bc4baSyz CACHE_NODE_OFFLINED = 0x4 /* nodes offlined */
76d62bc4baSyz } cache_node_state_t;
77d62bc4baSyz
78d62bc4baSyz /* Network Cache lookup options */
79d62bc4baSyz #define CACHE_NO_REFRESH 0x1 /* cache refresh not needed */
80d62bc4baSyz #define CACHE_REFRESH 0x2 /* refresh cache */
81d62bc4baSyz
82d62bc4baSyz /* Cache element */
83d62bc4baSyz typedef struct link_cache {
84d62bc4baSyz struct link_cache *vc_next; /* next cached resource */
85d62bc4baSyz struct link_cache *vc_prev; /* prev cached resource */
86d62bc4baSyz char *vc_resource; /* resource name */
87d62bc4baSyz datalink_id_t vc_linkid; /* linkid */
88d62bc4baSyz dl_vlan_t *vc_vlan; /* VLAN list on this link */
89d62bc4baSyz cache_node_state_t vc_state; /* cache state flags */
90d62bc4baSyz } link_cache_t;
91d62bc4baSyz
92d62bc4baSyz /*
93d62bc4baSyz * Global cache for network VLANs
94d62bc4baSyz */
95d62bc4baSyz static link_cache_t cache_head;
96d62bc4baSyz static link_cache_t cache_tail;
97d62bc4baSyz static mutex_t cache_lock;
98d62bc4baSyz static int events_registered = 0;
99d62bc4baSyz
1004ac67f02SAnurag S. Maskey static dladm_handle_t dld_handle = NULL;
1014ac67f02SAnurag S. Maskey
102d62bc4baSyz /*
103d62bc4baSyz * RCM module interface prototypes
104d62bc4baSyz */
105d62bc4baSyz static int vlan_register(rcm_handle_t *);
106d62bc4baSyz static int vlan_unregister(rcm_handle_t *);
107d62bc4baSyz static int vlan_get_info(rcm_handle_t *, char *, id_t, uint_t,
108d62bc4baSyz char **, char **, nvlist_t *, rcm_info_t **);
109d62bc4baSyz static int vlan_suspend(rcm_handle_t *, char *, id_t,
110d62bc4baSyz timespec_t *, uint_t, char **, rcm_info_t **);
111d62bc4baSyz static int vlan_resume(rcm_handle_t *, char *, id_t, uint_t,
112d62bc4baSyz char **, rcm_info_t **);
113d62bc4baSyz static int vlan_offline(rcm_handle_t *, char *, id_t, uint_t,
114d62bc4baSyz char **, rcm_info_t **);
115d62bc4baSyz static int vlan_undo_offline(rcm_handle_t *, char *, id_t, uint_t,
116d62bc4baSyz char **, rcm_info_t **);
117d62bc4baSyz static int vlan_remove(rcm_handle_t *, char *, id_t, uint_t,
118d62bc4baSyz char **, rcm_info_t **);
119d62bc4baSyz static int vlan_notify_event(rcm_handle_t *, char *, id_t, uint_t,
120d62bc4baSyz char **, nvlist_t *, rcm_info_t **);
121d62bc4baSyz static int vlan_configure(rcm_handle_t *, datalink_id_t);
122d62bc4baSyz
123d62bc4baSyz /* Module private routines */
124d62bc4baSyz static void cache_free();
125d62bc4baSyz static int cache_update(rcm_handle_t *);
126d62bc4baSyz static void cache_remove(link_cache_t *);
127d62bc4baSyz static void node_free(link_cache_t *);
128d62bc4baSyz static void cache_insert(link_cache_t *);
129d62bc4baSyz static link_cache_t *cache_lookup(rcm_handle_t *, char *, char);
130d62bc4baSyz static int vlan_consumer_offline(rcm_handle_t *, link_cache_t *,
131d62bc4baSyz char **, uint_t, rcm_info_t **);
132d62bc4baSyz static void vlan_consumer_online(rcm_handle_t *, link_cache_t *,
133d62bc4baSyz char **, uint_t, rcm_info_t **);
134d62bc4baSyz static int vlan_offline_vlan(link_cache_t *, uint32_t,
135d62bc4baSyz cache_node_state_t);
136d62bc4baSyz static void vlan_online_vlan(link_cache_t *);
137d62bc4baSyz static char *vlan_usage(link_cache_t *);
138d62bc4baSyz static void vlan_log_err(datalink_id_t, char **, char *);
139d62bc4baSyz static int vlan_consumer_notify(rcm_handle_t *, datalink_id_t,
140d62bc4baSyz char **, uint_t, rcm_info_t **);
141d62bc4baSyz
142d62bc4baSyz /* Module-Private data */
143d62bc4baSyz static struct rcm_mod_ops vlan_ops =
144d62bc4baSyz {
145d62bc4baSyz RCM_MOD_OPS_VERSION,
146d62bc4baSyz vlan_register,
147d62bc4baSyz vlan_unregister,
148d62bc4baSyz vlan_get_info,
149d62bc4baSyz vlan_suspend,
150d62bc4baSyz vlan_resume,
151d62bc4baSyz vlan_offline,
152d62bc4baSyz vlan_undo_offline,
153d62bc4baSyz vlan_remove,
154d62bc4baSyz NULL,
155d62bc4baSyz NULL,
156d62bc4baSyz vlan_notify_event
157d62bc4baSyz };
158d62bc4baSyz
159d62bc4baSyz /*
160d62bc4baSyz * rcm_mod_init() - Update registrations, and return the ops structure.
161d62bc4baSyz */
162d62bc4baSyz struct rcm_mod_ops *
rcm_mod_init(void)163d62bc4baSyz rcm_mod_init(void)
164d62bc4baSyz {
165d4d1f7bfSVasumathi Sundaram - Sun Microsystems dladm_status_t status;
166d4d1f7bfSVasumathi Sundaram - Sun Microsystems char errmsg[DLADM_STRSIZE];
167d4d1f7bfSVasumathi Sundaram - Sun Microsystems
168d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: mod_init\n");
169d62bc4baSyz
170d62bc4baSyz cache_head.vc_next = &cache_tail;
171d62bc4baSyz cache_head.vc_prev = NULL;
172d62bc4baSyz cache_tail.vc_prev = &cache_head;
173d62bc4baSyz cache_tail.vc_next = NULL;
174d62bc4baSyz (void) mutex_init(&cache_lock, 0, NULL);
175d62bc4baSyz
176d4d1f7bfSVasumathi Sundaram - Sun Microsystems if ((status = dladm_open(&dld_handle)) != DLADM_STATUS_OK) {
177d4d1f7bfSVasumathi Sundaram - Sun Microsystems rcm_log_message(RCM_WARNING,
178d4d1f7bfSVasumathi Sundaram - Sun Microsystems "VLAN: mod_init failed: cannot open datalink handle: %s\n",
179d4d1f7bfSVasumathi Sundaram - Sun Microsystems dladm_status2str(status, errmsg));
180d4d1f7bfSVasumathi Sundaram - Sun Microsystems return (NULL);
181d4d1f7bfSVasumathi Sundaram - Sun Microsystems }
1824ac67f02SAnurag S. Maskey
183d62bc4baSyz /* Return the ops vectors */
184d62bc4baSyz return (&vlan_ops);
185d62bc4baSyz }
186d62bc4baSyz
187d62bc4baSyz /*
188d62bc4baSyz * rcm_mod_info() - Return a string describing this module.
189d62bc4baSyz */
190d62bc4baSyz const char *
rcm_mod_info(void)191d62bc4baSyz rcm_mod_info(void)
192d62bc4baSyz {
193d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: mod_info\n");
194d62bc4baSyz
195648495d6Svikram return ("VLAN module version 1.2");
196d62bc4baSyz }
197d62bc4baSyz
198d62bc4baSyz /*
199d62bc4baSyz * rcm_mod_fini() - Destroy the network VLAN cache.
200d62bc4baSyz */
201d62bc4baSyz int
rcm_mod_fini(void)202d62bc4baSyz rcm_mod_fini(void)
203d62bc4baSyz {
204d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: mod_fini\n");
205d62bc4baSyz
206d62bc4baSyz /*
207d62bc4baSyz * Note that vlan_unregister() does not seem to be called anywhere,
208d62bc4baSyz * therefore we free the cache nodes here. In theory we should call
209d62bc4baSyz * rcm_register_interest() for each node before we free it, the
210d62bc4baSyz * framework does not provide the rcm_handle to allow us to do so.
211d62bc4baSyz */
212d62bc4baSyz cache_free();
213d62bc4baSyz (void) mutex_destroy(&cache_lock);
2144ac67f02SAnurag S. Maskey
2154ac67f02SAnurag S. Maskey dladm_close(dld_handle);
216d62bc4baSyz return (RCM_SUCCESS);
217d62bc4baSyz }
218d62bc4baSyz
219d62bc4baSyz /*
220d62bc4baSyz * vlan_register() - Make sure the cache is properly sync'ed, and its
221d62bc4baSyz * registrations are in order.
222d62bc4baSyz */
223d62bc4baSyz static int
vlan_register(rcm_handle_t * hd)224d62bc4baSyz vlan_register(rcm_handle_t *hd)
225d62bc4baSyz {
226d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: register\n");
227d62bc4baSyz
228d62bc4baSyz if (cache_update(hd) < 0)
229d62bc4baSyz return (RCM_FAILURE);
230d62bc4baSyz
231d62bc4baSyz /*
232d62bc4baSyz * Need to register interest in all new resources
233d62bc4baSyz * getting attached, so we get attach event notifications
234d62bc4baSyz */
235d62bc4baSyz if (!events_registered) {
236d62bc4baSyz if (rcm_register_event(hd, RCM_RESOURCE_LINK_NEW, 0, NULL)
237d62bc4baSyz != RCM_SUCCESS) {
238d62bc4baSyz rcm_log_message(RCM_ERROR,
239d62bc4baSyz _("VLAN: failed to register %s\n"),
240d62bc4baSyz RCM_RESOURCE_LINK_NEW);
241d62bc4baSyz return (RCM_FAILURE);
242d62bc4baSyz } else {
243d62bc4baSyz rcm_log_message(RCM_DEBUG, "VLAN: registered %s\n",
244d62bc4baSyz RCM_RESOURCE_LINK_NEW);
245d62bc4baSyz events_registered++;
246d62bc4baSyz }
247d62bc4baSyz }
248d62bc4baSyz
249d62bc4baSyz return (RCM_SUCCESS);
250d62bc4baSyz }
251d62bc4baSyz
252d62bc4baSyz /*
253d62bc4baSyz * vlan_unregister() - Walk the cache, unregistering all the networks.
254d62bc4baSyz */
255d62bc4baSyz static int
vlan_unregister(rcm_handle_t * hd)256d62bc4baSyz vlan_unregister(rcm_handle_t *hd)
257d62bc4baSyz {
258d62bc4baSyz link_cache_t *node;
259d62bc4baSyz
260d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: unregister\n");
261d62bc4baSyz
262d62bc4baSyz /* Walk the cache, unregistering everything */
263d62bc4baSyz (void) mutex_lock(&cache_lock);
264d62bc4baSyz node = cache_head.vc_next;
265d62bc4baSyz while (node != &cache_tail) {
266d62bc4baSyz if (rcm_unregister_interest(hd, node->vc_resource, 0)
267d62bc4baSyz != RCM_SUCCESS) {
268d62bc4baSyz rcm_log_message(RCM_ERROR,
269d62bc4baSyz _("VLAN: failed to unregister %s\n"),
270d62bc4baSyz node->vc_resource);
271d62bc4baSyz (void) mutex_unlock(&cache_lock);
272d62bc4baSyz return (RCM_FAILURE);
273d62bc4baSyz }
274d62bc4baSyz cache_remove(node);
275d62bc4baSyz node_free(node);
276d62bc4baSyz node = cache_head.vc_next;
277d62bc4baSyz }
278d62bc4baSyz (void) mutex_unlock(&cache_lock);
279d62bc4baSyz
280d62bc4baSyz /*
281d62bc4baSyz * Unregister interest in all new resources
282d62bc4baSyz */
283d62bc4baSyz if (events_registered) {
284d62bc4baSyz if (rcm_unregister_event(hd, RCM_RESOURCE_LINK_NEW, 0)
285d62bc4baSyz != RCM_SUCCESS) {
286d62bc4baSyz rcm_log_message(RCM_ERROR,
287d62bc4baSyz _("VLAN: failed to unregister %s\n"),
288d62bc4baSyz RCM_RESOURCE_LINK_NEW);
289d62bc4baSyz return (RCM_FAILURE);
290d62bc4baSyz } else {
291d62bc4baSyz rcm_log_message(RCM_DEBUG, "VLAN: unregistered %s\n",
292d62bc4baSyz RCM_RESOURCE_LINK_NEW);
293d62bc4baSyz events_registered--;
294d62bc4baSyz }
295d62bc4baSyz }
296d62bc4baSyz
297d62bc4baSyz return (RCM_SUCCESS);
298d62bc4baSyz }
299d62bc4baSyz
300d62bc4baSyz /*
301d62bc4baSyz * vlan_offline() - Offline VLANs on a specific node.
302d62bc4baSyz */
303d62bc4baSyz static int
vlan_offline(rcm_handle_t * hd,char * rsrc,id_t id,uint_t flags,char ** errorp,rcm_info_t ** info)304d62bc4baSyz vlan_offline(rcm_handle_t *hd, char *rsrc, id_t id, uint_t flags,
305d62bc4baSyz char **errorp, rcm_info_t **info)
306d62bc4baSyz {
307d62bc4baSyz link_cache_t *node;
308d62bc4baSyz
309d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: offline(%s)\n", rsrc);
310d62bc4baSyz
311d62bc4baSyz /* Lock the cache and lookup the resource */
312d62bc4baSyz (void) mutex_lock(&cache_lock);
313d62bc4baSyz node = cache_lookup(hd, rsrc, CACHE_REFRESH);
314d62bc4baSyz if (node == NULL) {
315d62bc4baSyz /* should not happen because the resource is registered. */
31632715170SCathy Zhou vlan_log_err(DATALINK_INVALID_LINKID, errorp,
31732715170SCathy Zhou "unrecognized resource");
318d62bc4baSyz (void) mutex_unlock(&cache_lock);
319d62bc4baSyz return (RCM_SUCCESS);
320d62bc4baSyz }
321d62bc4baSyz
322d62bc4baSyz /*
323d62bc4baSyz * Inform consumers (IP interfaces) of associated VLANs to be offlined
324d62bc4baSyz */
325d62bc4baSyz if (vlan_consumer_offline(hd, node, errorp, flags, info) ==
326d62bc4baSyz RCM_SUCCESS) {
327d62bc4baSyz rcm_log_message(RCM_DEBUG,
328d62bc4baSyz "VLAN: consumers agreed on offline\n");
329d62bc4baSyz } else {
330d62bc4baSyz vlan_log_err(node->vc_linkid, errorp,
331d62bc4baSyz "consumers failed to offline");
332d62bc4baSyz (void) mutex_unlock(&cache_lock);
333d62bc4baSyz return (RCM_FAILURE);
334d62bc4baSyz }
335d62bc4baSyz
336d62bc4baSyz /* Check if it's a query */
337d62bc4baSyz if (flags & RCM_QUERY) {
338d62bc4baSyz rcm_log_message(RCM_TRACE1,
339d62bc4baSyz "VLAN: offline query succeeded(%s)\n", rsrc);
340d62bc4baSyz (void) mutex_unlock(&cache_lock);
341d62bc4baSyz return (RCM_SUCCESS);
342d62bc4baSyz }
343d62bc4baSyz
344d62bc4baSyz if (vlan_offline_vlan(node, VLAN_OFFLINED, CACHE_NODE_OFFLINED) !=
345d62bc4baSyz RCM_SUCCESS) {
346d62bc4baSyz vlan_online_vlan(node);
347d62bc4baSyz vlan_log_err(node->vc_linkid, errorp, "offline failed");
348d62bc4baSyz (void) mutex_unlock(&cache_lock);
349d62bc4baSyz return (RCM_FAILURE);
350d62bc4baSyz }
351d62bc4baSyz
352d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: Offline succeeded(%s)\n", rsrc);
353d62bc4baSyz (void) mutex_unlock(&cache_lock);
354d62bc4baSyz return (RCM_SUCCESS);
355d62bc4baSyz }
356d62bc4baSyz
357d62bc4baSyz /*
358d62bc4baSyz * vlan_undo_offline() - Undo offline of a previously offlined node.
359d62bc4baSyz */
360d62bc4baSyz /*ARGSUSED*/
361d62bc4baSyz static int
vlan_undo_offline(rcm_handle_t * hd,char * rsrc,id_t id,uint_t flags,char ** errorp,rcm_info_t ** info)362d62bc4baSyz vlan_undo_offline(rcm_handle_t *hd, char *rsrc, id_t id, uint_t flags,
363d62bc4baSyz char **errorp, rcm_info_t **info)
364d62bc4baSyz {
365d62bc4baSyz link_cache_t *node;
366d62bc4baSyz
367d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: online(%s)\n", rsrc);
368d62bc4baSyz
369d62bc4baSyz (void) mutex_lock(&cache_lock);
370d62bc4baSyz node = cache_lookup(hd, rsrc, CACHE_NO_REFRESH);
371d62bc4baSyz if (node == NULL) {
372d62bc4baSyz vlan_log_err(DATALINK_INVALID_LINKID, errorp, "no such link");
373d62bc4baSyz (void) mutex_unlock(&cache_lock);
374d62bc4baSyz errno = ENOENT;
375d62bc4baSyz return (RCM_FAILURE);
376d62bc4baSyz }
377d62bc4baSyz
378d62bc4baSyz /* Check if no attempt should be made to online the link here */
379d62bc4baSyz if (!(node->vc_state & CACHE_NODE_OFFLINED)) {
380d62bc4baSyz vlan_log_err(node->vc_linkid, errorp, "link not offlined");
381d62bc4baSyz (void) mutex_unlock(&cache_lock);
382d62bc4baSyz errno = ENOTSUP;
383d62bc4baSyz return (RCM_SUCCESS);
384d62bc4baSyz }
385d62bc4baSyz
386d62bc4baSyz vlan_online_vlan(node);
387d62bc4baSyz
388d62bc4baSyz /*
389d62bc4baSyz * Inform IP interfaces on associated VLANs to be onlined
390d62bc4baSyz */
391d62bc4baSyz vlan_consumer_online(hd, node, errorp, flags, info);
392d62bc4baSyz
393d62bc4baSyz node->vc_state &= ~CACHE_NODE_OFFLINED;
394d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: online succeeded(%s)\n", rsrc);
395d62bc4baSyz (void) mutex_unlock(&cache_lock);
396d62bc4baSyz return (RCM_SUCCESS);
397d62bc4baSyz }
398d62bc4baSyz
399d62bc4baSyz static void
vlan_online_vlan(link_cache_t * node)400d62bc4baSyz vlan_online_vlan(link_cache_t *node)
401d62bc4baSyz {
402d62bc4baSyz dl_vlan_t *vlan;
403d62bc4baSyz dladm_status_t status;
404d62bc4baSyz char errmsg[DLADM_STRSIZE];
405d62bc4baSyz
406d62bc4baSyz /*
407d62bc4baSyz * Try to bring on all offlined VLANs
408d62bc4baSyz */
409d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = vlan->dv_next) {
410d62bc4baSyz if (!(vlan->dv_flags & VLAN_OFFLINED))
411d62bc4baSyz continue;
412d62bc4baSyz
4134ac67f02SAnurag S. Maskey if ((status = dladm_vlan_up(dld_handle, vlan->dv_vlanid)) !=
414d62bc4baSyz DLADM_STATUS_OK) {
415d62bc4baSyz /*
416d62bc4baSyz * Print a warning message and continue to online
417d62bc4baSyz * other VLANs.
418d62bc4baSyz */
419d62bc4baSyz rcm_log_message(RCM_WARNING,
420d62bc4baSyz _("VLAN: VLAN online failed (%u): %s\n"),
421d62bc4baSyz vlan->dv_vlanid, dladm_status2str(status, errmsg));
422d62bc4baSyz } else {
423d62bc4baSyz vlan->dv_flags &= ~VLAN_OFFLINED;
424d62bc4baSyz }
425d62bc4baSyz }
426d62bc4baSyz }
427d62bc4baSyz
428d62bc4baSyz static int
vlan_offline_vlan(link_cache_t * node,uint32_t flags,cache_node_state_t state)429d62bc4baSyz vlan_offline_vlan(link_cache_t *node, uint32_t flags, cache_node_state_t state)
430d62bc4baSyz {
431d62bc4baSyz dl_vlan_t *vlan;
432d62bc4baSyz dladm_status_t status;
433d62bc4baSyz char errmsg[DLADM_STRSIZE];
434d62bc4baSyz
435d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_offline_vlan (%s %u %u)\n",
436d62bc4baSyz node->vc_resource, flags, state);
437d62bc4baSyz
438d62bc4baSyz /*
439d62bc4baSyz * Try to delete all explicit created VLAN
440d62bc4baSyz */
441d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = vlan->dv_next) {
4424ac67f02SAnurag S. Maskey if ((status = dladm_vlan_delete(dld_handle, vlan->dv_vlanid,
443d62bc4baSyz DLADM_OPT_ACTIVE)) != DLADM_STATUS_OK) {
444d62bc4baSyz rcm_log_message(RCM_WARNING,
445d62bc4baSyz _("VLAN: VLAN offline failed (%u): %s\n"),
446d62bc4baSyz vlan->dv_vlanid, dladm_status2str(status, errmsg));
447d62bc4baSyz return (RCM_FAILURE);
448d62bc4baSyz } else {
449d62bc4baSyz rcm_log_message(RCM_TRACE1,
450d62bc4baSyz "VLAN: VLAN offline succeeded(%u)\n",
451d62bc4baSyz vlan->dv_vlanid);
452d62bc4baSyz vlan->dv_flags |= flags;
453d62bc4baSyz }
454d62bc4baSyz }
455d62bc4baSyz
456d62bc4baSyz node->vc_state |= state;
457d62bc4baSyz return (RCM_SUCCESS);
458d62bc4baSyz }
459d62bc4baSyz
460d62bc4baSyz /*
461d62bc4baSyz * vlan_get_info() - Gather usage information for this resource.
462d62bc4baSyz */
463d62bc4baSyz /*ARGSUSED*/
464d62bc4baSyz int
vlan_get_info(rcm_handle_t * hd,char * rsrc,id_t id,uint_t flags,char ** usagep,char ** errorp,nvlist_t * props,rcm_info_t ** info)465d62bc4baSyz vlan_get_info(rcm_handle_t *hd, char *rsrc, id_t id, uint_t flags,
466d62bc4baSyz char **usagep, char **errorp, nvlist_t *props, rcm_info_t **info)
467d62bc4baSyz {
468d62bc4baSyz link_cache_t *node;
469d62bc4baSyz
470d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: get_info(%s)\n", rsrc);
471d62bc4baSyz
472d62bc4baSyz (void) mutex_lock(&cache_lock);
473d62bc4baSyz node = cache_lookup(hd, rsrc, CACHE_REFRESH);
474d62bc4baSyz if (node == NULL) {
475d62bc4baSyz rcm_log_message(RCM_INFO,
476d62bc4baSyz _("VLAN: get_info(%s) unrecognized resource\n"), rsrc);
477d62bc4baSyz (void) mutex_unlock(&cache_lock);
478d62bc4baSyz errno = ENOENT;
479d62bc4baSyz return (RCM_FAILURE);
480d62bc4baSyz }
481d62bc4baSyz
482d62bc4baSyz *usagep = vlan_usage(node);
483d62bc4baSyz (void) mutex_unlock(&cache_lock);
484d62bc4baSyz if (*usagep == NULL) {
485d62bc4baSyz /* most likely malloc failure */
486d62bc4baSyz rcm_log_message(RCM_ERROR,
487d62bc4baSyz _("VLAN: get_info(%s) malloc failure\n"), rsrc);
488d62bc4baSyz (void) mutex_unlock(&cache_lock);
489d62bc4baSyz errno = ENOMEM;
490d62bc4baSyz return (RCM_FAILURE);
491d62bc4baSyz }
492d62bc4baSyz
493d62bc4baSyz /* Set client/role properties */
494d62bc4baSyz (void) nvlist_add_string(props, RCM_CLIENT_NAME, "VLAN");
495d62bc4baSyz
496d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: get_info(%s) info = %s\n",
497d62bc4baSyz rsrc, *usagep);
498d62bc4baSyz return (RCM_SUCCESS);
499d62bc4baSyz }
500d62bc4baSyz
501d62bc4baSyz /*
502d62bc4baSyz * vlan_suspend() - Nothing to do, always okay
503d62bc4baSyz */
504d62bc4baSyz /*ARGSUSED*/
505d62bc4baSyz static int
vlan_suspend(rcm_handle_t * hd,char * rsrc,id_t id,timespec_t * interval,uint_t flags,char ** errorp,rcm_info_t ** info)506d62bc4baSyz vlan_suspend(rcm_handle_t *hd, char *rsrc, id_t id, timespec_t *interval,
507d62bc4baSyz uint_t flags, char **errorp, rcm_info_t **info)
508d62bc4baSyz {
509d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: suspend(%s)\n", rsrc);
510d62bc4baSyz return (RCM_SUCCESS);
511d62bc4baSyz }
512d62bc4baSyz
513d62bc4baSyz /*
514d62bc4baSyz * vlan_resume() - Nothing to do, always okay
515d62bc4baSyz */
516d62bc4baSyz /*ARGSUSED*/
517d62bc4baSyz static int
vlan_resume(rcm_handle_t * hd,char * rsrc,id_t id,uint_t flags,char ** errorp,rcm_info_t ** info)518d62bc4baSyz vlan_resume(rcm_handle_t *hd, char *rsrc, id_t id, uint_t flags,
519d62bc4baSyz char **errorp, rcm_info_t **info)
520d62bc4baSyz {
521d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: resume(%s)\n", rsrc);
522d62bc4baSyz return (RCM_SUCCESS);
523d62bc4baSyz }
524d62bc4baSyz
525d62bc4baSyz /*
526d62bc4baSyz * vlan_consumer_remove()
527d62bc4baSyz *
528d62bc4baSyz * Notify VLAN consumers to remove cache.
529d62bc4baSyz */
530d62bc4baSyz static int
vlan_consumer_remove(rcm_handle_t * hd,link_cache_t * node,uint_t flags,rcm_info_t ** info)531d62bc4baSyz vlan_consumer_remove(rcm_handle_t *hd, link_cache_t *node, uint_t flags,
532d62bc4baSyz rcm_info_t **info)
533d62bc4baSyz {
534d62bc4baSyz dl_vlan_t *vlan = NULL;
535d62bc4baSyz char rsrc[RCM_LINK_RESOURCE_MAX];
536d62bc4baSyz int ret = RCM_SUCCESS;
537d62bc4baSyz
538d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_consumer_remove (%s)\n",
539d62bc4baSyz node->vc_resource);
540d62bc4baSyz
541d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = vlan->dv_next) {
542d62bc4baSyz
543d62bc4baSyz /*
544d62bc4baSyz * This will only be called when the offline operation
545d62bc4baSyz * succeeds, so the VLAN consumers must have been offlined
546d62bc4baSyz * at this point.
547d62bc4baSyz */
548d62bc4baSyz assert(vlan->dv_flags & VLAN_CONSUMER_OFFLINED);
549d62bc4baSyz
550d62bc4baSyz (void) snprintf(rsrc, RCM_LINK_RESOURCE_MAX, "%s/%u",
551d62bc4baSyz RCM_LINK_PREFIX, vlan->dv_vlanid);
552d62bc4baSyz
553d62bc4baSyz ret = rcm_notify_remove(hd, rsrc, flags, info);
554d62bc4baSyz if (ret != RCM_SUCCESS) {
555d62bc4baSyz rcm_log_message(RCM_WARNING,
556d62bc4baSyz _("VLAN: notify remove failed (%s)\n"), rsrc);
557d62bc4baSyz break;
558d62bc4baSyz }
559d62bc4baSyz }
560d62bc4baSyz
561d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_consumer_remove done\n");
562d62bc4baSyz return (ret);
563d62bc4baSyz }
564d62bc4baSyz
565d62bc4baSyz /*
566d62bc4baSyz * vlan_remove() - remove a resource from cache
567d62bc4baSyz */
568d62bc4baSyz /*ARGSUSED*/
569d62bc4baSyz static int
vlan_remove(rcm_handle_t * hd,char * rsrc,id_t id,uint_t flags,char ** errorp,rcm_info_t ** info)570d62bc4baSyz vlan_remove(rcm_handle_t *hd, char *rsrc, id_t id, uint_t flags,
571d62bc4baSyz char **errorp, rcm_info_t **info)
572d62bc4baSyz {
573d62bc4baSyz link_cache_t *node;
574d62bc4baSyz int rv;
575d62bc4baSyz
576d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: remove(%s)\n", rsrc);
577d62bc4baSyz
578d62bc4baSyz (void) mutex_lock(&cache_lock);
579d62bc4baSyz node = cache_lookup(hd, rsrc, CACHE_NO_REFRESH);
580d62bc4baSyz if (node == NULL) {
581d62bc4baSyz rcm_log_message(RCM_INFO,
582d62bc4baSyz _("VLAN: remove(%s) unrecognized resource\n"), rsrc);
583d62bc4baSyz (void) mutex_unlock(&cache_lock);
584d62bc4baSyz errno = ENOENT;
585d62bc4baSyz return (RCM_FAILURE);
586d62bc4baSyz }
587d62bc4baSyz
588d62bc4baSyz /* remove the cached entry for the resource */
589d62bc4baSyz cache_remove(node);
590d62bc4baSyz (void) mutex_unlock(&cache_lock);
591d62bc4baSyz
592d62bc4baSyz rv = vlan_consumer_remove(hd, node, flags, info);
593d62bc4baSyz node_free(node);
594d62bc4baSyz return (rv);
595d62bc4baSyz }
596d62bc4baSyz
597d62bc4baSyz /*
598d62bc4baSyz * vlan_notify_event - Project private implementation to receive new resource
599d62bc4baSyz * events. It intercepts all new resource events. If the
600d62bc4baSyz * new resource is a network resource, pass up a notify
601d62bc4baSyz * for it too. The new resource need not be cached, since
602d62bc4baSyz * it is done at register again.
603d62bc4baSyz */
604d62bc4baSyz /*ARGSUSED*/
605d62bc4baSyz static int
vlan_notify_event(rcm_handle_t * hd,char * rsrc,id_t id,uint_t flags,char ** errorp,nvlist_t * nvl,rcm_info_t ** info)606d62bc4baSyz vlan_notify_event(rcm_handle_t *hd, char *rsrc, id_t id, uint_t flags,
607d62bc4baSyz char **errorp, nvlist_t *nvl, rcm_info_t **info)
608d62bc4baSyz {
609d62bc4baSyz nvpair_t *nvp = NULL;
610d62bc4baSyz datalink_id_t linkid;
611d62bc4baSyz uint64_t id64;
612d62bc4baSyz int rv = RCM_SUCCESS;
613d62bc4baSyz
614d62bc4baSyz rcm_log_message(RCM_TRACE1, "VLAN: notify_event(%s)\n", rsrc);
615d62bc4baSyz
616d62bc4baSyz if (strcmp(rsrc, RCM_RESOURCE_LINK_NEW) != 0) {
617d62bc4baSyz vlan_log_err(DATALINK_INVALID_LINKID, errorp,
618d62bc4baSyz "unrecognized event");
619d62bc4baSyz errno = EINVAL;
620d62bc4baSyz return (RCM_FAILURE);
621d62bc4baSyz }
622d62bc4baSyz
623d62bc4baSyz /* Update cache to reflect latest VLANs */
624d62bc4baSyz if (cache_update(hd) < 0) {
625d62bc4baSyz vlan_log_err(DATALINK_INVALID_LINKID, errorp,
626d62bc4baSyz "private Cache update failed");
627d62bc4baSyz return (RCM_FAILURE);
628d62bc4baSyz }
629d62bc4baSyz
630d62bc4baSyz /*
631d62bc4baSyz * Try best to recover all configuration.
632d62bc4baSyz */
633d62bc4baSyz rcm_log_message(RCM_DEBUG, "VLAN: process_nvlist\n");
634d62bc4baSyz while ((nvp = nvlist_next_nvpair(nvl, nvp)) != NULL) {
635d62bc4baSyz if (strcmp(nvpair_name(nvp), RCM_NV_LINKID) != 0)
636d62bc4baSyz continue;
637d62bc4baSyz
638d62bc4baSyz if (nvpair_value_uint64(nvp, &id64) != 0) {
639d62bc4baSyz vlan_log_err(DATALINK_INVALID_LINKID, errorp,
640d62bc4baSyz "cannot get linkid");
641d62bc4baSyz rv = RCM_FAILURE;
642d62bc4baSyz continue;
643d62bc4baSyz }
644d62bc4baSyz
645d62bc4baSyz linkid = (datalink_id_t)id64;
646d62bc4baSyz if (vlan_configure(hd, linkid) != 0) {
647d62bc4baSyz vlan_log_err(linkid, errorp, "configuring failed");
648d62bc4baSyz rv = RCM_FAILURE;
649d62bc4baSyz continue;
650d62bc4baSyz }
651d62bc4baSyz
652d62bc4baSyz /* Notify all VLAN consumers */
653d62bc4baSyz if (vlan_consumer_notify(hd, linkid, errorp, flags,
654d62bc4baSyz info) != 0) {
655d62bc4baSyz vlan_log_err(linkid, errorp, "consumer notify failed");
656d62bc4baSyz rv = RCM_FAILURE;
657d62bc4baSyz }
658d62bc4baSyz }
659d62bc4baSyz
660d62bc4baSyz rcm_log_message(RCM_TRACE1,
661d62bc4baSyz "VLAN: notify_event: link configuration complete\n");
662d62bc4baSyz return (rv);
663d62bc4baSyz }
664d62bc4baSyz
665d62bc4baSyz /*
666d62bc4baSyz * vlan_usage - Determine the usage of a link.
667d62bc4baSyz * The returned buffer is owned by caller, and the caller
668d62bc4baSyz * must free it up when done.
669d62bc4baSyz */
670d62bc4baSyz static char *
vlan_usage(link_cache_t * node)671d62bc4baSyz vlan_usage(link_cache_t *node)
672d62bc4baSyz {
673d62bc4baSyz dl_vlan_t *vlan;
674d62bc4baSyz int nvlan;
675d62bc4baSyz char *buf;
676d62bc4baSyz const char *fmt;
677d62bc4baSyz char *sep;
678d62bc4baSyz char errmsg[DLADM_STRSIZE];
679d62bc4baSyz char name[MAXLINKNAMELEN];
680d62bc4baSyz dladm_status_t status;
681d62bc4baSyz size_t bufsz;
682d62bc4baSyz
683d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: usage(%s)\n", node->vc_resource);
684d62bc4baSyz
685d62bc4baSyz assert(MUTEX_HELD(&cache_lock));
6864ac67f02SAnurag S. Maskey if ((status = dladm_datalink_id2info(dld_handle, node->vc_linkid, NULL,
6874ac67f02SAnurag S. Maskey NULL, NULL, name, sizeof (name))) != DLADM_STATUS_OK) {
688d62bc4baSyz rcm_log_message(RCM_ERROR,
689d62bc4baSyz _("VLAN: usage(%s) get link name failure(%s)\n"),
690d62bc4baSyz node->vc_resource, dladm_status2str(status, errmsg));
691d62bc4baSyz return (NULL);
692d62bc4baSyz }
693d62bc4baSyz
694d62bc4baSyz if (node->vc_state & CACHE_NODE_OFFLINED)
695d62bc4baSyz fmt = _("%1$s offlined");
696d62bc4baSyz else
697d62bc4baSyz fmt = _("%1$s VLANs: ");
698d62bc4baSyz
699d62bc4baSyz /* TRANSLATION_NOTE: separator used between VLAN linkids */
700d62bc4baSyz sep = _(", ");
701d62bc4baSyz
702d62bc4baSyz nvlan = 0;
703d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = vlan->dv_next)
704d62bc4baSyz nvlan++;
705d62bc4baSyz
706d62bc4baSyz /* space for VLANs and separators, plus message */
707d62bc4baSyz bufsz = nvlan * (MAXLINKNAMELEN + strlen(sep)) +
708d62bc4baSyz strlen(fmt) + MAXLINKNAMELEN + 1;
709d62bc4baSyz if ((buf = malloc(bufsz)) == NULL) {
710d62bc4baSyz rcm_log_message(RCM_ERROR,
711d62bc4baSyz _("VLAN: usage(%s) malloc failure(%s)\n"),
712d62bc4baSyz node->vc_resource, strerror(errno));
713d62bc4baSyz return (NULL);
714d62bc4baSyz }
715d62bc4baSyz (void) snprintf(buf, bufsz, fmt, name);
716d62bc4baSyz
717d62bc4baSyz if (node->vc_state & CACHE_NODE_OFFLINED) {
718d62bc4baSyz /* Nothing else to do */
719d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: usage (%s) info = %s\n",
720d62bc4baSyz node->vc_resource, buf);
721d62bc4baSyz return (buf);
722d62bc4baSyz }
723d62bc4baSyz
724d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = vlan->dv_next) {
725d62bc4baSyz rcm_log_message(RCM_DEBUG, "VLAN:= %u\n", vlan->dv_vlanid);
726d62bc4baSyz
7274ac67f02SAnurag S. Maskey if ((status = dladm_datalink_id2info(dld_handle,
7284ac67f02SAnurag S. Maskey vlan->dv_vlanid, NULL, NULL, NULL, name,
7294ac67f02SAnurag S. Maskey sizeof (name))) != DLADM_STATUS_OK) {
730d62bc4baSyz rcm_log_message(RCM_ERROR,
731d62bc4baSyz _("VLAN: usage(%s) get vlan %u name failure(%s)\n"),
732d62bc4baSyz node->vc_resource, vlan->dv_vlanid,
733d62bc4baSyz dladm_status2str(status, errmsg));
734d62bc4baSyz free(buf);
735d62bc4baSyz return (NULL);
736d62bc4baSyz }
737d62bc4baSyz
738d62bc4baSyz (void) strlcat(buf, name, bufsz);
739d62bc4baSyz if (vlan->dv_next != NULL)
740d62bc4baSyz (void) strlcat(buf, sep, bufsz);
741d62bc4baSyz }
742d62bc4baSyz
743d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: usage (%s) info = %s\n",
744d62bc4baSyz node->vc_resource, buf);
745d62bc4baSyz
746d62bc4baSyz return (buf);
747d62bc4baSyz }
748d62bc4baSyz
749d62bc4baSyz /*
750d62bc4baSyz * Cache management routines, all cache management functions should be
751d62bc4baSyz * be called with cache_lock held.
752d62bc4baSyz */
753d62bc4baSyz
754d62bc4baSyz /*
755d62bc4baSyz * cache_lookup() - Get a cache node for a resource.
756d62bc4baSyz * Call with cache lock held.
757d62bc4baSyz *
758d62bc4baSyz * This ensures that the cache is consistent with the system state and
759d62bc4baSyz * returns a pointer to the cache element corresponding to the resource.
760d62bc4baSyz */
761d62bc4baSyz static link_cache_t *
cache_lookup(rcm_handle_t * hd,char * rsrc,char options)762d62bc4baSyz cache_lookup(rcm_handle_t *hd, char *rsrc, char options)
763d62bc4baSyz {
764d62bc4baSyz link_cache_t *node;
765d62bc4baSyz
766d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: cache lookup(%s)\n", rsrc);
767d62bc4baSyz
768d62bc4baSyz assert(MUTEX_HELD(&cache_lock));
769d62bc4baSyz if (options & CACHE_REFRESH) {
770d62bc4baSyz /* drop lock since update locks cache again */
771d62bc4baSyz (void) mutex_unlock(&cache_lock);
772d62bc4baSyz (void) cache_update(hd);
773d62bc4baSyz (void) mutex_lock(&cache_lock);
774d62bc4baSyz }
775d62bc4baSyz
776d62bc4baSyz node = cache_head.vc_next;
777d62bc4baSyz for (; node != &cache_tail; node = node->vc_next) {
778d62bc4baSyz if (strcmp(rsrc, node->vc_resource) == 0) {
779d62bc4baSyz rcm_log_message(RCM_TRACE2,
780d62bc4baSyz "VLAN: cache lookup succeeded(%s)\n", rsrc);
781d62bc4baSyz return (node);
782d62bc4baSyz }
783d62bc4baSyz }
784d62bc4baSyz return (NULL);
785d62bc4baSyz }
786d62bc4baSyz
787d62bc4baSyz /*
788d62bc4baSyz * node_free - Free a node from the cache
789d62bc4baSyz */
790d62bc4baSyz static void
node_free(link_cache_t * node)791d62bc4baSyz node_free(link_cache_t *node)
792d62bc4baSyz {
793d62bc4baSyz dl_vlan_t *vlan, *next;
794d62bc4baSyz
795d62bc4baSyz if (node != NULL) {
796d62bc4baSyz free(node->vc_resource);
797d62bc4baSyz
798d62bc4baSyz /* free the VLAN list */
799d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = next) {
800d62bc4baSyz next = vlan->dv_next;
801d62bc4baSyz free(vlan);
802d62bc4baSyz }
803d62bc4baSyz free(node);
804d62bc4baSyz }
805d62bc4baSyz }
806d62bc4baSyz
807d62bc4baSyz /*
808d62bc4baSyz * cache_insert - Insert a resource node in cache
809d62bc4baSyz */
810d62bc4baSyz static void
cache_insert(link_cache_t * node)811d62bc4baSyz cache_insert(link_cache_t *node)
812d62bc4baSyz {
813d62bc4baSyz assert(MUTEX_HELD(&cache_lock));
814d62bc4baSyz
815d62bc4baSyz /* insert at the head for best performance */
816d62bc4baSyz node->vc_next = cache_head.vc_next;
817d62bc4baSyz node->vc_prev = &cache_head;
818d62bc4baSyz
819d62bc4baSyz node->vc_next->vc_prev = node;
820d62bc4baSyz node->vc_prev->vc_next = node;
821d62bc4baSyz }
822d62bc4baSyz
823d62bc4baSyz /*
824d62bc4baSyz * cache_remove() - Remove a resource node from cache.
825d62bc4baSyz */
826d62bc4baSyz static void
cache_remove(link_cache_t * node)827d62bc4baSyz cache_remove(link_cache_t *node)
828d62bc4baSyz {
829d62bc4baSyz assert(MUTEX_HELD(&cache_lock));
830d62bc4baSyz node->vc_next->vc_prev = node->vc_prev;
831d62bc4baSyz node->vc_prev->vc_next = node->vc_next;
832d62bc4baSyz node->vc_next = NULL;
833d62bc4baSyz node->vc_prev = NULL;
834d62bc4baSyz }
835d62bc4baSyz
836d62bc4baSyz typedef struct vlan_update_arg_s {
837d62bc4baSyz rcm_handle_t *hd;
838d62bc4baSyz int retval;
839d62bc4baSyz } vlan_update_arg_t;
840d62bc4baSyz
841d62bc4baSyz /*
842d62bc4baSyz * vlan_update() - Update physical interface properties
843d62bc4baSyz */
844d62bc4baSyz static int
vlan_update(dladm_handle_t handle,datalink_id_t vlanid,void * arg)8454ac67f02SAnurag S. Maskey vlan_update(dladm_handle_t handle, datalink_id_t vlanid, void *arg)
846d62bc4baSyz {
847d62bc4baSyz vlan_update_arg_t *vlan_update_argp = arg;
848d62bc4baSyz rcm_handle_t *hd = vlan_update_argp->hd;
849d62bc4baSyz link_cache_t *node;
850d62bc4baSyz dl_vlan_t *vlan;
851d62bc4baSyz char *rsrc;
852d62bc4baSyz dladm_vlan_attr_t vlan_attr;
853d62bc4baSyz dladm_status_t status;
854d62bc4baSyz char errmsg[DLADM_STRSIZE];
85544e79163Syz boolean_t newnode = B_FALSE;
856d62bc4baSyz int ret = -1;
857d62bc4baSyz
858d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_update(%u)\n", vlanid);
859d62bc4baSyz
860d62bc4baSyz assert(MUTEX_HELD(&cache_lock));
8614ac67f02SAnurag S. Maskey status = dladm_vlan_info(handle, vlanid, &vlan_attr, DLADM_OPT_ACTIVE);
862d62bc4baSyz if (status != DLADM_STATUS_OK) {
863d62bc4baSyz rcm_log_message(RCM_TRACE1,
864d62bc4baSyz "VLAN: vlan_update() cannot get vlan information for "
865d62bc4baSyz "%u(%s)\n", vlanid, dladm_status2str(status, errmsg));
866d62bc4baSyz return (DLADM_WALK_CONTINUE);
867d62bc4baSyz }
868d62bc4baSyz
869d62bc4baSyz rsrc = malloc(RCM_LINK_RESOURCE_MAX);
870d62bc4baSyz if (rsrc == NULL) {
871d62bc4baSyz rcm_log_message(RCM_ERROR, _("VLAN: malloc error(%s): %u\n"),
872d62bc4baSyz strerror(errno), vlanid);
873d62bc4baSyz goto done;
874d62bc4baSyz }
875d62bc4baSyz
876d62bc4baSyz (void) snprintf(rsrc, RCM_LINK_RESOURCE_MAX, "%s/%u",
877d62bc4baSyz RCM_LINK_PREFIX, vlan_attr.dv_linkid);
878d62bc4baSyz
879d62bc4baSyz node = cache_lookup(hd, rsrc, CACHE_NO_REFRESH);
880d62bc4baSyz if (node != NULL) {
881d62bc4baSyz rcm_log_message(RCM_DEBUG,
882d62bc4baSyz "VLAN: %s already registered (vlanid:%d)\n",
883d62bc4baSyz rsrc, vlan_attr.dv_vid);
884d62bc4baSyz free(rsrc);
885d62bc4baSyz } else {
886d62bc4baSyz rcm_log_message(RCM_DEBUG,
887d62bc4baSyz "VLAN: %s is a new resource (vlanid:%d)\n",
888d62bc4baSyz rsrc, vlan_attr.dv_vid);
889d62bc4baSyz if ((node = calloc(1, sizeof (link_cache_t))) == NULL) {
890d62bc4baSyz free(rsrc);
891d62bc4baSyz rcm_log_message(RCM_ERROR, _("VLAN: calloc: %s\n"),
892d62bc4baSyz strerror(errno));
893d62bc4baSyz goto done;
894d62bc4baSyz }
895d62bc4baSyz
896d62bc4baSyz node->vc_resource = rsrc;
897d62bc4baSyz node->vc_vlan = NULL;
898d62bc4baSyz node->vc_linkid = vlan_attr.dv_linkid;
899d62bc4baSyz node->vc_state |= CACHE_NODE_NEW;
90044e79163Syz newnode = B_TRUE;
901d62bc4baSyz }
902d62bc4baSyz
903d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = vlan->dv_next) {
904d62bc4baSyz if (vlan->dv_vlanid == vlanid) {
905d62bc4baSyz vlan->dv_flags &= ~VLAN_STALE;
906d62bc4baSyz break;
907d62bc4baSyz }
908d62bc4baSyz }
909d62bc4baSyz
910d62bc4baSyz if (vlan == NULL) {
911d62bc4baSyz if ((vlan = calloc(1, sizeof (dl_vlan_t))) == NULL) {
912d62bc4baSyz rcm_log_message(RCM_ERROR, _("VLAN: malloc: %s\n"),
913d62bc4baSyz strerror(errno));
91444e79163Syz if (newnode) {
915d62bc4baSyz free(rsrc);
916d62bc4baSyz free(node);
917d62bc4baSyz }
918d62bc4baSyz goto done;
919d62bc4baSyz }
920d62bc4baSyz vlan->dv_vlanid = vlanid;
921d62bc4baSyz vlan->dv_next = node->vc_vlan;
922d62bc4baSyz vlan->dv_prev = NULL;
923d62bc4baSyz if (node->vc_vlan != NULL)
924d62bc4baSyz node->vc_vlan->dv_prev = vlan;
925d62bc4baSyz node->vc_vlan = vlan;
926d62bc4baSyz }
927d62bc4baSyz
928d62bc4baSyz node->vc_state &= ~CACHE_NODE_STALE;
929d62bc4baSyz
93044e79163Syz if (newnode)
931d62bc4baSyz cache_insert(node);
932d62bc4baSyz
933d62bc4baSyz rcm_log_message(RCM_TRACE3, "VLAN: vlan_update: succeeded(%u)\n",
934d62bc4baSyz vlanid);
935d62bc4baSyz ret = 0;
936d62bc4baSyz done:
937d62bc4baSyz vlan_update_argp->retval = ret;
938d62bc4baSyz return (ret == 0 ? DLADM_WALK_CONTINUE : DLADM_WALK_TERMINATE);
939d62bc4baSyz }
940d62bc4baSyz
941d62bc4baSyz /*
942d62bc4baSyz * vlan_update_all() - Determine all VLAN links in the system
943d62bc4baSyz */
944d62bc4baSyz static int
vlan_update_all(rcm_handle_t * hd)945d62bc4baSyz vlan_update_all(rcm_handle_t *hd)
946d62bc4baSyz {
947d62bc4baSyz vlan_update_arg_t arg = {NULL, 0};
948d62bc4baSyz
949d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_update_all\n");
950d62bc4baSyz
951d62bc4baSyz assert(MUTEX_HELD(&cache_lock));
952d62bc4baSyz arg.hd = hd;
9534ac67f02SAnurag S. Maskey (void) dladm_walk_datalink_id(vlan_update, dld_handle, &arg,
9544ac67f02SAnurag S. Maskey DATALINK_CLASS_VLAN, DATALINK_ANY_MEDIATYPE, DLADM_OPT_ACTIVE);
955d62bc4baSyz return (arg.retval);
956d62bc4baSyz }
957d62bc4baSyz
958d62bc4baSyz /*
959d62bc4baSyz * cache_update() - Update cache with latest interface info
960d62bc4baSyz */
961d62bc4baSyz static int
cache_update(rcm_handle_t * hd)962d62bc4baSyz cache_update(rcm_handle_t *hd)
963d62bc4baSyz {
964d62bc4baSyz link_cache_t *node, *nnode;
965d62bc4baSyz dl_vlan_t *vlan;
966d62bc4baSyz int rv;
967d62bc4baSyz
968d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: cache_update\n");
969d62bc4baSyz
970d62bc4baSyz (void) mutex_lock(&cache_lock);
971d62bc4baSyz
972d62bc4baSyz /* first we walk the entire cache, marking each entry stale */
973d62bc4baSyz node = cache_head.vc_next;
974d62bc4baSyz for (; node != &cache_tail; node = node->vc_next) {
975d62bc4baSyz node->vc_state |= CACHE_NODE_STALE;
976d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = vlan->dv_next)
977d62bc4baSyz vlan->dv_flags |= VLAN_STALE;
978d62bc4baSyz }
979d62bc4baSyz
980d62bc4baSyz rv = vlan_update_all(hd);
981d62bc4baSyz
982d62bc4baSyz /*
983d62bc4baSyz * Continue to delete all stale nodes from the cache even
984d62bc4baSyz * vlan_update_all() failed. Unregister link that are not offlined
985d62bc4baSyz * and still in cache
986d62bc4baSyz */
987d62bc4baSyz for (node = cache_head.vc_next; node != &cache_tail; node = nnode) {
988d62bc4baSyz dl_vlan_t *vlan, *next;
989d62bc4baSyz
990d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = next) {
991d62bc4baSyz next = vlan->dv_next;
992d62bc4baSyz
993d62bc4baSyz /* clear stale VLANs */
994d62bc4baSyz if (vlan->dv_flags & VLAN_STALE) {
995d62bc4baSyz if (vlan->dv_prev != NULL)
996d62bc4baSyz vlan->dv_prev->dv_next = next;
997d62bc4baSyz else
998d62bc4baSyz node->vc_vlan = next;
999d62bc4baSyz
1000d62bc4baSyz if (next != NULL)
1001d62bc4baSyz next->dv_prev = vlan->dv_prev;
1002d62bc4baSyz free(vlan);
1003d62bc4baSyz }
1004d62bc4baSyz }
1005d62bc4baSyz
1006d62bc4baSyz nnode = node->vc_next;
1007d62bc4baSyz if (node->vc_state & CACHE_NODE_STALE) {
1008d62bc4baSyz (void) rcm_unregister_interest(hd, node->vc_resource,
1009d62bc4baSyz 0);
1010d62bc4baSyz rcm_log_message(RCM_DEBUG, "VLAN: unregistered %s\n",
1011d62bc4baSyz node->vc_resource);
1012d62bc4baSyz assert(node->vc_vlan == NULL);
1013d62bc4baSyz cache_remove(node);
1014d62bc4baSyz node_free(node);
1015d62bc4baSyz continue;
1016d62bc4baSyz }
1017d62bc4baSyz
1018d62bc4baSyz if (!(node->vc_state & CACHE_NODE_NEW))
1019d62bc4baSyz continue;
1020d62bc4baSyz
1021d62bc4baSyz if (rcm_register_interest(hd, node->vc_resource, 0, NULL) !=
1022d62bc4baSyz RCM_SUCCESS) {
1023d62bc4baSyz rcm_log_message(RCM_ERROR,
1024d62bc4baSyz _("VLAN: failed to register %s\n"),
1025d62bc4baSyz node->vc_resource);
1026d62bc4baSyz rv = -1;
1027d62bc4baSyz } else {
1028d62bc4baSyz rcm_log_message(RCM_DEBUG, "VLAN: registered %s\n",
1029d62bc4baSyz node->vc_resource);
1030d62bc4baSyz node->vc_state &= ~CACHE_NODE_NEW;
1031d62bc4baSyz }
1032d62bc4baSyz }
1033d62bc4baSyz
1034d62bc4baSyz (void) mutex_unlock(&cache_lock);
1035d62bc4baSyz return (rv);
1036d62bc4baSyz }
1037d62bc4baSyz
1038d62bc4baSyz /*
1039d62bc4baSyz * cache_free() - Empty the cache
1040d62bc4baSyz */
1041d62bc4baSyz static void
cache_free()1042d62bc4baSyz cache_free()
1043d62bc4baSyz {
1044d62bc4baSyz link_cache_t *node;
1045d62bc4baSyz
1046d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: cache_free\n");
1047d62bc4baSyz
1048d62bc4baSyz (void) mutex_lock(&cache_lock);
1049d62bc4baSyz node = cache_head.vc_next;
1050d62bc4baSyz while (node != &cache_tail) {
1051d62bc4baSyz cache_remove(node);
1052d62bc4baSyz node_free(node);
1053d62bc4baSyz node = cache_head.vc_next;
1054d62bc4baSyz }
1055d62bc4baSyz (void) mutex_unlock(&cache_lock);
1056d62bc4baSyz }
1057d62bc4baSyz
1058d62bc4baSyz /*
1059d62bc4baSyz * vlan_log_err() - RCM error log wrapper
1060d62bc4baSyz */
1061d62bc4baSyz static void
vlan_log_err(datalink_id_t linkid,char ** errorp,char * errmsg)1062d62bc4baSyz vlan_log_err(datalink_id_t linkid, char **errorp, char *errmsg)
1063d62bc4baSyz {
1064d62bc4baSyz char link[MAXLINKNAMELEN];
1065d62bc4baSyz char errstr[DLADM_STRSIZE];
1066d62bc4baSyz dladm_status_t status;
1067d62bc4baSyz int len;
1068d62bc4baSyz const char *errfmt;
1069d62bc4baSyz char *error;
1070d62bc4baSyz
1071d62bc4baSyz link[0] = '\0';
1072d62bc4baSyz if (linkid != DATALINK_INVALID_LINKID) {
1073d62bc4baSyz char rsrc[RCM_LINK_RESOURCE_MAX];
1074d62bc4baSyz
1075d62bc4baSyz (void) snprintf(rsrc, sizeof (rsrc), "%s/%u",
1076d62bc4baSyz RCM_LINK_PREFIX, linkid);
1077d62bc4baSyz
1078d62bc4baSyz rcm_log_message(RCM_ERROR, _("VLAN: %s(%s)\n"), errmsg, rsrc);
10794ac67f02SAnurag S. Maskey if ((status = dladm_datalink_id2info(dld_handle, linkid, NULL,
10804ac67f02SAnurag S. Maskey NULL, NULL, link, sizeof (link))) != DLADM_STATUS_OK) {
1081d62bc4baSyz rcm_log_message(RCM_WARNING,
1082d62bc4baSyz _("VLAN: cannot get link name for (%s) %s\n"),
1083d62bc4baSyz rsrc, dladm_status2str(status, errstr));
1084d62bc4baSyz }
1085d62bc4baSyz } else {
1086d62bc4baSyz rcm_log_message(RCM_ERROR, _("VLAN: %s\n"), errmsg);
1087d62bc4baSyz }
1088d62bc4baSyz
1089d62bc4baSyz errfmt = strlen(link) > 0 ? _("VLAN: %s(%s)") : _("VLAN: %s");
1090d62bc4baSyz len = strlen(errfmt) + strlen(errmsg) + MAXLINKNAMELEN + 1;
1091d62bc4baSyz if ((error = malloc(len)) != NULL) {
1092d62bc4baSyz if (strlen(link) > 0)
1093d62bc4baSyz (void) snprintf(error, len, errfmt, errmsg, link);
1094d62bc4baSyz else
1095d62bc4baSyz (void) snprintf(error, len, errfmt, errmsg);
1096d62bc4baSyz }
1097d62bc4baSyz
1098d62bc4baSyz if (errorp != NULL)
1099d62bc4baSyz *errorp = error;
1100d62bc4baSyz }
1101d62bc4baSyz
1102d62bc4baSyz /*
1103d62bc4baSyz * vlan_consumer_online()
1104d62bc4baSyz *
1105d62bc4baSyz * Notify online to VLAN consumers.
1106d62bc4baSyz */
1107d62bc4baSyz /* ARGSUSED */
1108d62bc4baSyz static void
vlan_consumer_online(rcm_handle_t * hd,link_cache_t * node,char ** errorp,uint_t flags,rcm_info_t ** info)1109d62bc4baSyz vlan_consumer_online(rcm_handle_t *hd, link_cache_t *node, char **errorp,
1110d62bc4baSyz uint_t flags, rcm_info_t **info)
1111d62bc4baSyz {
1112d62bc4baSyz dl_vlan_t *vlan;
1113d62bc4baSyz char rsrc[RCM_LINK_RESOURCE_MAX];
1114d62bc4baSyz
1115d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_consumer_online (%s)\n",
1116d62bc4baSyz node->vc_resource);
1117d62bc4baSyz
1118d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = vlan->dv_next) {
1119d62bc4baSyz if (!(vlan->dv_flags & VLAN_CONSUMER_OFFLINED))
1120d62bc4baSyz continue;
1121d62bc4baSyz
1122d62bc4baSyz (void) snprintf(rsrc, RCM_LINK_RESOURCE_MAX, "%s/%u",
1123d62bc4baSyz RCM_LINK_PREFIX, vlan->dv_vlanid);
1124d62bc4baSyz
1125d62bc4baSyz if (rcm_notify_online(hd, rsrc, flags, info) == RCM_SUCCESS)
1126d62bc4baSyz vlan->dv_flags &= ~VLAN_CONSUMER_OFFLINED;
1127d62bc4baSyz }
1128d62bc4baSyz
1129d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_consumer_online done\n");
1130d62bc4baSyz }
1131d62bc4baSyz
1132d62bc4baSyz /*
1133d62bc4baSyz * vlan_consumer_offline()
1134d62bc4baSyz *
1135d62bc4baSyz * Offline VLAN consumers.
1136d62bc4baSyz */
1137d62bc4baSyz static int
vlan_consumer_offline(rcm_handle_t * hd,link_cache_t * node,char ** errorp,uint_t flags,rcm_info_t ** info)1138d62bc4baSyz vlan_consumer_offline(rcm_handle_t *hd, link_cache_t *node, char **errorp,
1139d62bc4baSyz uint_t flags, rcm_info_t **info)
1140d62bc4baSyz {
1141d62bc4baSyz dl_vlan_t *vlan;
1142d62bc4baSyz char rsrc[RCM_LINK_RESOURCE_MAX];
1143d62bc4baSyz int ret = RCM_SUCCESS;
1144d62bc4baSyz
1145d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_consumer_offline (%s)\n",
1146d62bc4baSyz node->vc_resource);
1147d62bc4baSyz
1148d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = vlan->dv_next) {
1149d62bc4baSyz (void) snprintf(rsrc, RCM_LINK_RESOURCE_MAX, "%s/%u",
1150d62bc4baSyz RCM_LINK_PREFIX, vlan->dv_vlanid);
1151d62bc4baSyz
1152d62bc4baSyz ret = rcm_request_offline(hd, rsrc, flags, info);
1153d62bc4baSyz if (ret != RCM_SUCCESS)
1154d62bc4baSyz break;
1155d62bc4baSyz
1156d62bc4baSyz vlan->dv_flags |= VLAN_CONSUMER_OFFLINED;
1157d62bc4baSyz }
1158d62bc4baSyz
1159d62bc4baSyz if (vlan != NULL)
1160d62bc4baSyz vlan_consumer_online(hd, node, errorp, flags, info);
1161d62bc4baSyz
1162d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_consumer_offline done\n");
1163d62bc4baSyz return (ret);
1164d62bc4baSyz }
1165d62bc4baSyz
1166d62bc4baSyz /*
1167d62bc4baSyz * Send RCM_RESOURCE_LINK_NEW events to other modules about new VLANs.
1168d62bc4baSyz * Return 0 on success, -1 on failure.
1169d62bc4baSyz */
1170d62bc4baSyz static int
vlan_notify_new_vlan(rcm_handle_t * hd,char * rsrc)1171d62bc4baSyz vlan_notify_new_vlan(rcm_handle_t *hd, char *rsrc)
1172d62bc4baSyz {
1173d62bc4baSyz link_cache_t *node;
1174d62bc4baSyz dl_vlan_t *vlan;
1175d62bc4baSyz nvlist_t *nvl = NULL;
1176d62bc4baSyz uint64_t id;
1177d62bc4baSyz int ret = -1;
1178d62bc4baSyz
1179d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_notify_new_vlan (%s)\n", rsrc);
1180d62bc4baSyz
1181d62bc4baSyz (void) mutex_lock(&cache_lock);
1182d62bc4baSyz if ((node = cache_lookup(hd, rsrc, CACHE_REFRESH)) == NULL) {
1183d62bc4baSyz (void) mutex_unlock(&cache_lock);
1184d62bc4baSyz return (0);
1185d62bc4baSyz }
1186d62bc4baSyz
1187d62bc4baSyz if (nvlist_alloc(&nvl, 0, 0) != 0) {
1188d62bc4baSyz (void) mutex_unlock(&cache_lock);
1189d62bc4baSyz rcm_log_message(RCM_WARNING,
1190d62bc4baSyz _("VLAN: failed to allocate nvlist\n"));
1191d62bc4baSyz goto done;
1192d62bc4baSyz }
1193d62bc4baSyz
1194d62bc4baSyz for (vlan = node->vc_vlan; vlan != NULL; vlan = vlan->dv_next) {
1195da14cebeSEric Cheng rcm_log_message(RCM_TRACE2,
1196da14cebeSEric Cheng "VLAN: vlan_notify_new_vlan add (%u)\n",
1197da14cebeSEric Cheng vlan->dv_vlanid);
1198d62bc4baSyz
1199da14cebeSEric Cheng id = vlan->dv_vlanid;
1200da14cebeSEric Cheng if (nvlist_add_uint64(nvl, RCM_NV_LINKID, id) != 0) {
1201da14cebeSEric Cheng rcm_log_message(RCM_ERROR,
1202da14cebeSEric Cheng _("VLAN: failed to construct nvlist\n"));
1203da14cebeSEric Cheng (void) mutex_unlock(&cache_lock);
1204da14cebeSEric Cheng goto done;
1205d62bc4baSyz }
1206d62bc4baSyz }
1207d62bc4baSyz (void) mutex_unlock(&cache_lock);
1208d62bc4baSyz
1209d62bc4baSyz if (rcm_notify_event(hd, RCM_RESOURCE_LINK_NEW, 0, nvl, NULL) !=
1210d62bc4baSyz RCM_SUCCESS) {
1211d62bc4baSyz rcm_log_message(RCM_ERROR,
1212d62bc4baSyz _("VLAN: failed to notify %s event for %s\n"),
1213d62bc4baSyz RCM_RESOURCE_LINK_NEW, node->vc_resource);
1214d62bc4baSyz goto done;
1215d62bc4baSyz }
1216d62bc4baSyz
1217d62bc4baSyz ret = 0;
1218d62bc4baSyz done:
1219*aab83bb8SJosef 'Jeff' Sipek nvlist_free(nvl);
1220d62bc4baSyz return (ret);
1221d62bc4baSyz }
1222d62bc4baSyz
1223d62bc4baSyz /*
1224d62bc4baSyz * vlan_consumer_notify() - Notify consumers of VLANs coming back online.
1225d62bc4baSyz */
1226d62bc4baSyz static int
vlan_consumer_notify(rcm_handle_t * hd,datalink_id_t linkid,char ** errorp,uint_t flags,rcm_info_t ** info)1227d62bc4baSyz vlan_consumer_notify(rcm_handle_t *hd, datalink_id_t linkid, char **errorp,
1228d62bc4baSyz uint_t flags, rcm_info_t **info)
1229d62bc4baSyz {
1230d62bc4baSyz char rsrc[RCM_LINK_RESOURCE_MAX];
1231d62bc4baSyz link_cache_t *node;
1232d62bc4baSyz
1233d62bc4baSyz /* Check for the interface in the cache */
1234d62bc4baSyz (void) snprintf(rsrc, RCM_LINK_RESOURCE_MAX, "%s/%u", RCM_LINK_PREFIX,
1235d62bc4baSyz linkid);
1236d62bc4baSyz
1237d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_consumer_notify(%s)\n", rsrc);
1238d62bc4baSyz
1239d62bc4baSyz /*
1240d62bc4baSyz * Inform IP consumers of the new link.
1241d62bc4baSyz */
1242d62bc4baSyz if (vlan_notify_new_vlan(hd, rsrc) != 0) {
1243d62bc4baSyz (void) mutex_lock(&cache_lock);
1244d62bc4baSyz if ((node = cache_lookup(hd, rsrc, CACHE_NO_REFRESH)) != NULL) {
1245d62bc4baSyz (void) vlan_offline_vlan(node, VLAN_STALE,
1246d62bc4baSyz CACHE_NODE_STALE);
1247d62bc4baSyz }
1248d62bc4baSyz (void) mutex_unlock(&cache_lock);
1249d62bc4baSyz rcm_log_message(RCM_TRACE2,
1250d62bc4baSyz "VLAN: vlan_notify_new_vlan failed(%s)\n", rsrc);
1251d62bc4baSyz return (-1);
1252d62bc4baSyz }
1253d62bc4baSyz
1254d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_consumer_notify succeeded\n");
1255d62bc4baSyz return (0);
1256d62bc4baSyz }
1257d62bc4baSyz
1258d62bc4baSyz typedef struct vlan_up_arg_s {
1259d62bc4baSyz datalink_id_t linkid;
1260d62bc4baSyz int retval;
1261d62bc4baSyz } vlan_up_arg_t;
1262d62bc4baSyz
1263d62bc4baSyz static int
vlan_up(dladm_handle_t handle,datalink_id_t vlanid,void * arg)12644ac67f02SAnurag S. Maskey vlan_up(dladm_handle_t handle, datalink_id_t vlanid, void *arg)
1265d62bc4baSyz {
1266d62bc4baSyz vlan_up_arg_t *vlan_up_argp = arg;
1267d62bc4baSyz dladm_status_t status;
1268d62bc4baSyz dladm_vlan_attr_t vlan_attr;
1269d62bc4baSyz char errmsg[DLADM_STRSIZE];
1270d62bc4baSyz
12714ac67f02SAnurag S. Maskey status = dladm_vlan_info(handle, vlanid, &vlan_attr, DLADM_OPT_PERSIST);
1272d62bc4baSyz if (status != DLADM_STATUS_OK) {
1273d62bc4baSyz rcm_log_message(RCM_TRACE1,
1274d62bc4baSyz "VLAN: vlan_up(): cannot get information for VLAN %u "
1275d62bc4baSyz "(%s)\n", vlanid, dladm_status2str(status, errmsg));
1276d62bc4baSyz return (DLADM_WALK_CONTINUE);
1277d62bc4baSyz }
1278d62bc4baSyz
1279d62bc4baSyz if (vlan_attr.dv_linkid != vlan_up_argp->linkid)
1280d62bc4baSyz return (DLADM_WALK_CONTINUE);
1281d62bc4baSyz
1282d62bc4baSyz rcm_log_message(RCM_TRACE3, "VLAN: vlan_up(%u)\n", vlanid);
12834ac67f02SAnurag S. Maskey if ((status = dladm_vlan_up(handle, vlanid)) == DLADM_STATUS_OK)
1284d62bc4baSyz return (DLADM_WALK_CONTINUE);
1285d62bc4baSyz
1286d62bc4baSyz /*
1287d62bc4baSyz * Prompt the warning message and continue to UP other VLANs.
1288d62bc4baSyz */
1289d62bc4baSyz rcm_log_message(RCM_WARNING,
1290d62bc4baSyz _("VLAN: VLAN up failed (%u): %s\n"),
1291d62bc4baSyz vlanid, dladm_status2str(status, errmsg));
1292d62bc4baSyz
1293d62bc4baSyz vlan_up_argp->retval = -1;
1294d62bc4baSyz return (DLADM_WALK_CONTINUE);
1295d62bc4baSyz }
1296d62bc4baSyz
1297d62bc4baSyz /*
1298d62bc4baSyz * vlan_configure() - Configure VLANs over a physical link after it attaches
1299d62bc4baSyz */
1300d62bc4baSyz static int
vlan_configure(rcm_handle_t * hd,datalink_id_t linkid)1301d62bc4baSyz vlan_configure(rcm_handle_t *hd, datalink_id_t linkid)
1302d62bc4baSyz {
1303d62bc4baSyz char rsrc[RCM_LINK_RESOURCE_MAX];
1304d62bc4baSyz link_cache_t *node;
1305d62bc4baSyz vlan_up_arg_t arg = {DATALINK_INVALID_LINKID, 0};
1306d62bc4baSyz
1307d62bc4baSyz /* Check for the VLANs in the cache */
1308d62bc4baSyz (void) snprintf(rsrc, sizeof (rsrc), "%s/%u", RCM_LINK_PREFIX, linkid);
1309d62bc4baSyz
1310d62bc4baSyz rcm_log_message(RCM_TRACE2, "VLAN: vlan_configure(%s)\n", rsrc);
1311d62bc4baSyz
1312d62bc4baSyz /* Check if the link is new or was previously offlined */
1313d62bc4baSyz (void) mutex_lock(&cache_lock);
1314d62bc4baSyz if (((node = cache_lookup(hd, rsrc, CACHE_REFRESH)) != NULL) &&
1315d62bc4baSyz (!(node->vc_state & CACHE_NODE_OFFLINED))) {
1316d62bc4baSyz rcm_log_message(RCM_TRACE2,
1317d62bc4baSyz "VLAN: Skipping configured interface(%s)\n", rsrc);
1318d62bc4baSyz (void) mutex_unlock(&cache_lock);
1319d62bc4baSyz return (0);
1320d62bc4baSyz }
1321d62bc4baSyz (void) mutex_unlock(&cache_lock);
1322d62bc4baSyz
1323d62bc4baSyz arg.linkid = linkid;
13244ac67f02SAnurag S. Maskey (void) dladm_walk_datalink_id(vlan_up, dld_handle, &arg,
13254ac67f02SAnurag S. Maskey DATALINK_CLASS_VLAN, DATALINK_ANY_MEDIATYPE, DLADM_OPT_PERSIST);
1326d62bc4baSyz
1327d62bc4baSyz if (arg.retval == 0) {
1328d62bc4baSyz rcm_log_message(RCM_TRACE2,
1329d62bc4baSyz "VLAN: vlan_configure succeeded(%s)\n", rsrc);
1330d62bc4baSyz }
1331d62bc4baSyz return (arg.retval);
1332d62bc4baSyz }
1333