Home | History | Annotate | Line # | Download | only in libnpftest
npf_test_subr.c revision 1.7
      1  1.7  rmind /*	$NetBSD: npf_test_subr.c,v 1.7 2014/02/05 03:30:13 rmind Exp $	*/
      2  1.1  rmind 
      3  1.1  rmind /*
      4  1.1  rmind  * NPF initialisation and handler routines.
      5  1.1  rmind  *
      6  1.1  rmind  * Public Domain.
      7  1.1  rmind  */
      8  1.1  rmind 
      9  1.1  rmind #include <sys/types.h>
     10  1.7  rmind #include <sys/cprng.h>
     11  1.1  rmind #include <net/if.h>
     12  1.1  rmind #include <net/if_types.h>
     13  1.1  rmind 
     14  1.1  rmind #include "npf_impl.h"
     15  1.1  rmind #include "npf_test.h"
     16  1.1  rmind 
     17  1.1  rmind /* State of the current stream. */
     18  1.1  rmind static npf_state_t	cstream_state;
     19  1.1  rmind static void *		cstream_ptr;
     20  1.1  rmind static bool		cstream_retval;
     21  1.1  rmind 
     22  1.4  rmind static void		npf_state_sample(npf_state_t *, bool);
     23  1.4  rmind 
     24  1.4  rmind void
     25  1.4  rmind npf_test_init(void)
     26  1.4  rmind {
     27  1.4  rmind 	npf_state_setsampler(npf_state_sample);
     28  1.4  rmind }
     29  1.4  rmind 
     30  1.1  rmind int
     31  1.1  rmind npf_test_load(const void *xml)
     32  1.1  rmind {
     33  1.1  rmind 	prop_dictionary_t npf_dict = prop_dictionary_internalize(xml);
     34  1.1  rmind 	return npfctl_reload(0, npf_dict);
     35  1.1  rmind }
     36  1.1  rmind 
     37  1.6  rmind ifnet_t *
     38  1.6  rmind npf_test_addif(const char *ifname, bool reg, bool verbose)
     39  1.3  rmind {
     40  1.3  rmind 	ifnet_t *ifp = if_alloc(IFT_OTHER);
     41  1.3  rmind 
     42  1.3  rmind 	/*
     43  1.3  rmind 	 * This is a "fake" interface with explicitly set index.
     44  1.6  rmind 	 * Note: test modules may not setup pfil(9) hooks and if_attach()
     45  1.6  rmind 	 * may not trigger npf_ifmap_attach(), so we call it manually.
     46  1.3  rmind 	 */
     47  1.3  rmind 	strlcpy(ifp->if_xname, ifname, sizeof(ifp->if_xname));
     48  1.3  rmind 	ifp->if_dlt = DLT_NULL;
     49  1.6  rmind 	ifp->if_index = 0;
     50  1.3  rmind 	if_attach(ifp);
     51  1.3  rmind 	if_alloc_sadl(ifp);
     52  1.6  rmind 
     53  1.6  rmind 	npf_ifmap_attach(ifp);
     54  1.6  rmind 	if (reg) {
     55  1.6  rmind 		npf_ifmap_register(ifname);
     56  1.6  rmind 	}
     57  1.6  rmind 
     58  1.6  rmind 	if (verbose) {
     59  1.6  rmind 		printf("+ Interface %s\n", ifname);
     60  1.6  rmind 	}
     61  1.6  rmind 	return ifp;
     62  1.3  rmind }
     63  1.3  rmind 
     64  1.6  rmind ifnet_t *
     65  1.3  rmind npf_test_getif(const char *ifname)
     66  1.3  rmind {
     67  1.6  rmind 	return ifunit(ifname);
     68  1.3  rmind }
     69  1.3  rmind 
     70  1.1  rmind /*
     71  1.1  rmind  * State sampler - this routine is called from inside of NPF state engine.
     72  1.1  rmind  */
     73  1.4  rmind static void
     74  1.1  rmind npf_state_sample(npf_state_t *nst, bool retval)
     75  1.1  rmind {
     76  1.1  rmind 	/* Pointer will serve as an ID. */
     77  1.1  rmind 	cstream_ptr = nst;
     78  1.1  rmind 	memcpy(&cstream_state, nst, sizeof(npf_state_t));
     79  1.1  rmind 	cstream_retval = retval;
     80  1.1  rmind }
     81  1.1  rmind 
     82  1.1  rmind int
     83  1.6  rmind npf_test_statetrack(const void *data, size_t len, ifnet_t *ifp,
     84  1.1  rmind     bool forw, int64_t *result)
     85  1.1  rmind {
     86  1.1  rmind 	struct mbuf *m;
     87  1.1  rmind 	int i = 0, error;
     88  1.1  rmind 
     89  1.1  rmind 	m = mbuf_getwithdata(data, len);
     90  1.6  rmind 	error = npf_packet_handler(NULL, &m, ifp, forw ? PFIL_OUT : PFIL_IN);
     91  1.1  rmind 	if (error) {
     92  1.1  rmind 		assert(m == NULL);
     93  1.1  rmind 		return error;
     94  1.1  rmind 	}
     95  1.1  rmind 	assert(m != NULL);
     96  1.1  rmind 	m_freem(m);
     97  1.1  rmind 
     98  1.1  rmind 	const int di = forw ? NPF_FLOW_FORW : NPF_FLOW_BACK;
     99  1.1  rmind 	npf_tcpstate_t *fstate = &cstream_state.nst_tcpst[di];
    100  1.1  rmind 	npf_tcpstate_t *tstate = &cstream_state.nst_tcpst[!di];
    101  1.1  rmind 
    102  1.1  rmind 	result[i++] = (intptr_t)cstream_ptr;
    103  1.1  rmind 	result[i++] = cstream_retval;
    104  1.1  rmind 	result[i++] = cstream_state.nst_state;
    105  1.1  rmind 
    106  1.1  rmind 	result[i++] = fstate->nst_end;
    107  1.1  rmind 	result[i++] = fstate->nst_maxend;
    108  1.1  rmind 	result[i++] = fstate->nst_maxwin;
    109  1.2  rmind 	result[i++] = fstate->nst_wscale;
    110  1.1  rmind 
    111  1.1  rmind 	result[i++] = tstate->nst_end;
    112  1.1  rmind 	result[i++] = tstate->nst_maxend;
    113  1.1  rmind 	result[i++] = tstate->nst_maxwin;
    114  1.2  rmind 	result[i++] = tstate->nst_wscale;
    115  1.1  rmind 
    116  1.1  rmind 	return 0;
    117  1.1  rmind }
    118  1.7  rmind 
    119  1.7  rmind /*
    120  1.7  rmind  * Need to override for cprng_fast32() -- we need deterministic PRNG.
    121  1.7  rmind  */
    122  1.7  rmind uint32_t
    123  1.7  rmind _arc4random(void)
    124  1.7  rmind {
    125  1.7  rmind 	return random();
    126  1.7  rmind }
    127