17c478bd9Sstevel@tonic-gate /*
27c478bd9Sstevel@tonic-gate * CDDL HEADER START
37c478bd9Sstevel@tonic-gate *
47c478bd9Sstevel@tonic-gate * The contents of this file are subject to the terms of the
57c478bd9Sstevel@tonic-gate * Common Development and Distribution License, Version 1.0 only
67c478bd9Sstevel@tonic-gate * (the "License"). You may not use this file except in compliance
77c478bd9Sstevel@tonic-gate * with the License.
87c478bd9Sstevel@tonic-gate *
97c478bd9Sstevel@tonic-gate * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
107c478bd9Sstevel@tonic-gate * or http://www.opensolaris.org/os/licensing.
117c478bd9Sstevel@tonic-gate * See the License for the specific language governing permissions
127c478bd9Sstevel@tonic-gate * and limitations under the License.
137c478bd9Sstevel@tonic-gate *
147c478bd9Sstevel@tonic-gate * When distributing Covered Code, include this CDDL HEADER in each
157c478bd9Sstevel@tonic-gate * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
167c478bd9Sstevel@tonic-gate * If applicable, add the following below this CDDL HEADER, with the
177c478bd9Sstevel@tonic-gate * fields enclosed by brackets "[]" replaced with your own identifying
187c478bd9Sstevel@tonic-gate * information: Portions Copyright [yyyy] [name of copyright owner]
197c478bd9Sstevel@tonic-gate *
207c478bd9Sstevel@tonic-gate * CDDL HEADER END
217c478bd9Sstevel@tonic-gate */
227c478bd9Sstevel@tonic-gate /*
237c478bd9Sstevel@tonic-gate * rpcb_stat.c
247c478bd9Sstevel@tonic-gate * Allows for gathering of statistics
257c478bd9Sstevel@tonic-gate *
267c478bd9Sstevel@tonic-gate * Copyright (c) 1990 by Sun Microsystems, Inc.
277c478bd9Sstevel@tonic-gate */
288f6d9daeSMarcel Telka /*
298f6d9daeSMarcel Telka * Copyright 2014 Nexenta Systems, Inc. All rights reserved.
308f6d9daeSMarcel Telka */
317c478bd9Sstevel@tonic-gate
327c478bd9Sstevel@tonic-gate #include <stdio.h>
337c478bd9Sstevel@tonic-gate #include <netconfig.h>
347c478bd9Sstevel@tonic-gate #include <rpc/rpc.h>
357c478bd9Sstevel@tonic-gate #include <rpc/rpcb_prot.h>
367c478bd9Sstevel@tonic-gate #include <sys/stat.h>
377c478bd9Sstevel@tonic-gate #ifdef PORTMAP
387c478bd9Sstevel@tonic-gate #include <rpc/pmap_prot.h>
397c478bd9Sstevel@tonic-gate #endif
407c478bd9Sstevel@tonic-gate #include <stdlib.h>
418f6d9daeSMarcel Telka #include <atomic.h>
428f6d9daeSMarcel Telka #include <assert.h>
438f6d9daeSMarcel Telka #include <thread.h>
448f6d9daeSMarcel Telka #include <synch.h>
458f6d9daeSMarcel Telka #include <string.h>
467c478bd9Sstevel@tonic-gate #include "rpcbind.h"
477c478bd9Sstevel@tonic-gate
487c478bd9Sstevel@tonic-gate static rpcb_stat_byvers inf;
498f6d9daeSMarcel Telka static rwlock_t inf_lock = DEFAULTRWLOCK;
507c478bd9Sstevel@tonic-gate
517c478bd9Sstevel@tonic-gate void
rpcbs_procinfo(int rtype,rpcproc_t proc)528f6d9daeSMarcel Telka rpcbs_procinfo(int rtype, rpcproc_t proc)
537c478bd9Sstevel@tonic-gate {
548f6d9daeSMarcel Telka assert(rtype >= 0 && rtype < RPCBVERS_STAT);
557c478bd9Sstevel@tonic-gate
567c478bd9Sstevel@tonic-gate #ifdef PORTMAP
578f6d9daeSMarcel Telka if ((rtype == RPCBVERS_2_STAT) && (proc > rpcb_highproc_2))
588f6d9daeSMarcel Telka return;
598f6d9daeSMarcel Telka #else
608f6d9daeSMarcel Telka assert(rtype != RPCBVERS_2_STAT);
617c478bd9Sstevel@tonic-gate #endif
628f6d9daeSMarcel Telka
638f6d9daeSMarcel Telka if ((rtype == RPCBVERS_3_STAT) && (proc > rpcb_highproc_3))
648f6d9daeSMarcel Telka return;
658f6d9daeSMarcel Telka
668f6d9daeSMarcel Telka if ((rtype == RPCBVERS_4_STAT) && (proc > rpcb_highproc_4))
678f6d9daeSMarcel Telka return;
688f6d9daeSMarcel Telka
698f6d9daeSMarcel Telka atomic_add_int((uint_t *)&inf[rtype].info[proc], 1);
707c478bd9Sstevel@tonic-gate }
717c478bd9Sstevel@tonic-gate
727c478bd9Sstevel@tonic-gate void
rpcbs_set(int rtype,bool_t success)738f6d9daeSMarcel Telka rpcbs_set(int rtype, bool_t success)
747c478bd9Sstevel@tonic-gate {
758f6d9daeSMarcel Telka assert(rtype >= 0 && rtype < RPCBVERS_STAT);
768f6d9daeSMarcel Telka
778f6d9daeSMarcel Telka if (success == FALSE)
787c478bd9Sstevel@tonic-gate return;
798f6d9daeSMarcel Telka
808f6d9daeSMarcel Telka atomic_add_int((uint_t *)&inf[rtype].setinfo, 1);
817c478bd9Sstevel@tonic-gate }
827c478bd9Sstevel@tonic-gate
837c478bd9Sstevel@tonic-gate void
rpcbs_unset(int rtype,bool_t success)848f6d9daeSMarcel Telka rpcbs_unset(int rtype, bool_t success)
857c478bd9Sstevel@tonic-gate {
868f6d9daeSMarcel Telka assert(rtype >= 0 && rtype < RPCBVERS_STAT);
878f6d9daeSMarcel Telka
888f6d9daeSMarcel Telka if (success == FALSE)
897c478bd9Sstevel@tonic-gate return;
908f6d9daeSMarcel Telka
918f6d9daeSMarcel Telka atomic_add_int((uint_t *)&inf[rtype].unsetinfo, 1);
927c478bd9Sstevel@tonic-gate }
937c478bd9Sstevel@tonic-gate
947c478bd9Sstevel@tonic-gate void
rpcbs_getaddr(int rtype,rpcprog_t prog,rpcvers_t vers,char * netid,char * uaddr)958f6d9daeSMarcel Telka rpcbs_getaddr(int rtype, rpcprog_t prog, rpcvers_t vers, char *netid,
968f6d9daeSMarcel Telka char *uaddr)
977c478bd9Sstevel@tonic-gate {
987c478bd9Sstevel@tonic-gate rpcbs_addrlist *al;
998f6d9daeSMarcel Telka rpcbs_addrlist *s;
1008f6d9daeSMarcel Telka rpcbs_addrlist *wal;
1017c478bd9Sstevel@tonic-gate struct netconfig *nconf;
1027c478bd9Sstevel@tonic-gate
1038f6d9daeSMarcel Telka assert(rtype >= 0 && rtype < RPCBVERS_STAT);
1047c478bd9Sstevel@tonic-gate
1058f6d9daeSMarcel Telka /*
1068f6d9daeSMarcel Telka * First try with read lock only.
1078f6d9daeSMarcel Telka */
1088f6d9daeSMarcel Telka (void) rw_rdlock(&inf_lock);
1098f6d9daeSMarcel Telka for (s = al = inf[rtype].addrinfo; al; al = al->next) {
1107c478bd9Sstevel@tonic-gate if ((al->prog == prog) && (al->vers == vers) &&
1117c478bd9Sstevel@tonic-gate (strcmp(al->netid, netid) == 0)) {
1128f6d9daeSMarcel Telka (void) rw_unlock(&inf_lock);
1138f6d9daeSMarcel Telka
114*05360118SToomas Soome if ((uaddr == NULL) || (uaddr[0] == '\0'))
1158f6d9daeSMarcel Telka atomic_add_int((uint_t *)&al->failure, 1);
1167c478bd9Sstevel@tonic-gate else
1178f6d9daeSMarcel Telka atomic_add_int((uint_t *)&al->success, 1);
1188f6d9daeSMarcel Telka
1197c478bd9Sstevel@tonic-gate return;
1207c478bd9Sstevel@tonic-gate }
1217c478bd9Sstevel@tonic-gate }
1228f6d9daeSMarcel Telka (void) rw_unlock(&inf_lock);
1238f6d9daeSMarcel Telka
1248f6d9daeSMarcel Telka /*
1258f6d9daeSMarcel Telka * If not found, we will likely need to add a new entry,
1268f6d9daeSMarcel Telka * so pre-allocate it, and then try to search again with write lock.
1278f6d9daeSMarcel Telka */
1287c478bd9Sstevel@tonic-gate nconf = rpcbind_get_conf(netid);
1297c478bd9Sstevel@tonic-gate if (nconf == NULL) {
1307c478bd9Sstevel@tonic-gate return;
1317c478bd9Sstevel@tonic-gate }
1328f6d9daeSMarcel Telka
1337c478bd9Sstevel@tonic-gate al = (rpcbs_addrlist *) malloc(sizeof (rpcbs_addrlist));
1347c478bd9Sstevel@tonic-gate if (al == NULL) {
1357c478bd9Sstevel@tonic-gate return;
1367c478bd9Sstevel@tonic-gate }
1378f6d9daeSMarcel Telka
1387c478bd9Sstevel@tonic-gate al->prog = prog;
1397c478bd9Sstevel@tonic-gate al->vers = vers;
1407c478bd9Sstevel@tonic-gate al->netid = nconf->nc_netid;
141*05360118SToomas Soome if ((uaddr == NULL) || (uaddr[0] == '\0')) {
1427c478bd9Sstevel@tonic-gate al->failure = 1;
1437c478bd9Sstevel@tonic-gate al->success = 0;
1447c478bd9Sstevel@tonic-gate } else {
1457c478bd9Sstevel@tonic-gate al->failure = 0;
1467c478bd9Sstevel@tonic-gate al->success = 1;
1477c478bd9Sstevel@tonic-gate }
1488f6d9daeSMarcel Telka
1498f6d9daeSMarcel Telka (void) rw_wrlock(&inf_lock);
1508f6d9daeSMarcel Telka for (wal = inf[rtype].addrinfo; wal != s; wal = wal->next) {
1518f6d9daeSMarcel Telka if ((wal->prog == prog) && (wal->vers == vers) &&
1528f6d9daeSMarcel Telka (strcmp(wal->netid, netid) == 0)) {
1538f6d9daeSMarcel Telka (void) rw_unlock(&inf_lock);
1548f6d9daeSMarcel Telka
1558f6d9daeSMarcel Telka free(al);
1568f6d9daeSMarcel Telka
157*05360118SToomas Soome if ((uaddr == NULL) || (uaddr[0] == '\0'))
1588f6d9daeSMarcel Telka atomic_add_int((uint_t *)&wal->failure, 1);
1598f6d9daeSMarcel Telka else
1608f6d9daeSMarcel Telka atomic_add_int((uint_t *)&wal->success, 1);
1618f6d9daeSMarcel Telka
1628f6d9daeSMarcel Telka return;
1638f6d9daeSMarcel Telka }
1648f6d9daeSMarcel Telka }
1658f6d9daeSMarcel Telka
1667c478bd9Sstevel@tonic-gate al->next = inf[rtype].addrinfo;
1677c478bd9Sstevel@tonic-gate inf[rtype].addrinfo = al;
1688f6d9daeSMarcel Telka (void) rw_unlock(&inf_lock);
1697c478bd9Sstevel@tonic-gate }
1707c478bd9Sstevel@tonic-gate
1718f6d9daeSMarcel Telka /*
1728f6d9daeSMarcel Telka * rpcbproc - rpcbind proc number on which this was called
1738f6d9daeSMarcel Telka */
1747c478bd9Sstevel@tonic-gate void
rpcbs_rmtcall(int rtype,rpcproc_t rpcbproc,rpcprog_t prog,rpcvers_t vers,rpcproc_t proc,char * netid,rpcblist_ptr rbl)1758f6d9daeSMarcel Telka rpcbs_rmtcall(int rtype, rpcproc_t rpcbproc, rpcprog_t prog, rpcvers_t vers,
1768f6d9daeSMarcel Telka rpcproc_t proc, char *netid, rpcblist_ptr rbl)
1777c478bd9Sstevel@tonic-gate {
1787c478bd9Sstevel@tonic-gate rpcbs_rmtcalllist *rl;
1798f6d9daeSMarcel Telka rpcbs_rmtcalllist *s;
1808f6d9daeSMarcel Telka rpcbs_rmtcalllist *wrl;
1817c478bd9Sstevel@tonic-gate struct netconfig *nconf;
1827c478bd9Sstevel@tonic-gate
1838f6d9daeSMarcel Telka assert(rtype >= 0 && rtype < RPCBVERS_STAT);
1847c478bd9Sstevel@tonic-gate
1858f6d9daeSMarcel Telka /*
1868f6d9daeSMarcel Telka * First try with read lock only.
1878f6d9daeSMarcel Telka */
1888f6d9daeSMarcel Telka (void) rw_rdlock(&inf_lock);
1898f6d9daeSMarcel Telka for (s = rl = inf[rtype].rmtinfo; rl; rl = rl->next) {
1907c478bd9Sstevel@tonic-gate if ((rl->prog == prog) && (rl->vers == vers) &&
1918f6d9daeSMarcel Telka (rl->proc == proc) && (strcmp(rl->netid, netid) == 0)) {
1928f6d9daeSMarcel Telka (void) rw_unlock(&inf_lock);
1938f6d9daeSMarcel Telka
1948f6d9daeSMarcel Telka if ((rbl == NULL) || (rbl->rpcb_map.r_vers != vers))
1958f6d9daeSMarcel Telka atomic_add_int((uint_t *)&rl->failure, 1);
1967c478bd9Sstevel@tonic-gate else
1978f6d9daeSMarcel Telka atomic_add_int((uint_t *)&rl->success, 1);
1987c478bd9Sstevel@tonic-gate if (rpcbproc == RPCBPROC_INDIRECT)
1998f6d9daeSMarcel Telka atomic_add_int((uint_t *)&rl->indirect, 1);
2008f6d9daeSMarcel Telka
2017c478bd9Sstevel@tonic-gate return;
2027c478bd9Sstevel@tonic-gate }
2037c478bd9Sstevel@tonic-gate }
2048f6d9daeSMarcel Telka (void) rw_unlock(&inf_lock);
2058f6d9daeSMarcel Telka
2068f6d9daeSMarcel Telka /*
2078f6d9daeSMarcel Telka * If not found, we will likely need to add a new entry,
2088f6d9daeSMarcel Telka * so pre-allocate it, and then try to search again with write lock.
2098f6d9daeSMarcel Telka */
2107c478bd9Sstevel@tonic-gate nconf = rpcbind_get_conf(netid);
2117c478bd9Sstevel@tonic-gate if (nconf == NULL) {
2127c478bd9Sstevel@tonic-gate return;
2137c478bd9Sstevel@tonic-gate }
2148f6d9daeSMarcel Telka
2157c478bd9Sstevel@tonic-gate rl = (rpcbs_rmtcalllist *) malloc(sizeof (rpcbs_rmtcalllist));
2167c478bd9Sstevel@tonic-gate if (rl == NULL) {
2177c478bd9Sstevel@tonic-gate return;
2187c478bd9Sstevel@tonic-gate }
2198f6d9daeSMarcel Telka
2207c478bd9Sstevel@tonic-gate rl->prog = prog;
2217c478bd9Sstevel@tonic-gate rl->vers = vers;
2227c478bd9Sstevel@tonic-gate rl->proc = proc;
2237c478bd9Sstevel@tonic-gate rl->netid = nconf->nc_netid;
2248f6d9daeSMarcel Telka if ((rbl == NULL) || (rbl->rpcb_map.r_vers != vers)) {
2257c478bd9Sstevel@tonic-gate rl->failure = 1;
2267c478bd9Sstevel@tonic-gate rl->success = 0;
2277c478bd9Sstevel@tonic-gate } else {
2287c478bd9Sstevel@tonic-gate rl->failure = 0;
2297c478bd9Sstevel@tonic-gate rl->success = 1;
2307c478bd9Sstevel@tonic-gate }
2318f6d9daeSMarcel Telka rl->indirect = rpcbproc == RPCBPROC_INDIRECT ? 1 : 0;
2328f6d9daeSMarcel Telka
2338f6d9daeSMarcel Telka (void) rw_wrlock(&inf_lock);
2348f6d9daeSMarcel Telka for (wrl = inf[rtype].rmtinfo; wrl != s; wrl = wrl->next) {
2358f6d9daeSMarcel Telka if ((wrl->prog == prog) && (wrl->vers == vers) &&
2368f6d9daeSMarcel Telka (wrl->proc == proc) && (strcmp(wrl->netid, netid) == 0)) {
2378f6d9daeSMarcel Telka (void) rw_unlock(&inf_lock);
2388f6d9daeSMarcel Telka
2398f6d9daeSMarcel Telka free(rl);
2408f6d9daeSMarcel Telka
2418f6d9daeSMarcel Telka if ((rbl == NULL) || (rbl->rpcb_map.r_vers != vers))
2428f6d9daeSMarcel Telka atomic_add_int((uint_t *)&wrl->failure, 1);
2438f6d9daeSMarcel Telka else
2448f6d9daeSMarcel Telka atomic_add_int((uint_t *)&wrl->success, 1);
2458f6d9daeSMarcel Telka if (rpcbproc == RPCBPROC_INDIRECT)
2468f6d9daeSMarcel Telka atomic_add_int((uint_t *)&wrl->indirect, 1);
2478f6d9daeSMarcel Telka
2488f6d9daeSMarcel Telka return;
2498f6d9daeSMarcel Telka }
2508f6d9daeSMarcel Telka }
2518f6d9daeSMarcel Telka
2527c478bd9Sstevel@tonic-gate rl->next = inf[rtype].rmtinfo;
2537c478bd9Sstevel@tonic-gate inf[rtype].rmtinfo = rl;
2548f6d9daeSMarcel Telka (void) rw_unlock(&inf_lock);
2557c478bd9Sstevel@tonic-gate }
2567c478bd9Sstevel@tonic-gate
2578f6d9daeSMarcel Telka /* ARGSUSED */
2588f6d9daeSMarcel Telka bool_t
rpcbproc_getstat(void * argp,rpcb_stat_byvers ** result)2598f6d9daeSMarcel Telka rpcbproc_getstat(void *argp, rpcb_stat_byvers **result)
2608f6d9daeSMarcel Telka {
2618f6d9daeSMarcel Telka /*
2628f6d9daeSMarcel Telka * inf_lock is unlocked in xdr_rpcb_stat_byvers_ptr()
2638f6d9daeSMarcel Telka */
2648f6d9daeSMarcel Telka (void) rw_rdlock(&inf_lock);
2658f6d9daeSMarcel Telka *result = &inf;
2668f6d9daeSMarcel Telka return (TRUE);
2678f6d9daeSMarcel Telka }
2688f6d9daeSMarcel Telka
2698f6d9daeSMarcel Telka bool_t
xdr_rpcb_stat_byvers_ptr(XDR * xdrs,rpcb_stat_byvers ** objp)2708f6d9daeSMarcel Telka xdr_rpcb_stat_byvers_ptr(XDR *xdrs, rpcb_stat_byvers **objp)
2717c478bd9Sstevel@tonic-gate {
2728f6d9daeSMarcel Telka if (xdrs->x_op == XDR_FREE) {
2738f6d9daeSMarcel Telka /*
2748f6d9daeSMarcel Telka * inf_lock is locked in rpcbproc_getstat()
2758f6d9daeSMarcel Telka */
2768f6d9daeSMarcel Telka (void) rw_unlock(&inf_lock);
2778f6d9daeSMarcel Telka return (TRUE);
2788f6d9daeSMarcel Telka }
2798f6d9daeSMarcel Telka
2808f6d9daeSMarcel Telka return (xdr_rpcb_stat_byvers(xdrs, (rpcb_stat *)*objp));
2817c478bd9Sstevel@tonic-gate }
282