[BACK]Return to bpf.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / libaitio / src

Diff for /libaitio/src/bpf.c between versions 1.1.2.7 and 1.1.2.8

version 1.1.2.7, 2013/06/25 08:45:50 version 1.1.2.8, 2013/06/25 08:53:22
Line 198  io_etherSend(int eth, const void *buf, size_t buflen) Line 198  io_etherSend(int eth, const void *buf, size_t buflen)
 }  }
   
 #ifdef __FreeBSD__  #ifdef __FreeBSD__
   static inline void
   ackZCbuf(struct bpf_zbuf_header * __restrict bzh)
   {
           atomic_store_rel_int(&bzh->bzh_user_gen, bzh->bzh_kernel_gen);
   }
   
   static inline int
   chkZCbuf(struct bpf_zbuf_header * __restrict bzh)
   {
           /* return true if userspace owns buffer, and false otherwise. */
           return (bzh->bzh_user_gen != atomic_load_acq_int(&bzh->bzh_kernel_gen));
   }
   
 static inline ssize_t  static inline ssize_t
 nextZCbuf(void ** __restrict zcache, struct bpf_zbuf * __restrict zbuf,   nextZCbuf(void ** __restrict zcache, struct bpf_zbuf * __restrict zbuf, 
                 const void * __restrict buf)                  const void * __restrict buf)
Line 207  nextZCbuf(void ** __restrict zcache, struct bpf_zbuf * Line 220  nextZCbuf(void ** __restrict zcache, struct bpf_zbuf *
   
         if (!*zcache || *zcache == zbuf->bz_bufb) {          if (!*zcache || *zcache == zbuf->bz_bufb) {
                 bzh = (struct bpf_zbuf_header *) zbuf->bz_bufa;                  bzh = (struct bpf_zbuf_header *) zbuf->bz_bufa;
                if (bzh->bzh_user_gen != atomic_load_acq_int(&bzh->bzh_kernel_gen)) {                if (chkZCbuf(bzh)) {
                         rlen = atomic_load_acq_int(&bzh->bzh_kernel_len);                          rlen = atomic_load_acq_int(&bzh->bzh_kernel_len);
                         *zcache = zbuf->bz_bufa;                          *zcache = zbuf->bz_bufa;
                         if (buf)                          if (buf)
                                 buf = ((caddr_t) *zcache) + sizeof(struct bpf_zbuf_header);                                  buf = ((caddr_t) *zcache) + sizeof(struct bpf_zbuf_header);
                           ackZCbuf(bzh);
                 }                  }
         } else if (*zcache == zbuf->bz_bufa) {          } else if (*zcache == zbuf->bz_bufa) {
                 bzh = (struct bpf_zbuf_header *) zbuf->bz_bufb;                  bzh = (struct bpf_zbuf_header *) zbuf->bz_bufb;
                if (bzh->bzh_user_gen != atomic_load_acq_int(&bzh->bzh_kernel_gen)) {                if (chkZCbuf(bzh)) {
                         rlen = atomic_load_acq_int(&bzh->bzh_kernel_len);                          rlen = atomic_load_acq_int(&bzh->bzh_kernel_len);
                         *zcache = zbuf->bz_bufb;                          *zcache = zbuf->bz_bufb;
                         if (buf)                          if (buf)
                                 buf = ((caddr_t) *zcache) + sizeof(struct bpf_zbuf_header);                                  buf = ((caddr_t) *zcache) + sizeof(struct bpf_zbuf_header);
                           ackZCbuf(bzh);
                 }                  }
         }          }
   
Removed from v.1.1.2.7  
changed lines
  Added in v.1.1.2.8

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>