1749f21d3Swesolows /*
2749f21d3Swesolows * CDDL HEADER START
3749f21d3Swesolows *
4749f21d3Swesolows * The contents of this file are subject to the terms of the
5749f21d3Swesolows * Common Development and Distribution License (the "License").
6749f21d3Swesolows * You may not use this file except in compliance with the License.
7749f21d3Swesolows *
8749f21d3Swesolows * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9749f21d3Swesolows * or http://www.opensolaris.org/os/licensing.
10749f21d3Swesolows * See the License for the specific language governing permissions
11749f21d3Swesolows * and limitations under the License.
12749f21d3Swesolows *
13749f21d3Swesolows * When distributing Covered Code, include this CDDL HEADER in each
14749f21d3Swesolows * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15749f21d3Swesolows * If applicable, add the following below this CDDL HEADER, with the
16749f21d3Swesolows * fields enclosed by brackets "[]" replaced with your own identifying
17749f21d3Swesolows * information: Portions Copyright [yyyy] [name of copyright owner]
18749f21d3Swesolows *
19749f21d3Swesolows * CDDL HEADER END
20749f21d3Swesolows */
21749f21d3Swesolows
22749f21d3Swesolows /*
23888e0559SRobert Johnston * Copyright 2009 Sun Microsystems, Inc. All rights reserved.
24749f21d3Swesolows * Use is subject to license terms.
25749f21d3Swesolows */
26749f21d3Swesolows
27749f21d3Swesolows #include <sys/fm/protocol.h>
28749f21d3Swesolows #include <fm/fmd_adm.h>
29749f21d3Swesolows #include <fm/fmd_snmp.h>
30749f21d3Swesolows #include <net-snmp/net-snmp-config.h>
31749f21d3Swesolows #include <net-snmp/net-snmp-includes.h>
32749f21d3Swesolows #include <net-snmp/agent/net-snmp-agent-includes.h>
33749f21d3Swesolows #include <pthread.h>
34749f21d3Swesolows #include <stddef.h>
35749f21d3Swesolows #include <errno.h>
36749f21d3Swesolows #include <alloca.h>
37749f21d3Swesolows #include <locale.h>
38749f21d3Swesolows #include <libuutil.h>
39749f21d3Swesolows #include <libnvpair.h>
40749f21d3Swesolows #include "sunFM_impl.h"
41749f21d3Swesolows #include "problem.h"
42749f21d3Swesolows
43749f21d3Swesolows /*
44749f21d3Swesolows * We assume that the number of suspect fault events associated with a
45749f21d3Swesolows * particular case will generally be sufficiently small that the overhead
46749f21d3Swesolows * associated with indexing them in a tree would exceed the gain from
47749f21d3Swesolows * not traversing the fault list for each request.
48749f21d3Swesolows */
49749f21d3Swesolows static uu_avl_pool_t *problem_uuid_avl_pool;
50749f21d3Swesolows static uu_avl_t *problem_uuid_avl;
51749f21d3Swesolows
52749f21d3Swesolows #define VALID_AVL_STATE (problem_uuid_avl_pool != NULL && \
53749f21d3Swesolows problem_uuid_avl != NULL)
54749f21d3Swesolows
55749f21d3Swesolows #define UPDATE_WAIT_MILLIS 10 /* poll interval in milliseconds */
56749f21d3Swesolows
57749f21d3Swesolows /*
58749f21d3Swesolows * Update types. Single-index and all are mutually exclusive.
59749f21d3Swesolows */
60749f21d3Swesolows #define UCT_INDEX 0x1
61749f21d3Swesolows #define UCT_ALL 0x2
62749f21d3Swesolows #define UCT_FLAGS 0x3
63749f21d3Swesolows
64749f21d3Swesolows /*
65749f21d3Swesolows * Locking strategy is described in module.c.
66749f21d3Swesolows */
67749f21d3Swesolows static int valid_stamp;
68749f21d3Swesolows static pthread_mutex_t update_lock;
69749f21d3Swesolows static pthread_cond_t update_cv;
70749f21d3Swesolows static volatile enum { US_QUIET, US_NEEDED, US_INPROGRESS } update_status;
71749f21d3Swesolows
72749f21d3Swesolows static Netsnmp_Node_Handler sunFmProblemTable_handler;
73749f21d3Swesolows static Netsnmp_Node_Handler sunFmFaultEventTable_handler;
74749f21d3Swesolows
75749f21d3Swesolows static sunFmProblem_data_t *
problem_key_build(const char * uuid)76749f21d3Swesolows problem_key_build(const char *uuid)
77749f21d3Swesolows {
78749f21d3Swesolows static sunFmProblem_data_t key;
79749f21d3Swesolows
80749f21d3Swesolows key.d_aci_uuid = uuid;
81749f21d3Swesolows
82749f21d3Swesolows return (&key);
83749f21d3Swesolows }
84749f21d3Swesolows
85749f21d3Swesolows static sunFmProblem_data_t *
problem_lookup_uuid_exact(const char * uuid)86749f21d3Swesolows problem_lookup_uuid_exact(const char *uuid)
87749f21d3Swesolows {
88749f21d3Swesolows sunFmProblem_data_t *key, *data;
89749f21d3Swesolows
90749f21d3Swesolows key = problem_key_build(uuid);
91749f21d3Swesolows
92749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "lookup_exact for uuid %s\n", uuid));
93749f21d3Swesolows data = uu_avl_find(problem_uuid_avl, key, NULL, NULL);
94749f21d3Swesolows
95749f21d3Swesolows return (data);
96749f21d3Swesolows }
97749f21d3Swesolows
98749f21d3Swesolows static sunFmProblem_data_t *
problem_lookup_uuid_next(const char * uuid)99749f21d3Swesolows problem_lookup_uuid_next(const char *uuid)
100749f21d3Swesolows {
101749f21d3Swesolows sunFmProblem_data_t *key, *data;
102749f21d3Swesolows uu_avl_index_t idx;
103749f21d3Swesolows
104749f21d3Swesolows key = problem_key_build(uuid);
105749f21d3Swesolows
106749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "lookup_next for uuid %s\n", uuid));
107749f21d3Swesolows (void) uu_avl_find(problem_uuid_avl, key, NULL, &idx);
108749f21d3Swesolows
109749f21d3Swesolows data = uu_avl_nearest_next(problem_uuid_avl, idx);
110749f21d3Swesolows
111749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "lookup_next: entry is %p\n", data));
112749f21d3Swesolows
113749f21d3Swesolows return (data);
114749f21d3Swesolows }
115749f21d3Swesolows
116749f21d3Swesolows static sunFmFaultEvent_data_t *
faultevent_lookup_index_exact(sunFmProblem_data_t * data,ulong_t index)117749f21d3Swesolows faultevent_lookup_index_exact(sunFmProblem_data_t *data, ulong_t index)
118749f21d3Swesolows {
119749f21d3Swesolows if (index > data->d_nsuspects)
120749f21d3Swesolows return (NULL);
121749f21d3Swesolows
122749f21d3Swesolows if (data->d_suspects == NULL)
123749f21d3Swesolows return (NULL);
124749f21d3Swesolows
125749f21d3Swesolows return (data->d_suspects[index - 1]);
126749f21d3Swesolows }
127749f21d3Swesolows
12825c6ff4bSstephh static sunFmFaultStatus_data_t
faultstatus_lookup_index_exact(sunFmProblem_data_t * data,ulong_t index)12925c6ff4bSstephh faultstatus_lookup_index_exact(sunFmProblem_data_t *data, ulong_t index)
13025c6ff4bSstephh {
13125c6ff4bSstephh if (index > data->d_nsuspects)
1322d2a5225Sstephh return (0);
13325c6ff4bSstephh
13425c6ff4bSstephh if (data->d_statuses == NULL)
1352d2a5225Sstephh return (0);
1362d2a5225Sstephh
1372d2a5225Sstephh if (data->d_valid != valid_stamp)
1382d2a5225Sstephh return (0);
13925c6ff4bSstephh
14025c6ff4bSstephh return (data->d_statuses[index - 1]);
14125c6ff4bSstephh }
14225c6ff4bSstephh
14330698f33Swesolows /*ARGSUSED*/
144749f21d3Swesolows static int
problem_update_one(const fmd_adm_caseinfo_t * acp,void * arg)145749f21d3Swesolows problem_update_one(const fmd_adm_caseinfo_t *acp, void *arg)
146749f21d3Swesolows {
147749f21d3Swesolows sunFmProblem_data_t *data;
148749f21d3Swesolows nvlist_t *nvl;
149749f21d3Swesolows int64_t *diag_time;
150749f21d3Swesolows uint_t nelem;
151749f21d3Swesolows uint32_t nsusp;
152749f21d3Swesolows int err;
153749f21d3Swesolows
154749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "update_one\n"));
155749f21d3Swesolows
156749f21d3Swesolows ASSERT(acp->aci_uuid != NULL);
157749f21d3Swesolows
158749f21d3Swesolows if ((data = problem_lookup_uuid_exact(acp->aci_uuid)) == NULL) {
159749f21d3Swesolows uu_avl_index_t idx;
160749f21d3Swesolows
161749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "found new problem %s\n",
162749f21d3Swesolows acp->aci_uuid));
163749f21d3Swesolows if ((data = SNMP_MALLOC_TYPEDEF(sunFmProblem_data_t)) == NULL) {
164888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": Out of memory "
165888e0559SRobert Johnston "for new problem data at %s:%d\n", __FILE__,
166888e0559SRobert Johnston __LINE__);
167749f21d3Swesolows return (0);
168749f21d3Swesolows }
169749f21d3Swesolows if ((err = nvlist_dup(acp->aci_event, &data->d_aci_event, 0))
170749f21d3Swesolows != 0) {
171888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": Problem data "
172888e0559SRobert Johnston "setup failed: %s\n", strerror(err));
173749f21d3Swesolows SNMP_FREE(data);
174749f21d3Swesolows return (0);
175749f21d3Swesolows }
176749f21d3Swesolows
177749f21d3Swesolows data->d_aci_uuid = data->d_aci_code = data->d_aci_url = "-";
178749f21d3Swesolows (void) nvlist_lookup_string(data->d_aci_event, FM_SUSPECT_UUID,
179749f21d3Swesolows (char **)&data->d_aci_uuid);
180749f21d3Swesolows (void) nvlist_lookup_string(data->d_aci_event,
181749f21d3Swesolows FM_SUSPECT_DIAG_CODE, (char **)&data->d_aci_code);
182749f21d3Swesolows data->d_aci_url = strdup(acp->aci_url);
183749f21d3Swesolows
184749f21d3Swesolows if (nvlist_lookup_nvlist(data->d_aci_event, FM_SUSPECT_DE,
185749f21d3Swesolows &nvl) == 0)
186749f21d3Swesolows if ((data->d_diag_engine = sunFm_nvl2str(nvl)) == NULL)
187749f21d3Swesolows data->d_diag_engine = "-";
188749f21d3Swesolows
189749f21d3Swesolows if (nvlist_lookup_int64_array(data->d_aci_event,
190749f21d3Swesolows FM_SUSPECT_DIAG_TIME, &diag_time, &nelem) == 0 &&
191749f21d3Swesolows nelem >= 2) {
192749f21d3Swesolows data->d_diag_time.tv_sec = (long)diag_time[0];
193749f21d3Swesolows data->d_diag_time.tv_usec = (long)diag_time[1];
194749f21d3Swesolows }
195749f21d3Swesolows
196749f21d3Swesolows (void) nvlist_lookup_uint32(data->d_aci_event,
197749f21d3Swesolows FM_SUSPECT_FAULT_SZ, &nsusp);
198749f21d3Swesolows data->d_nsuspects = (ulong_t)nsusp;
199749f21d3Swesolows
200749f21d3Swesolows (void) nvlist_lookup_nvlist_array(data->d_aci_event,
201749f21d3Swesolows FM_SUSPECT_FAULT_LIST, &data->d_suspects, &nelem);
202749f21d3Swesolows
203749f21d3Swesolows ASSERT(nelem == data->d_nsuspects);
204749f21d3Swesolows
20525c6ff4bSstephh (void) nvlist_lookup_uint8_array(data->d_aci_event,
20625c6ff4bSstephh FM_SUSPECT_FAULT_STATUS, &data->d_statuses, &nelem);
20725c6ff4bSstephh
20825c6ff4bSstephh ASSERT(nelem == data->d_nsuspects);
20925c6ff4bSstephh
210749f21d3Swesolows uu_avl_node_init(data, &data->d_uuid_avl,
211749f21d3Swesolows problem_uuid_avl_pool);
212749f21d3Swesolows (void) uu_avl_find(problem_uuid_avl, data, NULL, &idx);
213749f21d3Swesolows uu_avl_insert(problem_uuid_avl, data, idx);
214749f21d3Swesolows
215749f21d3Swesolows data->d_valid = valid_stamp;
216749f21d3Swesolows
217749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "completed new problem %s@%p\n",
218749f21d3Swesolows data->d_aci_uuid, data));
2192d2a5225Sstephh } else {
2202d2a5225Sstephh uint8_t *statuses;
2212d2a5225Sstephh int i;
2222d2a5225Sstephh
2232d2a5225Sstephh (void) nvlist_lookup_uint8_array(acp->aci_event,
2242d2a5225Sstephh FM_SUSPECT_FAULT_STATUS, &statuses, &nelem);
2252d2a5225Sstephh
2262d2a5225Sstephh ASSERT(nelem == data->d_nsuspects);
2272d2a5225Sstephh
2282d2a5225Sstephh for (i = 0; i < nelem; i++)
2292d2a5225Sstephh data->d_statuses[i] = statuses[i];
2302d2a5225Sstephh
2312d2a5225Sstephh data->d_valid = valid_stamp;
232749f21d3Swesolows }
233749f21d3Swesolows
234749f21d3Swesolows /*
235749f21d3Swesolows * We don't touch problems we've seen before; they shouldn't change
236749f21d3Swesolows * in any way we care about, since they've already been solved. The
237749f21d3Swesolows * state, however, could change, and if we later expose that to the
238749f21d3Swesolows * client we need to update it here.
239749f21d3Swesolows */
240749f21d3Swesolows
241749f21d3Swesolows return (0);
242749f21d3Swesolows }
243749f21d3Swesolows
244749f21d3Swesolows static int
problem_update(sunFmProblem_update_ctx_t * update_ctx)245749f21d3Swesolows problem_update(sunFmProblem_update_ctx_t *update_ctx)
246749f21d3Swesolows {
247749f21d3Swesolows fmd_adm_t *adm;
248749f21d3Swesolows
249749f21d3Swesolows ASSERT(update_ctx != NULL);
250749f21d3Swesolows ASSERT((update_ctx->uc_type & (UCT_INDEX|UCT_ALL)) !=
251749f21d3Swesolows (UCT_INDEX|UCT_ALL));
252749f21d3Swesolows ASSERT((update_ctx->uc_type & ~UCT_FLAGS) == 0);
253749f21d3Swesolows ASSERT(VALID_AVL_STATE);
254749f21d3Swesolows
255749f21d3Swesolows if ((adm = fmd_adm_open(update_ctx->uc_host, update_ctx->uc_prog,
256749f21d3Swesolows update_ctx->uc_version)) == NULL) {
257888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": Communication with fmd "
258749f21d3Swesolows "failed: %s\n", strerror(errno));
259749f21d3Swesolows return (SNMP_ERR_RESOURCEUNAVAILABLE);
260749f21d3Swesolows }
261749f21d3Swesolows
262749f21d3Swesolows ++valid_stamp;
263749f21d3Swesolows if (fmd_adm_case_iter(adm, SNMP_URL_MSG, problem_update_one,
264749f21d3Swesolows update_ctx) != 0) {
265888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": fmd case information "
266888e0559SRobert Johnston "update failed: %s\n", fmd_adm_errmsg(adm));
267749f21d3Swesolows fmd_adm_close(adm);
268749f21d3Swesolows return (SNMP_ERR_RESOURCEUNAVAILABLE);
269749f21d3Swesolows }
270749f21d3Swesolows
271749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "case iteration completed\n"));
272749f21d3Swesolows
273749f21d3Swesolows fmd_adm_close(adm);
274749f21d3Swesolows return (SNMP_ERR_NOERROR);
275749f21d3Swesolows }
276749f21d3Swesolows
277*1743a90dSToomas Soome __NORETURN static void *
update_thread(void * arg __unused)278*1743a90dSToomas Soome update_thread(void *arg __unused)
279749f21d3Swesolows {
280749f21d3Swesolows /*
281749f21d3Swesolows * The current problem_update implementation offers minimal savings
282749f21d3Swesolows * for the use of index-only updates; therefore we always do a full
283749f21d3Swesolows * update. If it becomes advantageous to limit updates to a single
284749f21d3Swesolows * index, the contexts can be queued by the handler instead.
285749f21d3Swesolows */
286749f21d3Swesolows sunFmProblem_update_ctx_t uc;
287749f21d3Swesolows
288749f21d3Swesolows uc.uc_host = NULL;
289749f21d3Swesolows uc.uc_prog = FMD_ADM_PROGRAM;
290749f21d3Swesolows uc.uc_version = FMD_ADM_VERSION;
291749f21d3Swesolows
292749f21d3Swesolows uc.uc_index = NULL;
293749f21d3Swesolows uc.uc_type = UCT_ALL;
294749f21d3Swesolows
295749f21d3Swesolows for (;;) {
296749f21d3Swesolows (void) pthread_mutex_lock(&update_lock);
297749f21d3Swesolows update_status = US_QUIET;
298749f21d3Swesolows while (update_status == US_QUIET)
299749f21d3Swesolows (void) pthread_cond_wait(&update_cv, &update_lock);
300749f21d3Swesolows update_status = US_INPROGRESS;
301749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
302749f21d3Swesolows (void) problem_update(&uc);
303749f21d3Swesolows }
304749f21d3Swesolows }
305749f21d3Swesolows
306749f21d3Swesolows static void
request_update(void)307749f21d3Swesolows request_update(void)
308749f21d3Swesolows {
309749f21d3Swesolows (void) pthread_mutex_lock(&update_lock);
310749f21d3Swesolows if (update_status != US_QUIET) {
311749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
312749f21d3Swesolows return;
313749f21d3Swesolows }
314749f21d3Swesolows update_status = US_NEEDED;
315749f21d3Swesolows (void) pthread_cond_signal(&update_cv);
316749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
317749f21d3Swesolows }
318749f21d3Swesolows
319749f21d3Swesolows /*ARGSUSED*/
320749f21d3Swesolows static int
problem_compare_uuid(const void * l,const void * r,void * private)321749f21d3Swesolows problem_compare_uuid(const void *l, const void *r, void *private)
322749f21d3Swesolows {
323749f21d3Swesolows sunFmProblem_data_t *l_data = (sunFmProblem_data_t *)l;
324749f21d3Swesolows sunFmProblem_data_t *r_data = (sunFmProblem_data_t *)r;
325749f21d3Swesolows
326749f21d3Swesolows ASSERT(l_data != NULL && r_data != NULL);
327749f21d3Swesolows
328749f21d3Swesolows return (strcmp(l_data->d_aci_uuid, r_data->d_aci_uuid));
329749f21d3Swesolows }
330749f21d3Swesolows
331749f21d3Swesolows int
sunFmProblemTable_init(void)332749f21d3Swesolows sunFmProblemTable_init(void)
333749f21d3Swesolows {
334749f21d3Swesolows static oid sunFmProblemTable_oid[] = { SUNFMPROBLEMTABLE_OID };
335749f21d3Swesolows netsnmp_table_registration_info *table_info;
336749f21d3Swesolows netsnmp_handler_registration *handler;
337749f21d3Swesolows int err;
338749f21d3Swesolows
339749f21d3Swesolows if ((err = pthread_mutex_init(&update_lock, NULL)) != 0) {
340888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": mutex_init failure: "
341888e0559SRobert Johnston "%s\n", strerror(err));
342749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
343749f21d3Swesolows }
344749f21d3Swesolows if ((err = pthread_cond_init(&update_cv, NULL)) != 0) {
345888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": cond_init failure: "
346888e0559SRobert Johnston "%s\n", strerror(err));
347749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
348749f21d3Swesolows }
349749f21d3Swesolows
350*1743a90dSToomas Soome if ((err = pthread_create(NULL, NULL, update_thread, NULL)) != 0) {
351888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": error creating update "
352749f21d3Swesolows "thread: %s\n", strerror(err));
353749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
354749f21d3Swesolows }
355749f21d3Swesolows
356749f21d3Swesolows if ((table_info =
357749f21d3Swesolows SNMP_MALLOC_TYPEDEF(netsnmp_table_registration_info)) == NULL)
358749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
359749f21d3Swesolows
360749f21d3Swesolows if ((handler = netsnmp_create_handler_registration("sunFmProblemTable",
361749f21d3Swesolows sunFmProblemTable_handler, sunFmProblemTable_oid,
362749f21d3Swesolows OID_LENGTH(sunFmProblemTable_oid), HANDLER_CAN_RONLY)) == NULL) {
363749f21d3Swesolows SNMP_FREE(table_info);
364749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
365749f21d3Swesolows }
366749f21d3Swesolows
367749f21d3Swesolows /*
368749f21d3Swesolows * The Net-SNMP template uses add_indexes here, but that
369749f21d3Swesolows * function is unsafe because it does not check for failure.
370749f21d3Swesolows */
371749f21d3Swesolows if (netsnmp_table_helper_add_index(table_info, ASN_OCTET_STR) == NULL) {
372749f21d3Swesolows SNMP_FREE(table_info);
373749f21d3Swesolows SNMP_FREE(handler);
374749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
375749f21d3Swesolows }
376749f21d3Swesolows
377749f21d3Swesolows table_info->min_column = SUNFMPROBLEM_COLMIN;
378749f21d3Swesolows table_info->max_column = SUNFMPROBLEM_COLMAX;
379749f21d3Swesolows
380749f21d3Swesolows if ((problem_uuid_avl_pool = uu_avl_pool_create("problem_uuid",
381749f21d3Swesolows sizeof (sunFmProblem_data_t),
382749f21d3Swesolows offsetof(sunFmProblem_data_t, d_uuid_avl), problem_compare_uuid,
383749f21d3Swesolows UU_AVL_DEBUG)) == NULL) {
384888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": problem_uuid avl pool "
385749f21d3Swesolows "creation failed: %s\n", uu_strerror(uu_error()));
386749f21d3Swesolows snmp_free_varbind(table_info->indexes);
387749f21d3Swesolows SNMP_FREE(table_info);
388749f21d3Swesolows SNMP_FREE(handler);
389749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
390749f21d3Swesolows }
391749f21d3Swesolows
392749f21d3Swesolows if ((problem_uuid_avl = uu_avl_create(problem_uuid_avl_pool, NULL,
393749f21d3Swesolows UU_AVL_DEBUG)) == NULL) {
394888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": problem_uuid avl "
395888e0559SRobert Johnston "creation failed: %s\n", uu_strerror(uu_error()));
396749f21d3Swesolows snmp_free_varbind(table_info->indexes);
397749f21d3Swesolows SNMP_FREE(table_info);
398749f21d3Swesolows SNMP_FREE(handler);
399749f21d3Swesolows uu_avl_pool_destroy(problem_uuid_avl_pool);
400749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
401749f21d3Swesolows }
402749f21d3Swesolows
403749f21d3Swesolows if ((err = netsnmp_register_table(handler, table_info)) !=
404749f21d3Swesolows MIB_REGISTERED_OK) {
405749f21d3Swesolows snmp_free_varbind(table_info->indexes);
406749f21d3Swesolows SNMP_FREE(table_info);
407749f21d3Swesolows SNMP_FREE(handler);
408749f21d3Swesolows uu_avl_destroy(problem_uuid_avl);
409749f21d3Swesolows uu_avl_pool_destroy(problem_uuid_avl_pool);
410749f21d3Swesolows return (err);
411749f21d3Swesolows }
412749f21d3Swesolows
413749f21d3Swesolows return (MIB_REGISTERED_OK);
414749f21d3Swesolows }
415749f21d3Swesolows
416749f21d3Swesolows int
sunFmFaultEventTable_init(void)417749f21d3Swesolows sunFmFaultEventTable_init(void)
418749f21d3Swesolows {
419749f21d3Swesolows static oid sunFmFaultEventTable_oid[] = { SUNFMFAULTEVENTTABLE_OID };
420749f21d3Swesolows netsnmp_table_registration_info *table_info;
421749f21d3Swesolows netsnmp_handler_registration *handler;
422749f21d3Swesolows int err;
423749f21d3Swesolows
424749f21d3Swesolows if ((table_info =
425749f21d3Swesolows SNMP_MALLOC_TYPEDEF(netsnmp_table_registration_info)) == NULL)
426749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
427749f21d3Swesolows
428749f21d3Swesolows if ((handler =
429749f21d3Swesolows netsnmp_create_handler_registration("sunFmFaultEventTable",
430749f21d3Swesolows sunFmFaultEventTable_handler, sunFmFaultEventTable_oid,
431749f21d3Swesolows OID_LENGTH(sunFmFaultEventTable_oid), HANDLER_CAN_RONLY)) == NULL) {
432749f21d3Swesolows SNMP_FREE(table_info);
433749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
434749f21d3Swesolows }
435749f21d3Swesolows
436749f21d3Swesolows /*
437749f21d3Swesolows * The Net-SNMP template uses add_indexes here, but that
438749f21d3Swesolows * function is unsafe because it does not check for failure.
439749f21d3Swesolows */
440749f21d3Swesolows if (netsnmp_table_helper_add_index(table_info, ASN_OCTET_STR) == NULL) {
441749f21d3Swesolows SNMP_FREE(table_info);
442749f21d3Swesolows SNMP_FREE(handler);
443749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
444749f21d3Swesolows }
445749f21d3Swesolows if (netsnmp_table_helper_add_index(table_info, ASN_UNSIGNED) == NULL) {
446749f21d3Swesolows snmp_free_varbind(table_info->indexes);
447749f21d3Swesolows SNMP_FREE(table_info);
448749f21d3Swesolows SNMP_FREE(handler);
449749f21d3Swesolows return (MIB_REGISTRATION_FAILED);
450749f21d3Swesolows }
451749f21d3Swesolows
452749f21d3Swesolows table_info->min_column = SUNFMFAULTEVENT_COLMIN;
453749f21d3Swesolows table_info->max_column = SUNFMFAULTEVENT_COLMAX;
454749f21d3Swesolows
455749f21d3Swesolows if ((err = netsnmp_register_table(handler, table_info)) !=
456749f21d3Swesolows MIB_REGISTERED_OK) {
457749f21d3Swesolows snmp_free_varbind(table_info->indexes);
458749f21d3Swesolows SNMP_FREE(table_info);
459749f21d3Swesolows SNMP_FREE(handler);
460749f21d3Swesolows return (err);
461749f21d3Swesolows }
462749f21d3Swesolows
463749f21d3Swesolows return (MIB_REGISTERED_OK);
464749f21d3Swesolows }
465749f21d3Swesolows
466749f21d3Swesolows /*
467749f21d3Swesolows * Returns the problem data for the problem whose uuid is next according
468749f21d3Swesolows * to ASN.1 lexical ordering after the request in table_info. Indexes are
469749f21d3Swesolows * updated to reflect the OID of the value being returned. This allows
470749f21d3Swesolows * us to implement GETNEXT.
471749f21d3Swesolows */
472749f21d3Swesolows static sunFmProblem_data_t *
sunFmProblemTable_nextpr(netsnmp_handler_registration * reginfo,netsnmp_table_request_info * table_info)473749f21d3Swesolows sunFmProblemTable_nextpr(netsnmp_handler_registration *reginfo,
474749f21d3Swesolows netsnmp_table_request_info *table_info)
475749f21d3Swesolows {
476749f21d3Swesolows sunFmProblem_data_t *data;
477749f21d3Swesolows char *uuid = "";
478749f21d3Swesolows
479749f21d3Swesolows if (table_info->number_indexes < 1) {
480749f21d3Swesolows oid tmpoid[MAX_OID_LEN];
481749f21d3Swesolows
482749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "nextpr: no indexes given\n"));
483749f21d3Swesolows
48430698f33Swesolows snmp_free_varbind(table_info->indexes);
485749f21d3Swesolows table_info->indexes =
486749f21d3Swesolows SNMP_MALLOC_TYPEDEF(netsnmp_variable_list);
487888e0559SRobert Johnston (void) snmp_set_var_typed_value(table_info->indexes,
488888e0559SRobert Johnston ASN_OCTET_STR, (const uchar_t *)uuid, 0);
48930698f33Swesolows (void) memcpy(tmpoid, reginfo->rootoid,
490749f21d3Swesolows reginfo->rootoid_len * sizeof (oid));
491749f21d3Swesolows tmpoid[reginfo->rootoid_len] = 1;
492749f21d3Swesolows tmpoid[reginfo->rootoid_len + 1] = table_info->colnum;
493749f21d3Swesolows if (build_oid_segment(table_info->indexes) != SNMPERR_SUCCESS) {
494749f21d3Swesolows snmp_free_varbind(table_info->indexes);
495749f21d3Swesolows return (NULL);
496749f21d3Swesolows }
497749f21d3Swesolows table_info->number_indexes = 1;
498749f21d3Swesolows table_info->index_oid_len = table_info->indexes->name_length;
49930698f33Swesolows (void) memcpy(table_info->index_oid, table_info->indexes->name,
500749f21d3Swesolows table_info->indexes->name_length);
501749f21d3Swesolows
502749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "nextpr: built fake index:\n"));
503749f21d3Swesolows DEBUGMSGVAR((MODNAME_STR, table_info->indexes));
504749f21d3Swesolows DEBUGMSG((MODNAME_STR, "\n"));
505749f21d3Swesolows } else {
506749f21d3Swesolows /*
507749f21d3Swesolows * Construct the next possible UUID to look for. We can
508749f21d3Swesolows * simply increment the least significant byte of the last
509749f21d3Swesolows * UUID because (a) that preserves SNMP lex order and (b)
510749f21d3Swesolows * the characters that may appear in a UUID do not include
511749f21d3Swesolows * 127 nor 255.
512749f21d3Swesolows */
513749f21d3Swesolows uuid = alloca(table_info->indexes->val_len + 1);
514749f21d3Swesolows (void) strlcpy(uuid,
515749f21d3Swesolows (const char *)table_info->indexes->val.string,
516749f21d3Swesolows table_info->indexes->val_len + 1);
517749f21d3Swesolows ++uuid[table_info->indexes->val_len - 1];
518749f21d3Swesolows
519749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "nextpr: received index:\n"));
520749f21d3Swesolows DEBUGMSGVAR((MODNAME_STR, table_info->indexes));
521749f21d3Swesolows DEBUGMSG((MODNAME_STR, "\n"));
522749f21d3Swesolows }
523749f21d3Swesolows
524749f21d3Swesolows if ((data = problem_lookup_uuid_next(uuid)) == NULL) {
525749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "nextpr: next match not found for "
526749f21d3Swesolows "%s; trying next column\n", uuid));
52730698f33Swesolows if (table_info->colnum >=
52830698f33Swesolows netsnmp_find_table_registration_info(reginfo)->max_column) {
529749f21d3Swesolows snmp_free_varbind(table_info->indexes);
530749f21d3Swesolows table_info->indexes = NULL;
531749f21d3Swesolows table_info->number_indexes = 0;
532749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "nextpr: out of columns\n"));
533749f21d3Swesolows return (NULL);
534749f21d3Swesolows }
535749f21d3Swesolows table_info->colnum++;
536749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "nextpr: search for col %u empty "
53754575832SDan McDonald "uuid\n", table_info->colnum));
538749f21d3Swesolows
539749f21d3Swesolows if ((data = problem_lookup_uuid_next("")) == NULL) {
540749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "nextpr: next match not found "
541749f21d3Swesolows "for empty uuid; stopping\n"));
542749f21d3Swesolows snmp_free_varbind(table_info->indexes);
543749f21d3Swesolows table_info->indexes = NULL;
544749f21d3Swesolows table_info->number_indexes = 0;
545749f21d3Swesolows return (NULL);
546749f21d3Swesolows }
547749f21d3Swesolows }
548749f21d3Swesolows
549888e0559SRobert Johnston (void) snmp_set_var_typed_value(table_info->indexes, ASN_OCTET_STR,
550749f21d3Swesolows (uchar_t *)data->d_aci_uuid, strlen(data->d_aci_uuid));
551749f21d3Swesolows table_info->number_indexes = 1;
552749f21d3Swesolows
553749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "matching data is %s@%p\n", data->d_aci_uuid,
554749f21d3Swesolows data));
555749f21d3Swesolows
556749f21d3Swesolows return (data);
557749f21d3Swesolows }
558749f21d3Swesolows
559749f21d3Swesolows /*
560749f21d3Swesolows * Returns the problem data corresponding to the request in table_info.
561749f21d3Swesolows * All request parameters are unmodified.
562749f21d3Swesolows */
56330698f33Swesolows /*ARGSUSED*/
564749f21d3Swesolows static sunFmProblem_data_t *
sunFmProblemTable_pr(netsnmp_handler_registration * reginfo,netsnmp_table_request_info * table_info)565749f21d3Swesolows sunFmProblemTable_pr(netsnmp_handler_registration *reginfo,
566749f21d3Swesolows netsnmp_table_request_info *table_info)
567749f21d3Swesolows {
568749f21d3Swesolows char *uuid;
569749f21d3Swesolows
570749f21d3Swesolows ASSERT(table_info->number_indexes >= 1);
571749f21d3Swesolows
572749f21d3Swesolows uuid = alloca(table_info->indexes->val_len + 1);
573749f21d3Swesolows (void) strlcpy(uuid, (const char *)table_info->indexes->val.string,
574749f21d3Swesolows table_info->indexes->val_len + 1);
575749f21d3Swesolows
576749f21d3Swesolows return (problem_lookup_uuid_exact(uuid));
577749f21d3Swesolows }
578749f21d3Swesolows
579749f21d3Swesolows /*
580749f21d3Swesolows * Returns the ASN.1 lexicographically first fault event after the one
581749f21d3Swesolows * identified by table_info. Indexes are updated to reflect the OID
582749f21d3Swesolows * of the data returned. This allows us to implement GETNEXT.
583749f21d3Swesolows */
584749f21d3Swesolows static sunFmFaultEvent_data_t *
sunFmFaultEventTable_nextfe(netsnmp_handler_registration * reginfo,netsnmp_table_request_info * table_info,sunFmFaultStatus_data_t * statusp)585749f21d3Swesolows sunFmFaultEventTable_nextfe(netsnmp_handler_registration *reginfo,
5862d2a5225Sstephh netsnmp_table_request_info *table_info, sunFmFaultStatus_data_t *statusp)
587749f21d3Swesolows {
588749f21d3Swesolows sunFmProblem_data_t *data;
589749f21d3Swesolows sunFmFaultEvent_data_t *rv;
590749f21d3Swesolows netsnmp_variable_list *var;
591749f21d3Swesolows ulong_t index;
592749f21d3Swesolows
593749f21d3Swesolows for (;;) {
594749f21d3Swesolows switch (table_info->number_indexes) {
595749f21d3Swesolows case 2:
596749f21d3Swesolows default:
597749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "nextfe: 2 indices:\n"));
598749f21d3Swesolows DEBUGMSGVAR((MODNAME_STR, table_info->indexes));
599749f21d3Swesolows DEBUGMSG((MODNAME_STR, "\n"));
600749f21d3Swesolows DEBUGMSGVAR((MODNAME_STR,
601749f21d3Swesolows table_info->indexes->next_variable));
602749f21d3Swesolows DEBUGMSG((MODNAME_STR, "\n"));
603749f21d3Swesolows index = *(ulong_t *)
604749f21d3Swesolows table_info->indexes->next_variable->val.integer + 1;
605749f21d3Swesolows
606749f21d3Swesolows if ((data = sunFmProblemTable_pr(reginfo,
607749f21d3Swesolows table_info)) != NULL &&
6082d2a5225Sstephh (*statusp = faultstatus_lookup_index_exact(data,
6092d2a5225Sstephh index)) != 0 &&
610749f21d3Swesolows (rv = faultevent_lookup_index_exact(data, index)) !=
611749f21d3Swesolows NULL) {
612888e0559SRobert Johnston (void) snmp_set_var_typed_value(
613749f21d3Swesolows table_info->indexes->next_variable,
614749f21d3Swesolows ASN_UNSIGNED, (uchar_t *)&index,
615749f21d3Swesolows sizeof (index));
616749f21d3Swesolows return (rv);
617749f21d3Swesolows }
618749f21d3Swesolows
619749f21d3Swesolows if (sunFmProblemTable_nextpr(reginfo, table_info) ==
620749f21d3Swesolows NULL)
621749f21d3Swesolows return (NULL);
622749f21d3Swesolows break;
623749f21d3Swesolows case 1:
624749f21d3Swesolows if ((data = sunFmProblemTable_pr(reginfo,
625749f21d3Swesolows table_info)) != NULL) {
626749f21d3Swesolows oid tmpoid[MAX_OID_LEN];
627749f21d3Swesolows index = 0;
628749f21d3Swesolows
629749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "nextfe: 1 index:\n"));
630749f21d3Swesolows DEBUGMSGVAR((MODNAME_STR, table_info->indexes));
631749f21d3Swesolows DEBUGMSG((MODNAME_STR, "\n"));
632749f21d3Swesolows var =
633749f21d3Swesolows SNMP_MALLOC_TYPEDEF(netsnmp_variable_list);
634888e0559SRobert Johnston (void) snmp_set_var_typed_value(var,
635888e0559SRobert Johnston ASN_UNSIGNED, (uchar_t *)&index,
636888e0559SRobert Johnston sizeof (index));
63730698f33Swesolows (void) memcpy(tmpoid, reginfo->rootoid,
638749f21d3Swesolows reginfo->rootoid_len * sizeof (oid));
639749f21d3Swesolows tmpoid[reginfo->rootoid_len] = 1;
640749f21d3Swesolows tmpoid[reginfo->rootoid_len + 1] =
641749f21d3Swesolows table_info->colnum;
642749f21d3Swesolows if (build_oid_segment(var) != SNMPERR_SUCCESS) {
643749f21d3Swesolows snmp_free_varbind(var);
644749f21d3Swesolows return (NULL);
645749f21d3Swesolows }
64630698f33Swesolows snmp_free_varbind(
64730698f33Swesolows table_info->indexes->next_variable);
648749f21d3Swesolows table_info->indexes->next_variable = var;
649749f21d3Swesolows table_info->number_indexes = 2;
650749f21d3Swesolows DEBUGMSGTL((MODNAME_STR, "nextfe: built fake "
651749f21d3Swesolows "index:\n"));
652749f21d3Swesolows DEBUGMSGVAR((MODNAME_STR, table_info->indexes));
653749f21d3Swesolows DEBUGMSG((MODNAME_STR, "\n"));
654749f21d3Swesolows DEBUGMSGVAR((MODNAME_STR,
655749f21d3Swesolows table_info->indexes->next_variable));
656749f21d3Swesolows DEBUGMSG((MODNAME_STR, "\n"));
657749f21d3Swesolows } else {
658749f21d3Swesolows if (sunFmProblemTable_nextpr(reginfo,
659749f21d3Swesolows table_info) == NULL)
660749f21d3Swesolows return (NULL);
661749f21d3Swesolows }
662749f21d3Swesolows break;
663749f21d3Swesolows case 0:
664749f21d3Swesolows if (sunFmProblemTable_nextpr(reginfo, table_info) ==
665749f21d3Swesolows NULL)
666749f21d3Swesolows return (NULL);
667749f21d3Swesolows break;
668749f21d3Swesolows }
669749f21d3Swesolows }
670749f21d3Swesolows }
671749f21d3Swesolows
672749f21d3Swesolows static sunFmFaultEvent_data_t *
sunFmFaultEventTable_fe(netsnmp_handler_registration * reginfo,netsnmp_table_request_info * table_info,sunFmFaultStatus_data_t * statusp)673749f21d3Swesolows sunFmFaultEventTable_fe(netsnmp_handler_registration *reginfo,
6742d2a5225Sstephh netsnmp_table_request_info *table_info, sunFmFaultStatus_data_t *statusp)
675749f21d3Swesolows {
676749f21d3Swesolows sunFmProblem_data_t *data;
677749f21d3Swesolows
678749f21d3Swesolows ASSERT(table_info->number_indexes == 2);
679749f21d3Swesolows
680749f21d3Swesolows if ((data = sunFmProblemTable_pr(reginfo, table_info)) == NULL)
681749f21d3Swesolows return (NULL);
682749f21d3Swesolows
6832d2a5225Sstephh *statusp = faultstatus_lookup_index_exact(data,
6842d2a5225Sstephh *(ulong_t *)table_info->indexes->next_variable->val.integer);
6852d2a5225Sstephh if (*statusp == 0)
68625c6ff4bSstephh return (NULL);
6872d2a5225Sstephh return (faultevent_lookup_index_exact(data,
68825c6ff4bSstephh *(ulong_t *)table_info->indexes->next_variable->val.integer));
68925c6ff4bSstephh }
69025c6ff4bSstephh
69130698f33Swesolows /*ARGSUSED*/
692749f21d3Swesolows static void
sunFmProblemTable_return(unsigned int reg,void * arg)693749f21d3Swesolows sunFmProblemTable_return(unsigned int reg, void *arg)
694749f21d3Swesolows {
695749f21d3Swesolows netsnmp_delegated_cache *cache = (netsnmp_delegated_cache *)arg;
696749f21d3Swesolows netsnmp_request_info *request;
697749f21d3Swesolows netsnmp_agent_request_info *reqinfo;
698749f21d3Swesolows netsnmp_handler_registration *reginfo;
699749f21d3Swesolows netsnmp_table_request_info *table_info;
700749f21d3Swesolows sunFmProblem_data_t *data;
701749f21d3Swesolows
702749f21d3Swesolows ASSERT(netsnmp_handler_check_cache(cache) != NULL);
703749f21d3Swesolows
704749f21d3Swesolows (void) pthread_mutex_lock(&update_lock);
705749f21d3Swesolows if (update_status != US_QUIET) {
706749f21d3Swesolows struct timeval tv;
707749f21d3Swesolows
708749f21d3Swesolows tv.tv_sec = UPDATE_WAIT_MILLIS / 1000;
709749f21d3Swesolows tv.tv_usec = (UPDATE_WAIT_MILLIS % 1000) * 1000;
710749f21d3Swesolows
711749f21d3Swesolows (void) snmp_alarm_register_hr(tv, 0, sunFmProblemTable_return,
712749f21d3Swesolows cache);
713749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
714749f21d3Swesolows return;
715749f21d3Swesolows }
716749f21d3Swesolows
717749f21d3Swesolows request = cache->requests;
718749f21d3Swesolows reqinfo = cache->reqinfo;
719749f21d3Swesolows reginfo = cache->reginfo;
720749f21d3Swesolows
721749f21d3Swesolows table_info = netsnmp_extract_table_info(request);
722749f21d3Swesolows request->delegated = 0;
723749f21d3Swesolows
724749f21d3Swesolows ASSERT(table_info->colnum >= SUNFMPROBLEM_COLMIN);
725749f21d3Swesolows ASSERT(table_info->colnum <= SUNFMPROBLEM_COLMAX);
726749f21d3Swesolows
727749f21d3Swesolows /*
728749f21d3Swesolows * table_info->colnum contains the column number requested.
729749f21d3Swesolows * table_info->indexes contains a linked list of snmp variable
730749f21d3Swesolows * bindings for the indexes of the table. Values in the list
731749f21d3Swesolows * have been set corresponding to the indexes of the
732749f21d3Swesolows * request. We have other guarantees as well:
733749f21d3Swesolows *
734749f21d3Swesolows * - The column number is always within range.
735749f21d3Swesolows * - If we have no index data, table_info->index_oid_len is 0.
736749f21d3Swesolows * - We will never receive requests outside our table nor
737749f21d3Swesolows * those with the first subid anything other than 1 (Entry)
738749f21d3Swesolows * nor those without a column number. This is true even
739749f21d3Swesolows * for GETNEXT requests.
740749f21d3Swesolows */
741749f21d3Swesolows
742749f21d3Swesolows switch (reqinfo->mode) {
743749f21d3Swesolows case MODE_GET:
744749f21d3Swesolows if ((data = sunFmProblemTable_pr(reginfo, table_info)) ==
745749f21d3Swesolows NULL) {
746749f21d3Swesolows netsnmp_free_delegated_cache(cache);
747749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
748749f21d3Swesolows return;
749749f21d3Swesolows }
750749f21d3Swesolows break;
751749f21d3Swesolows case MODE_GETNEXT:
752749f21d3Swesolows case MODE_GETBULK:
753749f21d3Swesolows if ((data = sunFmProblemTable_nextpr(reginfo, table_info)) ==
754749f21d3Swesolows NULL) {
755749f21d3Swesolows netsnmp_free_delegated_cache(cache);
756749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
757749f21d3Swesolows return;
758749f21d3Swesolows }
759749f21d3Swesolows break;
760749f21d3Swesolows default:
761888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": Unsupported request "
762888e0559SRobert Johnston "mode %d\n", reqinfo->mode);
763749f21d3Swesolows netsnmp_free_delegated_cache(cache);
764749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
765749f21d3Swesolows return;
766749f21d3Swesolows }
767749f21d3Swesolows
768749f21d3Swesolows switch (table_info->colnum) {
769749f21d3Swesolows case SUNFMPROBLEM_COL_UUID:
770749f21d3Swesolows {
771888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
772749f21d3Swesolows ASN_OCTET_STR, (uchar_t *)data->d_aci_uuid,
773749f21d3Swesolows strlen(data->d_aci_uuid));
774749f21d3Swesolows break;
775749f21d3Swesolows }
776749f21d3Swesolows case SUNFMPROBLEM_COL_CODE:
777749f21d3Swesolows {
778888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
779749f21d3Swesolows ASN_OCTET_STR, (uchar_t *)data->d_aci_code,
780749f21d3Swesolows strlen(data->d_aci_code));
781749f21d3Swesolows break;
782749f21d3Swesolows }
783749f21d3Swesolows case SUNFMPROBLEM_COL_URL:
784749f21d3Swesolows {
785888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
786749f21d3Swesolows ASN_OCTET_STR, (uchar_t *)data->d_aci_url,
787749f21d3Swesolows strlen(data->d_aci_url));
788749f21d3Swesolows break;
789749f21d3Swesolows }
790749f21d3Swesolows case SUNFMPROBLEM_COL_DIAGENGINE:
791749f21d3Swesolows {
792888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
793749f21d3Swesolows ASN_OCTET_STR, (uchar_t *)data->d_diag_engine,
794749f21d3Swesolows strlen(data->d_diag_engine));
795749f21d3Swesolows break;
796749f21d3Swesolows }
797749f21d3Swesolows case SUNFMPROBLEM_COL_DIAGTIME:
798749f21d3Swesolows {
799749f21d3Swesolows /*
800749f21d3Swesolows * The date_n_time function is not Y2038-safe; this may
801749f21d3Swesolows * need to be updated when a suitable Y2038-safe Net-SNMP
802749f21d3Swesolows * API is available.
803749f21d3Swesolows */
804749f21d3Swesolows size_t dt_size;
805749f21d3Swesolows time_t dt_time = (time_t)data->d_diag_time.tv_sec;
806749f21d3Swesolows uchar_t *dt = date_n_time(&dt_time, &dt_size);
807749f21d3Swesolows
808888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
809749f21d3Swesolows ASN_OCTET_STR, dt, dt_size);
810749f21d3Swesolows break;
811749f21d3Swesolows }
812749f21d3Swesolows case SUNFMPROBLEM_COL_SUSPECTCOUNT:
813749f21d3Swesolows {
814888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
815749f21d3Swesolows ASN_UNSIGNED, (uchar_t *)&data->d_nsuspects,
816749f21d3Swesolows sizeof (data->d_nsuspects));
817749f21d3Swesolows break;
818749f21d3Swesolows }
819749f21d3Swesolows default:
820749f21d3Swesolows break;
821749f21d3Swesolows }
822749f21d3Swesolows
823749f21d3Swesolows netsnmp_free_delegated_cache(cache);
824749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
825749f21d3Swesolows }
826749f21d3Swesolows
827749f21d3Swesolows static int
sunFmProblemTable_handler(netsnmp_mib_handler * handler,netsnmp_handler_registration * reginfo,netsnmp_agent_request_info * reqinfo,netsnmp_request_info * requests)828749f21d3Swesolows sunFmProblemTable_handler(netsnmp_mib_handler *handler,
829749f21d3Swesolows netsnmp_handler_registration *reginfo, netsnmp_agent_request_info *reqinfo,
830749f21d3Swesolows netsnmp_request_info *requests)
831749f21d3Swesolows {
832749f21d3Swesolows netsnmp_request_info *request;
833749f21d3Swesolows struct timeval tv;
834749f21d3Swesolows
835749f21d3Swesolows tv.tv_sec = UPDATE_WAIT_MILLIS / 1000;
836749f21d3Swesolows tv.tv_usec = (UPDATE_WAIT_MILLIS % 1000) * 1000;
837749f21d3Swesolows
838749f21d3Swesolows request_update();
839749f21d3Swesolows
840749f21d3Swesolows for (request = requests; request; request = request->next) {
841749f21d3Swesolows if (request->processed != 0)
842749f21d3Swesolows continue;
843749f21d3Swesolows
844749f21d3Swesolows if (netsnmp_extract_table_info(request) == NULL)
845749f21d3Swesolows continue;
846749f21d3Swesolows
847749f21d3Swesolows request->delegated = 1;
848749f21d3Swesolows (void) snmp_alarm_register_hr(tv, 0,
849749f21d3Swesolows sunFmProblemTable_return,
850749f21d3Swesolows (void *) netsnmp_create_delegated_cache(handler, reginfo,
851749f21d3Swesolows reqinfo, request, NULL));
852749f21d3Swesolows }
853749f21d3Swesolows
854749f21d3Swesolows return (SNMP_ERR_NOERROR);
855749f21d3Swesolows }
856749f21d3Swesolows
85730698f33Swesolows /*ARGSUSED*/
858749f21d3Swesolows static void
sunFmFaultEventTable_return(unsigned int reg,void * arg)859749f21d3Swesolows sunFmFaultEventTable_return(unsigned int reg, void *arg)
860749f21d3Swesolows {
861749f21d3Swesolows netsnmp_delegated_cache *cache = (netsnmp_delegated_cache *)arg;
862749f21d3Swesolows netsnmp_request_info *request;
863749f21d3Swesolows netsnmp_agent_request_info *reqinfo;
864749f21d3Swesolows netsnmp_handler_registration *reginfo;
865749f21d3Swesolows netsnmp_table_request_info *table_info;
866749f21d3Swesolows sunFmProblem_data_t *pdata;
867749f21d3Swesolows sunFmFaultEvent_data_t *data;
86825c6ff4bSstephh sunFmFaultStatus_data_t status;
869749f21d3Swesolows
870749f21d3Swesolows ASSERT(netsnmp_handler_check_cache(cache) != NULL);
871749f21d3Swesolows
872749f21d3Swesolows (void) pthread_mutex_lock(&update_lock);
873749f21d3Swesolows if (update_status != US_QUIET) {
874749f21d3Swesolows struct timeval tv;
875749f21d3Swesolows
876749f21d3Swesolows tv.tv_sec = UPDATE_WAIT_MILLIS / 1000;
877749f21d3Swesolows tv.tv_usec = (UPDATE_WAIT_MILLIS % 1000) * 1000;
878749f21d3Swesolows
879749f21d3Swesolows (void) snmp_alarm_register_hr(tv, 0,
880749f21d3Swesolows sunFmFaultEventTable_return, cache);
881749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
882749f21d3Swesolows return;
883749f21d3Swesolows }
884749f21d3Swesolows
885749f21d3Swesolows request = cache->requests;
886749f21d3Swesolows reqinfo = cache->reqinfo;
887749f21d3Swesolows reginfo = cache->reginfo;
888749f21d3Swesolows
889749f21d3Swesolows table_info = netsnmp_extract_table_info(request);
890749f21d3Swesolows request->delegated = 0;
891749f21d3Swesolows
892749f21d3Swesolows ASSERT(table_info->colnum >= SUNFMFAULTEVENT_COLMIN);
893749f21d3Swesolows ASSERT(table_info->colnum <= SUNFMFAULTEVENT_COLMAX);
894749f21d3Swesolows
895749f21d3Swesolows /*
896749f21d3Swesolows * table_info->colnum contains the column number requested.
897749f21d3Swesolows * table_info->indexes contains a linked list of snmp variable
898749f21d3Swesolows * bindings for the indexes of the table. Values in the list
899749f21d3Swesolows * have been set corresponding to the indexes of the
900749f21d3Swesolows * request. We have other guarantees as well:
901749f21d3Swesolows *
902749f21d3Swesolows * - The column number is always within range.
903749f21d3Swesolows * - If we have no index data, table_info->index_oid_len is 0.
904749f21d3Swesolows * - We will never receive requests outside our table nor
905749f21d3Swesolows * those with the first subid anything other than 1 (Entry)
906749f21d3Swesolows * nor those without a column number. This is true even
907749f21d3Swesolows * for GETNEXT requests.
908749f21d3Swesolows */
909749f21d3Swesolows
9102d2a5225Sstephh switch (reqinfo->mode) {
9112d2a5225Sstephh case MODE_GET:
9122d2a5225Sstephh if ((data = sunFmFaultEventTable_fe(reginfo, table_info,
9132d2a5225Sstephh &status)) == NULL) {
914749f21d3Swesolows netsnmp_free_delegated_cache(cache);
915749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
916749f21d3Swesolows return;
917749f21d3Swesolows }
9182d2a5225Sstephh break;
9192d2a5225Sstephh case MODE_GETNEXT:
9202d2a5225Sstephh case MODE_GETBULK:
9212d2a5225Sstephh if ((data = sunFmFaultEventTable_nextfe(reginfo, table_info,
9222d2a5225Sstephh &status)) == NULL) {
923749f21d3Swesolows netsnmp_free_delegated_cache(cache);
924749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
925749f21d3Swesolows return;
926749f21d3Swesolows }
9272d2a5225Sstephh break;
9282d2a5225Sstephh default:
929888e0559SRobert Johnston (void) snmp_log(LOG_ERR, MODNAME_STR ": Unsupported request "
930888e0559SRobert Johnston "mode %d\n", reqinfo->mode);
9312d2a5225Sstephh netsnmp_free_delegated_cache(cache);
9322d2a5225Sstephh (void) pthread_mutex_unlock(&update_lock);
9332d2a5225Sstephh return;
934749f21d3Swesolows }
935749f21d3Swesolows
936749f21d3Swesolows switch (table_info->colnum) {
937749f21d3Swesolows case SUNFMFAULTEVENT_COL_PROBLEMUUID:
938749f21d3Swesolows {
939749f21d3Swesolows if ((pdata = sunFmProblemTable_pr(reginfo, table_info))
940749f21d3Swesolows == NULL) {
941888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request,
942888e0559SRobert Johnston table_info, ASN_OCTET_STR, NULL, 0);
943749f21d3Swesolows break;
944749f21d3Swesolows }
945888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
946749f21d3Swesolows ASN_OCTET_STR, (uchar_t *)pdata->d_aci_uuid,
947749f21d3Swesolows strlen(pdata->d_aci_uuid));
948749f21d3Swesolows break;
949749f21d3Swesolows }
950749f21d3Swesolows case SUNFMFAULTEVENT_COL_CLASS:
951749f21d3Swesolows {
952749f21d3Swesolows char *class = "-";
953749f21d3Swesolows
954749f21d3Swesolows (void) nvlist_lookup_string(data, FM_CLASS, &class);
955888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
956749f21d3Swesolows ASN_OCTET_STR, (uchar_t *)class, strlen(class));
957749f21d3Swesolows break;
958749f21d3Swesolows }
959749f21d3Swesolows case SUNFMFAULTEVENT_COL_CERTAINTY:
960749f21d3Swesolows {
961749f21d3Swesolows uint8_t pct = 0;
962749f21d3Swesolows ulong_t pl;
963749f21d3Swesolows
964749f21d3Swesolows (void) nvlist_lookup_uint8(data, FM_FAULT_CERTAINTY,
965749f21d3Swesolows &pct);
966749f21d3Swesolows pl = (ulong_t)pct;
967888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
968749f21d3Swesolows ASN_UNSIGNED, (uchar_t *)&pl, sizeof (pl));
969749f21d3Swesolows break;
970749f21d3Swesolows }
971749f21d3Swesolows case SUNFMFAULTEVENT_COL_ASRU:
972749f21d3Swesolows {
973749f21d3Swesolows nvlist_t *asru = NULL;
97430698f33Swesolows char *fmri, *str;
975749f21d3Swesolows
976749f21d3Swesolows (void) nvlist_lookup_nvlist(data, FM_FAULT_ASRU, &asru);
97730698f33Swesolows if ((str = sunFm_nvl2str(asru)) == NULL)
978749f21d3Swesolows fmri = "-";
97930698f33Swesolows else
98030698f33Swesolows fmri = str;
98130698f33Swesolows
982888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
983749f21d3Swesolows ASN_OCTET_STR, (uchar_t *)fmri, strlen(fmri));
98430698f33Swesolows free(str);
985749f21d3Swesolows break;
986749f21d3Swesolows }
987749f21d3Swesolows case SUNFMFAULTEVENT_COL_FRU:
988749f21d3Swesolows {
989749f21d3Swesolows nvlist_t *fru = NULL;
99030698f33Swesolows char *fmri, *str;
991749f21d3Swesolows
992749f21d3Swesolows (void) nvlist_lookup_nvlist(data, FM_FAULT_FRU, &fru);
99330698f33Swesolows if ((str = sunFm_nvl2str(fru)) == NULL)
994749f21d3Swesolows fmri = "-";
99530698f33Swesolows else
99630698f33Swesolows fmri = str;
99730698f33Swesolows
998888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
999749f21d3Swesolows ASN_OCTET_STR, (uchar_t *)fmri, strlen(fmri));
100030698f33Swesolows free(str);
1001749f21d3Swesolows break;
1002749f21d3Swesolows }
1003749f21d3Swesolows case SUNFMFAULTEVENT_COL_RESOURCE:
1004749f21d3Swesolows {
1005749f21d3Swesolows nvlist_t *rsrc = NULL;
100630698f33Swesolows char *fmri, *str;
1007749f21d3Swesolows
100830698f33Swesolows (void) nvlist_lookup_nvlist(data, FM_FAULT_RESOURCE, &rsrc);
100930698f33Swesolows if ((str = sunFm_nvl2str(rsrc)) == NULL)
1010749f21d3Swesolows fmri = "-";
101130698f33Swesolows else
101230698f33Swesolows fmri = str;
101330698f33Swesolows
1014888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
1015749f21d3Swesolows ASN_OCTET_STR, (uchar_t *)fmri, strlen(fmri));
101630698f33Swesolows free(str);
1017749f21d3Swesolows break;
1018749f21d3Swesolows }
101925c6ff4bSstephh case SUNFMFAULTEVENT_COL_STATUS:
102025c6ff4bSstephh {
10212d2a5225Sstephh ulong_t pl = SUNFMFAULTEVENT_STATE_OTHER;
102225c6ff4bSstephh
102325c6ff4bSstephh if (status & FM_SUSPECT_FAULTY)
102425c6ff4bSstephh pl = SUNFMFAULTEVENT_STATE_FAULTY;
102525c6ff4bSstephh else if (status & FM_SUSPECT_NOT_PRESENT)
102625c6ff4bSstephh pl = SUNFMFAULTEVENT_STATE_REMOVED;
102725c6ff4bSstephh else if (status & FM_SUSPECT_REPLACED)
102825c6ff4bSstephh pl = SUNFMFAULTEVENT_STATE_REPLACED;
102925c6ff4bSstephh else if (status & FM_SUSPECT_REPAIRED)
103025c6ff4bSstephh pl = SUNFMFAULTEVENT_STATE_REPAIRED;
103125c6ff4bSstephh else if (status & FM_SUSPECT_ACQUITTED)
103225c6ff4bSstephh pl = SUNFMFAULTEVENT_STATE_ACQUITTED;
1033888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
10342d2a5225Sstephh ASN_INTEGER, (uchar_t *)&pl, sizeof (pl));
103525c6ff4bSstephh break;
103625c6ff4bSstephh }
103725c6ff4bSstephh case SUNFMFAULTEVENT_COL_LOCATION:
103825c6ff4bSstephh {
103925c6ff4bSstephh char *location = "-";
104025c6ff4bSstephh
104125c6ff4bSstephh (void) nvlist_lookup_string(data, FM_FAULT_LOCATION, &location);
1042888e0559SRobert Johnston (void) netsnmp_table_build_result(reginfo, request, table_info,
104325c6ff4bSstephh ASN_OCTET_STR, (uchar_t *)location, strlen(location));
104425c6ff4bSstephh break;
104525c6ff4bSstephh }
1046749f21d3Swesolows default:
1047749f21d3Swesolows break;
1048749f21d3Swesolows }
1049749f21d3Swesolows
1050749f21d3Swesolows netsnmp_free_delegated_cache(cache);
1051749f21d3Swesolows (void) pthread_mutex_unlock(&update_lock);
1052749f21d3Swesolows }
1053749f21d3Swesolows
1054749f21d3Swesolows static int
sunFmFaultEventTable_handler(netsnmp_mib_handler * handler,netsnmp_handler_registration * reginfo,netsnmp_agent_request_info * reqinfo,netsnmp_request_info * requests)1055749f21d3Swesolows sunFmFaultEventTable_handler(netsnmp_mib_handler *handler,
1056749f21d3Swesolows netsnmp_handler_registration *reginfo, netsnmp_agent_request_info *reqinfo,
1057749f21d3Swesolows netsnmp_request_info *requests)
1058749f21d3Swesolows {
1059749f21d3Swesolows netsnmp_request_info *request;
1060749f21d3Swesolows struct timeval tv;
1061749f21d3Swesolows
1062749f21d3Swesolows tv.tv_sec = UPDATE_WAIT_MILLIS / 1000;
1063749f21d3Swesolows tv.tv_usec = (UPDATE_WAIT_MILLIS % 1000) * 1000;
1064749f21d3Swesolows
1065749f21d3Swesolows request_update();
1066749f21d3Swesolows
1067749f21d3Swesolows for (request = requests; request; request = request->next) {
1068749f21d3Swesolows if (request->processed != 0)
1069749f21d3Swesolows continue;
1070749f21d3Swesolows
1071749f21d3Swesolows if (netsnmp_extract_table_info(request) == NULL)
1072749f21d3Swesolows continue;
1073749f21d3Swesolows
1074749f21d3Swesolows request->delegated = 1;
1075749f21d3Swesolows (void) snmp_alarm_register_hr(tv, 0,
1076749f21d3Swesolows sunFmFaultEventTable_return,
1077749f21d3Swesolows (void *) netsnmp_create_delegated_cache(handler, reginfo,
1078749f21d3Swesolows reqinfo, request, NULL));
1079749f21d3Swesolows }
1080749f21d3Swesolows
1081749f21d3Swesolows return (SNMP_ERR_NOERROR);
1082749f21d3Swesolows }
1083