Add the Inferno license to files we got from Inferno
[akaros.git] / kern / src / net / ethermedium.c
index 3ce5298..f7bb15f 100644 (file)
@@ -1,4 +1,31 @@
-// INFERNO
+/* Copyright © 1994-1999 Lucent Technologies Inc.  All rights reserved.
+ * Portions Copyright © 1997-1999 Vita Nuova Limited
+ * Portions Copyright © 2000-2007 Vita Nuova Holdings Limited
+ *                                (www.vitanuova.com)
+ * Revisions Copyright © 2000-2007 Lucent Technologies Inc. and others
+ *
+ * Modified for the Akaros operating system:
+ * Copyright (c) 2013-2014 The Regents of the University of California
+ * Copyright (c) 2013-2015 Google Inc.
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in
+ * all copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE. */
+
 #include <vfs.h>
 #include <kfs.h>
 #include <slab.h>
@@ -62,11 +89,11 @@ struct medium ethermedium = {
        .pref2addr = etherpref2addr,
 };
 
-struct medium gbemedium = {
-       .name = "gbe",
+struct medium trexmedium = {
+       .name = "trex",
        .hsize = 14,
        .mintu = 60,
-       .maxtu = 9014,
+       .maxtu = 1514,
        .maclen = 6,
        .bind = etherbind,
        .unbind = etherunbind,
@@ -120,6 +147,25 @@ struct Etherarp {
 
 static char *nbmsg = "nonblocking";
 
+static unsigned int parsefeat(char *ptr)
+{
+       unsigned int feat = 0;
+
+       if (strstr(ptr, "ipck"))
+               feat |= NETF_IPCK;
+       if (strstr(ptr, "udpck"))
+               feat |= NETF_UDPCK;
+       if (strstr(ptr, "tcpck"))
+               feat |= NETF_TCPCK;
+       if (strstr(ptr, "padmin"))
+               feat |= NETF_PADMIN;
+       if (strstr(ptr, "sg"))
+               feat |= NETF_SG;
+       if (strstr(ptr, "tso"))
+               feat |= NETF_TSO;
+       return feat;
+}
+
 /*
  *  called to bind an IP ifc to an ethernet device
  *  called with ifc wlock'd
@@ -128,16 +174,16 @@ static void etherbind(struct Ipifc *ifc, int argc, char **argv)
 {
        ERRSTACK(1);
        struct chan *mchan4, *cchan4, *achan, *mchan6, *cchan6;
-       char addr[Maxpath];                     //char addr[2*KNAMELEN];
-       char dir[Maxpath];                      //char dir[2*KNAMELEN];
-       char *buf;
+       char *addr, *dir, *buf;
        int fd, cfd, n;
        char *ptr;
        Etherrock *er;
 
        if (argc < 2)
-               error(Ebadarg);
+               error(EINVAL, NULL);
 
+       addr = kmalloc(Maxpath, KMALLOC_WAIT);  //char addr[2*KNAMELEN];
+       dir = kmalloc(Maxpath, KMALLOC_WAIT);   //char addr[2*KNAMELEN];
        mchan4 = cchan4 = achan = mchan6 = cchan6 = NULL;
        buf = NULL;
        if (waserror()) {
@@ -153,6 +199,8 @@ static void etherbind(struct Ipifc *ifc, int argc, char **argv)
                        cclose(cchan6);
                if (buf != NULL)
                        kfree(buf);
+               kfree(addr);
+               kfree(dir);
                nexterror();
        }
 
@@ -162,12 +210,12 @@ static void etherbind(struct Ipifc *ifc, int argc, char **argv)
         *  the dial will fail if the type is already open on
         *  this device.
         */
-       snprintf(addr, sizeof(addr), "%s!0x800", argv[2]);
+       snprintf(addr, Maxpath, "%s!0x800", argv[2]);
        fd = kdial(addr, NULL, dir, &cfd);
        if (fd < 0)
-               error("dial 0x800 failed: %s", get_cur_errbuf());
-       mchan4 = commonfdtochan(fd, ORDWR, 0, 1);
-       cchan4 = commonfdtochan(cfd, ORDWR, 0, 1);
+               error(EFAIL, "dial 0x800 failed: %s", get_cur_errbuf());
+       mchan4 = commonfdtochan(fd, O_RDWR, 0, 1);
+       cchan4 = commonfdtochan(cfd, O_RDWR, 0, 1);
        sysclose(fd);
        sysclose(cfd);
 
@@ -179,21 +227,21 @@ static void etherbind(struct Ipifc *ifc, int argc, char **argv)
        /*
         *  get mac address and speed
         */
-       snprintf(addr, sizeof(addr), "%s/stats", dir);
-       fd = sysopen(addr, OREAD);
+       snprintf(addr, Maxpath, "%s/stats", dir);
+       fd = sysopen(addr, O_READ);
        if (fd < 0)
-               error("can't open ether stats: %s", get_cur_errbuf());
+               error(EFAIL, "can't open ether stats: %s", get_cur_errbuf());
 
        buf = kzmalloc(512, 0);
        n = sysread(fd, buf, 511);
        sysclose(fd);
        if (n <= 0)
-               error(Eio);
+               error(EIO, NULL);
        buf[n] = 0;
 
        ptr = strstr(buf, "addr: ");
        if (!ptr)
-               error(Eio);
+               error(EIO, NULL);
        ptr += 6;
        parsemac(ifc->mac, ptr, 6);
 
@@ -204,14 +252,22 @@ static void etherbind(struct Ipifc *ifc, int argc, char **argv)
        } else
                ifc->mbps = 100;
 
+
+       ptr = strstr(buf, "feat: ");
+       if (ptr) {
+               ptr += 6;
+               ifc->feat = parsefeat(ptr);
+       } else {
+               ifc->feat = 0;
+       }
        /*
         *  open arp conversation
         */
-       snprintf(addr, sizeof(addr), "%s!0x806", argv[2]);
+       snprintf(addr, Maxpath, "%s!0x806", argv[2]);
        fd = kdial(addr, NULL, NULL, NULL);
        if (fd < 0)
-               error("dial 0x806 failed: %s", get_cur_errbuf());
-       achan = commonfdtochan(fd, ORDWR, 0, 1);
+               error(EFAIL, "dial 0x806 failed: %s", get_cur_errbuf());
+       achan = commonfdtochan(fd, O_RDWR, 0, 1);
        sysclose(fd);
 
        /*
@@ -220,12 +276,12 @@ static void etherbind(struct Ipifc *ifc, int argc, char **argv)
         *  the dial will fail if the type is already open on
         *  this device.
         */
-       snprintf(addr, sizeof(addr), "%s!0x86DD", argv[2]);
+       snprintf(addr, Maxpath, "%s!0x86DD", argv[2]);
        fd = kdial(addr, NULL, dir, &cfd);
        if (fd < 0)
-               error("dial 0x86DD failed: %s", get_cur_errbuf());
-       mchan6 = commonfdtochan(fd, ORDWR, 0, 1);
-       cchan6 = commonfdtochan(cfd, ORDWR, 0, 1);
+               error(EFAIL, "dial 0x86DD failed: %s", get_cur_errbuf());
+       mchan6 = commonfdtochan(fd, O_RDWR, 0, 1);
+       cchan6 = commonfdtochan(cfd, O_RDWR, 0, 1);
        sysclose(fd);
        sysclose(cfd);
 
@@ -244,6 +300,8 @@ static void etherbind(struct Ipifc *ifc, int argc, char **argv)
        ifc->arg = er;
 
        kfree(buf);
+       kfree(addr);
+       kfree(dir);
        poperror();
 
        ktask("etherread4", etherread4, ifc);
@@ -270,8 +328,9 @@ static void etherunbind(struct Ipifc *ifc)
 #endif
 
        /* wait for readers to die */
-       while (er->arpp != 0 || er->read4p != 0 || er->read6p != 0) ;
-       udelay_sched(300 * 1000);
+       while (er->arpp != 0 || er->read4p != 0 || er->read6p != 0)
+               cpu_relax();
+       kthread_usleep(300 * 1000);
 
        if (er->mchan4 != NULL)
                cclose(er->mchan4);
@@ -288,6 +347,19 @@ static void etherunbind(struct Ipifc *ifc)
 }
 
 /*
+ * copy ethernet address
+ */
+static inline void etherfilladdr(uint16_t *pkt, uint16_t *dst, uint16_t *src)
+{
+       *pkt++ = *dst++;
+       *pkt++ = *dst++;
+       *pkt++ = *dst++;
+       *pkt++ = *src++;
+       *pkt++ = *src++;
+       *pkt = *src;
+}
+
+/*
  *  called by ipoput with a single block to write with ifc rlock'd
  */
 static void
@@ -298,10 +370,15 @@ etherbwrite(struct Ipifc *ifc, struct block *bp, int version, uint8_t * ip)
        uint8_t mac[6];
        Etherrock *er = ifc->arg;
 
-       /* get mac address of destination */
+       /* get mac address of destination.
+        *
+        * Locking is tricky here.  If we get arpent 'a' back, the f->arp is
+        * qlocked.  if multicastarp returns bp, then it unlocked it for us.  if
+        * not, sendarp or resolveaddr6 unlocked it for us.  yikes. */
        a = arpget(er->f->arp, bp, version, ifc, ip, mac);
        if (a) {
-               /* check for broadcast or multicast */
+               /* check for broadcast or multicast.  if it is either, this sorts that
+                * out and returns the bp for the first packet on the arp's hold list.*/
                bp = multicastarp(er->f, a, ifc->m, mac);
                if (bp == NULL) {
                        switch (version) {
@@ -322,13 +399,10 @@ etherbwrite(struct Ipifc *ifc, struct block *bp, int version, uint8_t * ip)
        bp = padblock(bp, ifc->m->hsize);
        if (bp->next)
                bp = concatblock(bp);
-       if (BLEN(bp) < ifc->mintu)
-               bp = adjustblock(bp, ifc->mintu);
        eh = (Etherhdr *) bp->rp;
 
        /* copy in mac addresses and ether type */
-       memmove(eh->s, ifc->mac, sizeof(eh->s));
-       memmove(eh->d, mac, sizeof(eh->d));
+       etherfilladdr((uint16_t *)bp->rp, (uint16_t *)mac, (uint16_t *)ifc->mac);
 
        switch (version) {
                case V4:
@@ -367,7 +441,7 @@ static void etherread4(void *a)
                return;
        }
        for (;;) {
-               bp = devtab[er->mchan4->type].bread(er->mchan4, ifc->maxtu, 0);
+               bp = devtab[er->mchan4->type].bread(er->mchan4, 128 * 1024, 0);
                if (!canrlock(&ifc->rwlock)) {
                        freeb(bp);
                        continue;
@@ -474,7 +548,8 @@ static void etherremmulti(struct Ipifc *ifc, uint8_t * a, uint8_t * unused)
 /*
  *  send an ethernet arp
  *  (only v4, v6 uses the neighbor discovery, rfc1970)
- */
+ *
+ * May drop packets on stale arps. */
 static void sendarp(struct Ipifc *ifc, struct arpent *a)
 {
        int n;
@@ -482,13 +557,17 @@ static void sendarp(struct Ipifc *ifc, struct arpent *a)
        Etherarp *e;
        Etherrock *er = ifc->arg;
 
-       /* don't do anything if it's been less than a second since the last */
+       /* don't do anything if it's been less than a second since the last.  ctime
+        * is set to 0 for the first time through.  we hold the f->arp qlock, so
+        * there shouldn't be a problem with another arp request for this same
+        * arpent coming down til we update ctime again. */
        if (NOW - a->ctime < 1000) {
                arprelease(er->f->arp, a);
                return;
        }
 
-       /* remove all but the last message */
+       /* remove all but the last message.  brho: this might be unnecessary.  we'll
+        * eventually send them.  but they should be quite stale at this point. */
        while ((bp = a->hold) != NULL) {
                if (bp == a->last)
                        break;
@@ -496,7 +575,7 @@ static void sendarp(struct Ipifc *ifc, struct arpent *a)
                freeblist(bp);
        }
 
-       /* try to keep it around for a second more */
+       /* update last sent time */
        a->ctime = NOW;
        arprelease(er->f->arp, a);
 
@@ -780,7 +859,7 @@ static struct block *multicastarp(struct Fs *f,
 linker_func_4(ethermediumlink)
 {
        addipmedium(&ethermedium);
-       addipmedium(&gbemedium);
+       addipmedium(&trexmedium);
 }
 
 static void etherpref2addr(uint8_t * pref, uint8_t * ea)