[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.11

version 1.1.2.7, 2013/06/25 08:45:50 version 1.1.2.11, 2013/06/25 10:58:22
Line 97  allocZCbuf(u_int len) Line 97  allocZCbuf(u_int len)
 int  int
 io_etherOpen(const char *csIface, int flags, int whdr, u_int *buflen, void **zcbuf)  io_etherOpen(const char *csIface, int flags, int whdr, u_int *buflen, void **zcbuf)
 {  {
        int n = 1, eth = -1;        int eth = -1;
         register int i;          register int i;
         char szStr[STRSIZ];          char szStr[STRSIZ];
         struct ifreq ifr;          struct ifreq ifr;
           u_int n = 1;
   
   #ifndef __FreeBSD__
           if (zcbuf) {
                   io_SetErr(ENOTSUP, "bpf zero copy buffer mode is not supported");
                   return -1;
           }
   #endif
   
         for (i = 0; i < BPF_DEV_MAX; i++) {          for (i = 0; i < BPF_DEV_MAX; i++) {
                 memset(szStr, 0, sizeof szStr);                  memset(szStr, 0, sizeof szStr);
                 snprintf(szStr, sizeof szStr, "/dev/bpf%d", i);                  snprintf(szStr, sizeof szStr, "/dev/bpf%d", i);
Line 124  io_etherOpen(const char *csIface, int flags, int whdr, Line 132  io_etherOpen(const char *csIface, int flags, int whdr,
                 close(eth);                  close(eth);
                 return -1;                  return -1;
         }          }
        if (buflen && *buflen) {
                if (!zcbuf) {        if (!zcbuf) {
                        if (ioctl(eth, BIOCSBLEN, buflen) == -1) {                if (ioctl(eth, BIOCGBLEN, &n) == -1) {
                                LOGERR;                        LOGERR;
                                close(eth);                        close(eth);
                                return -1;                        return -1;
                        }                } else
                } else {                        n = (buflen && *buflen) ? MIN(n, *buflen) : n;
                 if (ioctl(eth, BIOCSBLEN, &n) == -1) {
                         LOGERR;
                         close(eth);
                         return -1;
                 }
                 if (buflen && *buflen)
                         *buflen = n;
         } else {
 #ifdef __FreeBSD__  #ifdef __FreeBSD__
                        n = BPF_BUFMODE_ZBUF;                n = BPF_BUFMODE_ZBUF;
                        if (ioctl(eth, BIOCSETBUFMODE, &n) == -1) {                if (ioctl(eth, BIOCSETBUFMODE, &n) == -1) {
                                LOGERR;                        LOGERR;
                                close(eth);                        close(eth);
                                return -1;                        return -1;
                        } 
                        if (ioctl(eth, BIOCGETZMAX, &n) == -1) { 
                                LOGERR; 
                                close(eth); 
                                return -1; 
                        } else 
                                *buflen = MIN(n, *buflen); 
                        if (!(*zcbuf = allocZCbuf(*buflen))) { 
                                close(eth); 
                                return -1; 
                        } 
                        if (ioctl(eth, BIOCSETZBUF, (struct bpf_zbuf*) *zcbuf) == -1) { 
                                LOGERR; 
                                io_etherClose(eth, zcbuf); 
                                return -1; 
                        } 
#endif 
                 }                  }
                   if (ioctl(eth, BIOCGETZMAX, &n) == -1) {
                           LOGERR;
                           close(eth);
                           return -1;
                   } else
                           n = (buflen && *buflen) ? MIN(n, *buflen) : n;
                   if (!(*zcbuf = allocZCbuf(n))) {
                           close(eth);
                           return -1;
                   }
                   if (ioctl(eth, BIOCSETZBUF, (struct bpf_zbuf*) *zcbuf) == -1) {
                           LOGERR;
                           io_etherClose(eth, zcbuf);
                           return -1;
                   }
                   if (buflen && *buflen)
                           *buflen = n;
   #endif
         }          }
   
         if (csIface)          if (csIface)
                 strlcpy(szStr, csIface, sizeof szStr);                  strlcpy(szStr, csIface, sizeof szStr);
         else if (io_get1stiface(szStr, sizeof szStr) == -1) {          else if (io_get1stiface(szStr, sizeof szStr) == -1) {
                 io_etherClose(eth, zcbuf);                  io_etherClose(eth, zcbuf);
                 return -1;                  return -1;
         }          }
           memset(&ifr, 0, sizeof ifr);
         strlcpy(ifr.ifr_name, szStr, sizeof ifr.ifr_name);          strlcpy(ifr.ifr_name, szStr, sizeof ifr.ifr_name);
         if (ioctl(eth, BIOCSETIF, &ifr) == -1) {          if (ioctl(eth, BIOCSETIF, &ifr) == -1) {
                 LOGERR;                  LOGERR;
Line 198  io_etherSend(int eth, const void *buf, size_t buflen) Line 217  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 239  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
                         io_SetErr(EAGAIN, "kernel owns the buffer");
         } 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);
                 } else
                         io_SetErr(EAGAIN, "kernel owns the buffer");
         }          }
   
         return rlen;          return rlen;
Removed from v.1.1.2.7  
changed lines
  Added in v.1.1.2.11

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