ref: 796e5e6000677a39577d545e4603ce251e7cbfe9
dir: /sys/src/9/ip/pktmedium.c/
#include "u.h" #include "../port/lib.h" #include "mem.h" #include "dat.h" #include "fns.h" #include "../port/error.h" #include "ip.h" static void pktbind(Ipifc*, int, char**); static void pktunbind(Ipifc*); static void pktbwrite(Ipifc*, Block*, int, uchar*); static void pktin(Fs*, Ipifc*, Block*); Medium pktmedium = { .name= "pkt", .hsize= 0, .mintu= 0, .maxtu= 4*1024, .maclen= 0, .bind= pktbind, .unbind= pktunbind, .bwrite= pktbwrite, .pktin= pktin, .unbindonclose= 1, }; /* * called to bind an IP ifc to an packet device * called with ifc wlock'd */ static void pktbind(Ipifc*, int argc, char **argv) { USED(argc, argv); } /* * called with ifc wlock'd */ static void pktunbind(Ipifc*) { } /* * called by ipoput with a single packet to write */ static void pktbwrite(Ipifc *ifc, Block *bp, int, uchar*) { /* enqueue onto the conversation's rq */ if(ifc->conv->snoopers.ref > 0) qpass(ifc->conv->sq, copyblock(bp, BLEN(bp))); qpass(ifc->conv->rq, bp); } /* * called with ifc rlocked when someone write's to 'data' */ static void pktin(Fs *f, Ipifc *ifc, Block *bp) { if(ifc->lifc == nil) freeb(bp); else { if(ifc->conv->snoopers.ref > 0) qpass(ifc->conv->sq, copyblock(bp, BLEN(bp))); ipiput4(f, ifc, bp); } } void pktmediumlink(void) { addipmedium(&pktmedium); }