13299f39fSGordon Ross /*
23299f39fSGordon Ross * CDDL HEADER START
33299f39fSGordon Ross *
43299f39fSGordon Ross * The contents of this file are subject to the terms of the
53299f39fSGordon Ross * Common Development and Distribution License (the "License").
63299f39fSGordon Ross * You may not use this file except in compliance with the License.
73299f39fSGordon Ross *
83299f39fSGordon Ross * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
93299f39fSGordon Ross * or http://www.opensolaris.org/os/licensing.
103299f39fSGordon Ross * See the License for the specific language governing permissions
113299f39fSGordon Ross * and limitations under the License.
123299f39fSGordon Ross *
133299f39fSGordon Ross * When distributing Covered Code, include this CDDL HEADER in each
143299f39fSGordon Ross * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
153299f39fSGordon Ross * If applicable, add the following below this CDDL HEADER, with the
163299f39fSGordon Ross * fields enclosed by brackets "[]" replaced with your own identifying
173299f39fSGordon Ross * information: Portions Copyright [yyyy] [name of copyright owner]
183299f39fSGordon Ross *
193299f39fSGordon Ross * CDDL HEADER END
203299f39fSGordon Ross */
213299f39fSGordon Ross
223299f39fSGordon Ross /*
233299f39fSGordon Ross * Copyright (c) 2008, 2010, Oracle and/or its affiliates. All rights reserved.
24*ce8560eeSMatt Barden * Copyright 2020 Tintri by DDN, Inc. All rights reserved.
253299f39fSGordon Ross */
263299f39fSGordon Ross
273299f39fSGordon Ross /*
283299f39fSGordon Ross * Server-side NDR stream (PDU) operations. Stream operations should
293299f39fSGordon Ross * return TRUE (non-zero) on success or FALSE (zero or a null pointer)
303299f39fSGordon Ross * on failure. When an operation returns FALSE, including ndo_malloc()
313299f39fSGordon Ross * returning NULL, it should set the nds->error to indicate what went
323299f39fSGordon Ross * wrong.
333299f39fSGordon Ross *
343299f39fSGordon Ross * When available, the relevant ndr reference is passed to the
353299f39fSGordon Ross * operation but keep in mind that it may be a null pointer.
363299f39fSGordon Ross *
373299f39fSGordon Ross * Functions ndo_get_pdu(), ndo_put_pdu(), and ndo_pad_pdu()
383299f39fSGordon Ross * must never grow the PDU data. A request for out-of-bounds data is
393299f39fSGordon Ross * an error. The swap_bytes flag is 1 if NDR knows that the byte-
403299f39fSGordon Ross * order in the PDU is different from the local system.
413299f39fSGordon Ross */
423299f39fSGordon Ross
433299f39fSGordon Ross #include <sys/types.h>
443299f39fSGordon Ross #include <stdarg.h>
453299f39fSGordon Ross #include <ctype.h>
463299f39fSGordon Ross #include <stdio.h>
473299f39fSGordon Ross #include <stdlib.h>
483299f39fSGordon Ross #include <strings.h>
493299f39fSGordon Ross #include <string.h>
503299f39fSGordon Ross #include <assert.h>
513299f39fSGordon Ross
523299f39fSGordon Ross #include <libmlrpc.h>
533299f39fSGordon Ross
543299f39fSGordon Ross #define NDOBUFSZ 128
553299f39fSGordon Ross
563299f39fSGordon Ross #define NDR_PDU_BLOCK_SIZE (4*1024)
573299f39fSGordon Ross #define NDR_PDU_BLOCK_MASK (NDR_PDU_BLOCK_SIZE - 1)
583299f39fSGordon Ross #define NDR_PDU_ALIGN(N) \
593299f39fSGordon Ross (((N) + NDR_PDU_BLOCK_SIZE) & ~NDR_PDU_BLOCK_MASK)
603299f39fSGordon Ross #define NDR_PDU_MAX_SIZE (64*1024*1024)
613299f39fSGordon Ross
623299f39fSGordon Ross static char *ndo_malloc(ndr_stream_t *, unsigned, ndr_ref_t *);
633299f39fSGordon Ross static int ndo_free(ndr_stream_t *, char *, ndr_ref_t *);
643299f39fSGordon Ross static int ndo_grow_pdu(ndr_stream_t *, unsigned long, ndr_ref_t *);
653299f39fSGordon Ross static int ndo_pad_pdu(ndr_stream_t *, unsigned long, unsigned long,
663299f39fSGordon Ross ndr_ref_t *);
673299f39fSGordon Ross static int ndo_get_pdu(ndr_stream_t *, unsigned long, unsigned long,
683299f39fSGordon Ross char *, int, ndr_ref_t *);
693299f39fSGordon Ross static int ndo_put_pdu(ndr_stream_t *, unsigned long, unsigned long,
703299f39fSGordon Ross char *, int, ndr_ref_t *);
713299f39fSGordon Ross static void ndo_tattle(ndr_stream_t *, char *, ndr_ref_t *);
723299f39fSGordon Ross static void ndo_tattle_error(ndr_stream_t *, ndr_ref_t *);
733299f39fSGordon Ross static int ndo_reset(ndr_stream_t *);
743299f39fSGordon Ross static void ndo_destruct(ndr_stream_t *);
753299f39fSGordon Ross static void ndo_hexfmt(uint8_t *, int, int, char *, int);
763299f39fSGordon Ross
773299f39fSGordon Ross /*
783299f39fSGordon Ross * The ndr stream operations table.
793299f39fSGordon Ross */
803299f39fSGordon Ross static ndr_stream_ops_t nds_ops = {
813299f39fSGordon Ross ndo_malloc,
823299f39fSGordon Ross ndo_free,
833299f39fSGordon Ross ndo_grow_pdu,
843299f39fSGordon Ross ndo_pad_pdu,
853299f39fSGordon Ross ndo_get_pdu,
863299f39fSGordon Ross ndo_put_pdu,
873299f39fSGordon Ross ndo_tattle,
883299f39fSGordon Ross ndo_tattle_error,
893299f39fSGordon Ross ndo_reset,
903299f39fSGordon Ross ndo_destruct
913299f39fSGordon Ross };
923299f39fSGordon Ross
933299f39fSGordon Ross /*
943299f39fSGordon Ross * nds_bswap
953299f39fSGordon Ross *
963299f39fSGordon Ross * Copies len bytes from src to dst such that dst contains the bytes
973299f39fSGordon Ross * from src in reverse order.
983299f39fSGordon Ross *
993299f39fSGordon Ross * We expect to be dealing with bytes, words, dwords etc. So the
1003299f39fSGordon Ross * length must be non-zero and a power of 2.
1013299f39fSGordon Ross */
1023299f39fSGordon Ross void
nds_bswap(void * srcbuf,void * dstbuf,size_t len)1033299f39fSGordon Ross nds_bswap(void *srcbuf, void *dstbuf, size_t len)
1043299f39fSGordon Ross {
1053299f39fSGordon Ross uint8_t *src = (uint8_t *)srcbuf;
1063299f39fSGordon Ross uint8_t *dst = (uint8_t *)dstbuf;
1073299f39fSGordon Ross
1083299f39fSGordon Ross if ((len != 0) && ((len & (len - 1)) == 0)) {
1093299f39fSGordon Ross src += len;
1103299f39fSGordon Ross
1113299f39fSGordon Ross while (len--)
1123299f39fSGordon Ross *dst++ = *(--src);
1133299f39fSGordon Ross }
1143299f39fSGordon Ross }
1153299f39fSGordon Ross
1163299f39fSGordon Ross /*
1173299f39fSGordon Ross * nds_initialize
1183299f39fSGordon Ross *
1193299f39fSGordon Ross * Initialize a stream. Sets up the PDU parameters and assigns the stream
1203299f39fSGordon Ross * operations and the reference to the heap. An external heap is provided
1213299f39fSGordon Ross * to the stream, rather than each stream creating its own heap.
1223299f39fSGordon Ross */
1233299f39fSGordon Ross int
nds_initialize(ndr_stream_t * nds,unsigned pdu_size_hint,int composite_op,ndr_heap_t * heap)1243299f39fSGordon Ross nds_initialize(ndr_stream_t *nds, unsigned pdu_size_hint,
1253299f39fSGordon Ross int composite_op, ndr_heap_t *heap)
1263299f39fSGordon Ross {
1273299f39fSGordon Ross unsigned size;
1283299f39fSGordon Ross
1293299f39fSGordon Ross assert(nds);
1303299f39fSGordon Ross assert(heap);
1313299f39fSGordon Ross
1323299f39fSGordon Ross bzero(nds, sizeof (*nds));
1333299f39fSGordon Ross nds->ndo = &nds_ops;
1343299f39fSGordon Ross nds->heap = (struct ndr_heap *)heap;
1353299f39fSGordon Ross
1363299f39fSGordon Ross if (pdu_size_hint > NDR_PDU_MAX_SIZE) {
1373299f39fSGordon Ross nds->error = NDR_ERR_BOUNDS_CHECK;
1383299f39fSGordon Ross nds->error_ref = __LINE__;
1393299f39fSGordon Ross NDS_TATTLE_ERROR(nds, NULL, NULL);
1403299f39fSGordon Ross return (NDR_DRC_FAULT_RESOURCE_1);
1413299f39fSGordon Ross }
1423299f39fSGordon Ross
1433299f39fSGordon Ross size = (pdu_size_hint == 0) ? NDR_PDU_BLOCK_SIZE : pdu_size_hint;
1443299f39fSGordon Ross
1453299f39fSGordon Ross if ((nds->pdu_base_addr = malloc(size)) == NULL) {
1463299f39fSGordon Ross nds->error = NDR_ERR_MALLOC_FAILED;
1473299f39fSGordon Ross nds->error_ref = __LINE__;
1483299f39fSGordon Ross NDS_TATTLE_ERROR(nds, NULL, NULL);
1493299f39fSGordon Ross return (NDR_DRC_FAULT_OUT_OF_MEMORY);
1503299f39fSGordon Ross }
1513299f39fSGordon Ross
1523299f39fSGordon Ross nds->pdu_max_size = size;
1533299f39fSGordon Ross nds->pdu_size = 0;
1543299f39fSGordon Ross nds->pdu_base_offset = (unsigned long)nds->pdu_base_addr;
1553299f39fSGordon Ross
1563299f39fSGordon Ross nds->m_op = NDR_MODE_TO_M_OP(composite_op);
1573299f39fSGordon Ross nds->dir = NDR_MODE_TO_DIR(composite_op);
1583299f39fSGordon Ross
1593299f39fSGordon Ross nds->outer_queue_tailp = &nds->outer_queue_head;
1603299f39fSGordon Ross return (0);
1613299f39fSGordon Ross }
1623299f39fSGordon Ross
1633299f39fSGordon Ross /*
1643299f39fSGordon Ross * nds_destruct
1653299f39fSGordon Ross *
1663299f39fSGordon Ross * Destroy a stream. This is an external interface to provide access to
1673299f39fSGordon Ross * the stream's destruct operation.
1683299f39fSGordon Ross */
1693299f39fSGordon Ross void
nds_destruct(ndr_stream_t * nds)1703299f39fSGordon Ross nds_destruct(ndr_stream_t *nds)
1713299f39fSGordon Ross {
1723299f39fSGordon Ross if ((nds == NULL) || (nds->ndo == NULL))
1733299f39fSGordon Ross return;
1743299f39fSGordon Ross
1753299f39fSGordon Ross NDS_DESTRUCT(nds);
1763299f39fSGordon Ross }
1773299f39fSGordon Ross
1783299f39fSGordon Ross /*
1793299f39fSGordon Ross * Print NDR stream state.
1803299f39fSGordon Ross */
1813299f39fSGordon Ross void
nds_show_state(ndr_stream_t * nds)1823299f39fSGordon Ross nds_show_state(ndr_stream_t *nds)
1833299f39fSGordon Ross {
1843299f39fSGordon Ross if (nds == NULL) {
1853299f39fSGordon Ross ndo_printf(NULL, NULL, "nds: <null");
1863299f39fSGordon Ross return;
1873299f39fSGordon Ross }
1883299f39fSGordon Ross
189*ce8560eeSMatt Barden ndo_printf(NULL, NULL, "nds: base=0x%x, size=%d, max=%d, scan=%d, "
190*ce8560eeSMatt Barden "hdr_size=%d, body_size=%d, body_offset=%d",
1913299f39fSGordon Ross nds->pdu_base_offset, nds->pdu_size, nds->pdu_max_size,
192*ce8560eeSMatt Barden nds->pdu_scan_offset, nds->pdu_hdr_size, nds->pdu_body_size,
193*ce8560eeSMatt Barden nds->pdu_body_offset);
1943299f39fSGordon Ross }
1953299f39fSGordon Ross
1963299f39fSGordon Ross /*
1973299f39fSGordon Ross * ndo_malloc
1983299f39fSGordon Ross *
1993299f39fSGordon Ross * Allocate memory from the stream heap.
2003299f39fSGordon Ross */
2013299f39fSGordon Ross /*ARGSUSED*/
2023299f39fSGordon Ross static char *
ndo_malloc(ndr_stream_t * nds,unsigned len,ndr_ref_t * ref)2033299f39fSGordon Ross ndo_malloc(ndr_stream_t *nds, unsigned len, ndr_ref_t *ref)
2043299f39fSGordon Ross {
2053299f39fSGordon Ross return (ndr_heap_malloc((ndr_heap_t *)nds->heap, len));
2063299f39fSGordon Ross }
2073299f39fSGordon Ross
2083299f39fSGordon Ross /*
2093299f39fSGordon Ross * ndo_free
2103299f39fSGordon Ross *
2113299f39fSGordon Ross * Always succeeds: cannot free individual stream allocations.
2123299f39fSGordon Ross */
2133299f39fSGordon Ross /*ARGSUSED*/
2143299f39fSGordon Ross static int
ndo_free(ndr_stream_t * nds,char * p,ndr_ref_t * ref)2153299f39fSGordon Ross ndo_free(ndr_stream_t *nds, char *p, ndr_ref_t *ref)
2163299f39fSGordon Ross {
2173299f39fSGordon Ross return (1);
2183299f39fSGordon Ross }
2193299f39fSGordon Ross
2203299f39fSGordon Ross /*
2213299f39fSGordon Ross * ndo_grow_pdu
2223299f39fSGordon Ross *
2233299f39fSGordon Ross * This is the only place that should change the size of the PDU. If the
2243299f39fSGordon Ross * desired offset is beyond the current PDU size, we realloc the PDU
2253299f39fSGordon Ross * buffer to accommodate the request. For efficiency, the PDU is always
2263299f39fSGordon Ross * extended to a NDR_PDU_BLOCK_SIZE boundary. Requests to grow the PDU
2273299f39fSGordon Ross * beyond NDR_PDU_MAX_SIZE are rejected.
2283299f39fSGordon Ross *
2293299f39fSGordon Ross * Returns 1 to indicate success. Otherwise 0 to indicate failure.
2303299f39fSGordon Ross */
2313299f39fSGordon Ross static int
ndo_grow_pdu(ndr_stream_t * nds,unsigned long want_end_offset,ndr_ref_t * ref)2323299f39fSGordon Ross ndo_grow_pdu(ndr_stream_t *nds, unsigned long want_end_offset, ndr_ref_t *ref)
2333299f39fSGordon Ross {
2343299f39fSGordon Ross unsigned char *pdu_addr;
2353299f39fSGordon Ross unsigned pdu_max_size;
2363299f39fSGordon Ross
2373299f39fSGordon Ross ndo_printf(nds, ref, "grow %d", want_end_offset);
2383299f39fSGordon Ross
2393299f39fSGordon Ross pdu_max_size = nds->pdu_max_size;
2403299f39fSGordon Ross
2413299f39fSGordon Ross if (want_end_offset > pdu_max_size) {
2423299f39fSGordon Ross pdu_max_size = NDR_PDU_ALIGN(want_end_offset);
2433299f39fSGordon Ross
2443299f39fSGordon Ross if (pdu_max_size >= NDR_PDU_MAX_SIZE)
2453299f39fSGordon Ross return (0);
2463299f39fSGordon Ross
2473299f39fSGordon Ross pdu_addr = realloc(nds->pdu_base_addr, pdu_max_size);
2483299f39fSGordon Ross if (pdu_addr == 0)
2493299f39fSGordon Ross return (0);
2503299f39fSGordon Ross
2513299f39fSGordon Ross nds->pdu_max_size = pdu_max_size;
2523299f39fSGordon Ross nds->pdu_base_addr = pdu_addr;
2533299f39fSGordon Ross nds->pdu_base_offset = (unsigned long)pdu_addr;
2543299f39fSGordon Ross }
2553299f39fSGordon Ross
2563299f39fSGordon Ross nds->pdu_size = want_end_offset;
2573299f39fSGordon Ross return (1);
2583299f39fSGordon Ross }
2593299f39fSGordon Ross
2603299f39fSGordon Ross static int
ndo_pad_pdu(ndr_stream_t * nds,unsigned long pdu_offset,unsigned long n_bytes,ndr_ref_t * ref)2613299f39fSGordon Ross ndo_pad_pdu(ndr_stream_t *nds, unsigned long pdu_offset,
2623299f39fSGordon Ross unsigned long n_bytes, ndr_ref_t *ref)
2633299f39fSGordon Ross {
2643299f39fSGordon Ross unsigned char *data;
2653299f39fSGordon Ross
2663299f39fSGordon Ross data = (unsigned char *)nds->pdu_base_offset;
2673299f39fSGordon Ross data += pdu_offset;
2683299f39fSGordon Ross
2693299f39fSGordon Ross ndo_printf(nds, ref, "pad %d@%-3d", n_bytes, pdu_offset);
2703299f39fSGordon Ross
2713299f39fSGordon Ross bzero(data, n_bytes);
2723299f39fSGordon Ross return (1);
2733299f39fSGordon Ross }
2743299f39fSGordon Ross
2753299f39fSGordon Ross /*
2763299f39fSGordon Ross * ndo_get_pdu
2773299f39fSGordon Ross *
2783299f39fSGordon Ross * The swap flag is 1 if NDR knows that the byte-order in the PDU
2793299f39fSGordon Ross * is different from the local system.
2803299f39fSGordon Ross *
2813299f39fSGordon Ross * Returns 1 on success or 0 to indicate failure.
2823299f39fSGordon Ross */
2833299f39fSGordon Ross static int
ndo_get_pdu(ndr_stream_t * nds,unsigned long pdu_offset,unsigned long n_bytes,char * buf,int swap_bytes,ndr_ref_t * ref)2843299f39fSGordon Ross ndo_get_pdu(ndr_stream_t *nds, unsigned long pdu_offset,
2853299f39fSGordon Ross unsigned long n_bytes, char *buf, int swap_bytes, ndr_ref_t *ref)
2863299f39fSGordon Ross {
2873299f39fSGordon Ross unsigned char *data;
2883299f39fSGordon Ross char hexbuf[NDOBUFSZ];
2893299f39fSGordon Ross
2903299f39fSGordon Ross data = (unsigned char *)nds->pdu_base_offset;
2913299f39fSGordon Ross data += pdu_offset;
2923299f39fSGordon Ross
2933299f39fSGordon Ross ndo_hexfmt(data, n_bytes, swap_bytes, hexbuf, NDOBUFSZ);
2943299f39fSGordon Ross
2953299f39fSGordon Ross ndo_printf(nds, ref, "get %d@%-3d = %s",
2963299f39fSGordon Ross n_bytes, pdu_offset, hexbuf);
2973299f39fSGordon Ross
2983299f39fSGordon Ross if (!swap_bytes)
2993299f39fSGordon Ross bcopy(data, buf, n_bytes);
3003299f39fSGordon Ross else
3013299f39fSGordon Ross nds_bswap(data, (unsigned char *)buf, n_bytes);
3023299f39fSGordon Ross
3033299f39fSGordon Ross return (1);
3043299f39fSGordon Ross }
3053299f39fSGordon Ross
3063299f39fSGordon Ross /*
3073299f39fSGordon Ross * ndo_put_pdu
3083299f39fSGordon Ross *
3093299f39fSGordon Ross * This is a receiver makes right protocol. So we do not need
3103299f39fSGordon Ross * to be concerned about the byte-order of an outgoing PDU.
3113299f39fSGordon Ross */
3123299f39fSGordon Ross /*ARGSUSED*/
3133299f39fSGordon Ross static int
ndo_put_pdu(ndr_stream_t * nds,unsigned long pdu_offset,unsigned long n_bytes,char * buf,int swap_bytes,ndr_ref_t * ref)3143299f39fSGordon Ross ndo_put_pdu(ndr_stream_t *nds, unsigned long pdu_offset,
3153299f39fSGordon Ross unsigned long n_bytes, char *buf, int swap_bytes, ndr_ref_t *ref)
3163299f39fSGordon Ross {
3173299f39fSGordon Ross unsigned char *data;
3183299f39fSGordon Ross char hexbuf[NDOBUFSZ];
3193299f39fSGordon Ross
3203299f39fSGordon Ross data = (unsigned char *)nds->pdu_base_offset;
3213299f39fSGordon Ross data += pdu_offset;
3223299f39fSGordon Ross
3233299f39fSGordon Ross ndo_hexfmt((uint8_t *)buf, n_bytes, 0, hexbuf, NDOBUFSZ);
3243299f39fSGordon Ross
3253299f39fSGordon Ross ndo_printf(nds, ref, "put %d@%-3d = %s",
3263299f39fSGordon Ross n_bytes, pdu_offset, hexbuf);
3273299f39fSGordon Ross
3283299f39fSGordon Ross bcopy(buf, data, n_bytes);
3293299f39fSGordon Ross return (1);
3303299f39fSGordon Ross }
3313299f39fSGordon Ross
3323299f39fSGordon Ross static void
ndo_tattle(ndr_stream_t * nds,char * what,ndr_ref_t * ref)3333299f39fSGordon Ross ndo_tattle(ndr_stream_t *nds, char *what, ndr_ref_t *ref)
3343299f39fSGordon Ross {
3353299f39fSGordon Ross ndo_printf(nds, ref, what);
3363299f39fSGordon Ross }
3373299f39fSGordon Ross
3383299f39fSGordon Ross static void
ndo_tattle_error(ndr_stream_t * nds,ndr_ref_t * ref)3393299f39fSGordon Ross ndo_tattle_error(ndr_stream_t *nds, ndr_ref_t *ref)
3403299f39fSGordon Ross {
3413299f39fSGordon Ross unsigned char *data;
3423299f39fSGordon Ross char hexbuf[NDOBUFSZ];
3433299f39fSGordon Ross
3443299f39fSGordon Ross if (nds->pdu_base_addr != NULL) {
3453299f39fSGordon Ross data = (unsigned char *)nds->pdu_base_offset;
3463299f39fSGordon Ross if (ref)
3473299f39fSGordon Ross data += ref->pdu_offset;
3483299f39fSGordon Ross else
3493299f39fSGordon Ross data += nds->pdu_scan_offset;
3503299f39fSGordon Ross
3513299f39fSGordon Ross ndo_hexfmt(data, 16, 0, hexbuf, NDOBUFSZ);
3523299f39fSGordon Ross } else {
3533299f39fSGordon Ross bzero(hexbuf, NDOBUFSZ);
3543299f39fSGordon Ross }
3553299f39fSGordon Ross
3563299f39fSGordon Ross ndo_printf(nds, ref, "ERROR=%d REF=%d OFFSET=%d SIZE=%d/%d",
3573299f39fSGordon Ross nds->error, nds->error_ref, nds->pdu_scan_offset,
3583299f39fSGordon Ross nds->pdu_size, nds->pdu_max_size);
3593299f39fSGordon Ross ndo_printf(nds, ref, " %s", hexbuf);
3603299f39fSGordon Ross }
3613299f39fSGordon Ross
3623299f39fSGordon Ross /*
3633299f39fSGordon Ross * ndo_reset
3643299f39fSGordon Ross *
3653299f39fSGordon Ross * Reset a stream: zap the outer_queue. We don't need to tamper
3663299f39fSGordon Ross * with the stream heap: it's handled externally to the stream.
3673299f39fSGordon Ross */
3683299f39fSGordon Ross static int
ndo_reset(ndr_stream_t * nds)3693299f39fSGordon Ross ndo_reset(ndr_stream_t *nds)
3703299f39fSGordon Ross {
3713299f39fSGordon Ross ndo_printf(nds, 0, "reset");
3723299f39fSGordon Ross
3733299f39fSGordon Ross nds->pdu_size = 0;
3743299f39fSGordon Ross nds->pdu_scan_offset = 0;
3753299f39fSGordon Ross nds->outer_queue_head = 0;
3763299f39fSGordon Ross nds->outer_current = 0;
3773299f39fSGordon Ross nds->outer_queue_tailp = &nds->outer_queue_head;
3783299f39fSGordon Ross
3793299f39fSGordon Ross return (1);
3803299f39fSGordon Ross }
3813299f39fSGordon Ross
3823299f39fSGordon Ross /*
3833299f39fSGordon Ross * ndo_destruct
3843299f39fSGordon Ross *
3853299f39fSGordon Ross * Destruct a stream: zap the outer_queue.
3863299f39fSGordon Ross * Note: heap management (creation/destruction) is external to the stream.
3873299f39fSGordon Ross */
3883299f39fSGordon Ross static void
ndo_destruct(ndr_stream_t * nds)3893299f39fSGordon Ross ndo_destruct(ndr_stream_t *nds)
3903299f39fSGordon Ross {
3913299f39fSGordon Ross
3923299f39fSGordon Ross ndo_printf(nds, 0, "destruct");
3933299f39fSGordon Ross
3943299f39fSGordon Ross if (nds == NULL)
3953299f39fSGordon Ross return;
3963299f39fSGordon Ross
3973299f39fSGordon Ross if (nds->pdu_base_addr != NULL) {
3983299f39fSGordon Ross free(nds->pdu_base_addr);
3993299f39fSGordon Ross nds->pdu_base_addr = NULL;
4003299f39fSGordon Ross nds->pdu_base_offset = 0;
4013299f39fSGordon Ross }
4023299f39fSGordon Ross
4033299f39fSGordon Ross nds->outer_queue_head = 0;
4043299f39fSGordon Ross nds->outer_current = 0;
4053299f39fSGordon Ross nds->outer_queue_tailp = &nds->outer_queue_head;
4063299f39fSGordon Ross }
4073299f39fSGordon Ross
4083299f39fSGordon Ross /*
4093299f39fSGordon Ross * Printf style formatting for NDR operations.
4103299f39fSGordon Ross */
4113299f39fSGordon Ross void
ndo_printf(ndr_stream_t * nds,ndr_ref_t * ref,const char * fmt,...)4123299f39fSGordon Ross ndo_printf(ndr_stream_t *nds, ndr_ref_t *ref, const char *fmt, ...)
4133299f39fSGordon Ross {
4143299f39fSGordon Ross va_list ap;
4153299f39fSGordon Ross char buf[NDOBUFSZ];
4163299f39fSGordon Ross
4173299f39fSGordon Ross va_start(ap, fmt);
4183299f39fSGordon Ross (void) vsnprintf(buf, NDOBUFSZ, fmt, ap);
4193299f39fSGordon Ross va_end(ap);
4203299f39fSGordon Ross
4213299f39fSGordon Ross if (nds)
4223299f39fSGordon Ross ndo_fmt(nds, ref, buf);
4233299f39fSGordon Ross else
4243299f39fSGordon Ross ndo_trace(buf);
4253299f39fSGordon Ross }
4263299f39fSGordon Ross
4273299f39fSGordon Ross /*
4283299f39fSGordon Ross * Main output formatter for NDR operations.
4293299f39fSGordon Ross *
4303299f39fSGordon Ross * UI 03 ... rpc_vers get 1@0 = 5 {05}
4313299f39fSGordon Ross * UI 03 ... rpc_vers_minor get 1@1 = 0 {00}
4323299f39fSGordon Ross *
4333299f39fSGordon Ross * U Marshalling flag (M=marshal, U=unmarshal)
4343299f39fSGordon Ross * I Direction flag (I=in, O=out)
4353299f39fSGordon Ross * ... Field name
4363299f39fSGordon Ross * get PDU operation (get or put)
4373299f39fSGordon Ross * 1@0 Bytes @ offset (i.e. 1 byte at offset 0)
4383299f39fSGordon Ross * {05} Value
4393299f39fSGordon Ross */
4403299f39fSGordon Ross void
ndo_fmt(ndr_stream_t * nds,ndr_ref_t * ref,char * note)4413299f39fSGordon Ross ndo_fmt(ndr_stream_t *nds, ndr_ref_t *ref, char *note)
4423299f39fSGordon Ross {
4433299f39fSGordon Ross ndr_ref_t *p;
4443299f39fSGordon Ross int indent;
4453299f39fSGordon Ross char ref_name[NDOBUFSZ];
4463299f39fSGordon Ross char buf[NDOBUFSZ];
4473299f39fSGordon Ross int m_op_c = '?', dir_c = '?';
4483299f39fSGordon Ross
4493299f39fSGordon Ross switch (nds->m_op) {
4503299f39fSGordon Ross case 0: m_op_c = '-'; break;
4513299f39fSGordon Ross case NDR_M_OP_MARSHALL: m_op_c = 'M'; break;
4523299f39fSGordon Ross case NDR_M_OP_UNMARSHALL: m_op_c = 'U'; break;
4533299f39fSGordon Ross default: m_op_c = '?'; break;
4543299f39fSGordon Ross }
4553299f39fSGordon Ross
4563299f39fSGordon Ross switch (nds->dir) {
4573299f39fSGordon Ross case 0: dir_c = '-'; break;
4583299f39fSGordon Ross case NDR_DIR_IN: dir_c = 'I'; break;
4593299f39fSGordon Ross case NDR_DIR_OUT: dir_c = 'O'; break;
4603299f39fSGordon Ross default: dir_c = '?'; break;
4613299f39fSGordon Ross }
4623299f39fSGordon Ross
4633299f39fSGordon Ross for (indent = 0, p = ref; p; p = p->enclosing)
4643299f39fSGordon Ross indent++;
4653299f39fSGordon Ross
4663299f39fSGordon Ross if (ref && ref->name) {
4673299f39fSGordon Ross if (*ref->name == '[' && ref->enclosing) {
4683299f39fSGordon Ross indent--;
4693299f39fSGordon Ross (void) snprintf(ref_name, NDOBUFSZ, "%s%s",
4703299f39fSGordon Ross ref->enclosing->name, ref->name);
4713299f39fSGordon Ross } else {
4723299f39fSGordon Ross (void) strlcpy(ref_name, ref->name, NDOBUFSZ);
4733299f39fSGordon Ross }
4743299f39fSGordon Ross } else {
4753299f39fSGordon Ross (void) strlcpy(ref_name, "----", NDOBUFSZ);
4763299f39fSGordon Ross }
4773299f39fSGordon Ross
4783299f39fSGordon Ross (void) snprintf(buf, NDOBUFSZ, "%c%c %-.*s %-*s %s",
4793299f39fSGordon Ross m_op_c, dir_c, indent,
4803299f39fSGordon Ross "....+....+....+....+....+....",
4813299f39fSGordon Ross 20 - indent, ref_name, note);
4823299f39fSGordon Ross
4833299f39fSGordon Ross ndo_trace(buf);
4843299f39fSGordon Ross }
4853299f39fSGordon Ross
4863299f39fSGordon Ross /*ARGSUSED*/
4873299f39fSGordon Ross void
ndo_trace(const char * s)4883299f39fSGordon Ross ndo_trace(const char *s)
4893299f39fSGordon Ross {
4903299f39fSGordon Ross /*
4913299f39fSGordon Ross * Temporary fbt for dtrace until user space sdt enabled.
4923299f39fSGordon Ross */
4933299f39fSGordon Ross }
4943299f39fSGordon Ross
4953299f39fSGordon Ross /*
4963299f39fSGordon Ross * Format data as hex bytes (limit is 10 bytes):
4973299f39fSGordon Ross *
4983299f39fSGordon Ross * 1188689424 {10 f6 d9 46}
4993299f39fSGordon Ross *
5003299f39fSGordon Ross * If the input data is greater than 10 bytes, an ellipsis will
5013299f39fSGordon Ross * be inserted before the closing brace.
5023299f39fSGordon Ross */
5033299f39fSGordon Ross static void
ndo_hexfmt(uint8_t * data,int size,int swap_bytes,char * buf,int len)5043299f39fSGordon Ross ndo_hexfmt(uint8_t *data, int size, int swap_bytes, char *buf, int len)
5053299f39fSGordon Ross {
5063299f39fSGordon Ross char *p = buf;
5073299f39fSGordon Ross int interp = 1;
5083299f39fSGordon Ross uint32_t c;
5093299f39fSGordon Ross int n;
5103299f39fSGordon Ross int i;
5113299f39fSGordon Ross
5123299f39fSGordon Ross n = (size > 10) ? 10 : size;
5133299f39fSGordon Ross if (n > len-1)
5143299f39fSGordon Ross n = len-1;
5153299f39fSGordon Ross
5163299f39fSGordon Ross switch (size) {
5173299f39fSGordon Ross case 1:
5183299f39fSGordon Ross c = *(uint8_t *)data;
5193299f39fSGordon Ross break;
5203299f39fSGordon Ross case 2:
5213299f39fSGordon Ross if (swap_bytes == 0) /*LINTED E_BAD_PTR_CAST_ALIGN*/
5223299f39fSGordon Ross c = *(uint16_t *)data;
5233299f39fSGordon Ross else
5243299f39fSGordon Ross c = (data[0] << 8) | data[1];
5253299f39fSGordon Ross break;
5263299f39fSGordon Ross case 4:
5273299f39fSGordon Ross if (swap_bytes == 0) { /*LINTED E_BAD_PTR_CAST_ALIGN*/
5283299f39fSGordon Ross c = *(uint32_t *)data;
5293299f39fSGordon Ross } else {
5303299f39fSGordon Ross c = (data[0] << 24) | (data[1] << 16)
5313299f39fSGordon Ross | (data[2] << 8) | data[3];
5323299f39fSGordon Ross }
5333299f39fSGordon Ross break;
5343299f39fSGordon Ross default:
5353299f39fSGordon Ross c = 0;
5363299f39fSGordon Ross interp = 0;
5373299f39fSGordon Ross break;
5383299f39fSGordon Ross }
5393299f39fSGordon Ross
5403299f39fSGordon Ross if (interp)
5413299f39fSGordon Ross p += sprintf(p, "%4u {", c);
5423299f39fSGordon Ross else
5433299f39fSGordon Ross p += sprintf(p, " {");
5443299f39fSGordon Ross
5453299f39fSGordon Ross p += sprintf(p, "%02x", data[0]);
5463299f39fSGordon Ross for (i = 1; i < n; i++)
5473299f39fSGordon Ross p += sprintf(p, " %02x", data[i]);
5483299f39fSGordon Ross if (size > 10)
5493299f39fSGordon Ross p += sprintf(p, " ...}");
5503299f39fSGordon Ross else
5513299f39fSGordon Ross p += sprintf(p, "}");
5523299f39fSGordon Ross
5533299f39fSGordon Ross /*
5543299f39fSGordon Ross * Show c if it's a printable character or wide-char.
5553299f39fSGordon Ross */
5563299f39fSGordon Ross if (size < 4 && isprint((uint8_t)c))
5573299f39fSGordon Ross (void) sprintf(p, " %c", (uint8_t)c);
5583299f39fSGordon Ross }
559