kproc -> ktask
authorBarret Rhoden <brho@cs.berkeley.edu>
Fri, 17 Jan 2014 20:31:23 +0000 (12:31 -0800)
committerBarret Rhoden <brho@cs.berkeley.edu>
Fri, 17 Jan 2014 20:31:23 +0000 (12:31 -0800)
With a cocci file added to PATCHPLAN9 for future files.

Note that our ktasks aren't exactly like kprocs (kthreads, no process
context, etc), so we'll need to review the specific functions being run.

14 files changed:
kern/src/net/arp.c
kern/src/net/bootp.c
kern/src/net/dhcp.c
kern/src/net/ethermedium.c
kern/src/net/igmp.c
kern/src/net/ihbootp.c
kern/src/net/loopbackmedium.c
kern/src/net/netdevmedium.c
kern/src/net/ppp.c
kern/src/net/pppmedium.c
kern/src/net/rudp.c
kern/src/net/tcp.c
scripts/PATCHPLAN9
scripts/spatch/kproc.cocci [new file with mode: 0644]

index b77cf7a..02b4afd 100644 (file)
@@ -62,7 +62,7 @@ arpinit(struct Fs *f)
        f->arp->f = f;
        f->arp->rxmt = NULL;
        f->arp->dropf = f->arp->dropl = NULL;
-       kproc("rxmitproc", rxmitproc, f->arp, 0);
+       ktask("rxmitproc", rxmitproc, f->arp);
 }
 
 /*
index 78bba83..a956132 100644 (file)
@@ -154,7 +154,7 @@ rbootp(Ipifc *ifc)
        done = 0;
        recv = 0;
 
-       kproc("rcvbootp", rcvbootp, (void*)dfd, KPDUPFDG);
+       ktask("rcvbootp", rcvbootp, (void *)dfd);
 
        /*
         * broadcast bootp's till we get a reply,
index 6447c73..37ff9c6 100644 (file)
@@ -289,7 +289,7 @@ rbootp(Ipifc *ifc)
 /* DHCPDISCOVER*/
                done = 0;
                recv = 0;
-               kproc("rcvbootp", rcvbootp, (void*)dfd, KPDUPFDG);
+               ktask("rcvbootp", rcvbootp, (void *)dfd);
                /* Prepare DHCPDISCOVER */      
                memset(&req, 0, sizeof(req));
                ipmove(req.raddr, IPv4bcast);
index 3b559af..7d9aa6e 100644 (file)
@@ -253,9 +253,9 @@ etherbind(struct Ipifc *ifc, int argc, char **argv)
        kfree(buf);
        poperror();
 
-       kproc("etherread4", etherread4, ifc, 0);
-       kproc("recvarpproc", recvarpproc, ifc, 0);
-       kproc("etherread6", etherread6, ifc, 0);
+       ktask("etherread4", etherread4, ifc);
+       ktask("recvarpproc", recvarpproc, ifc);
+       ktask("etherread6", etherread6, ifc);
 }
 
 /*
index 316e696..8952726 100644 (file)
@@ -285,7 +285,7 @@ igmpinit(Fs *fs)
        igmp.ptclsize = 0;
 
        igmpreportfn = igmpsendreport;
-       kproc("igmpproc", igmpproc, 0, 0);
+       ktask("igmpproc", igmpproc, 0);
 
        Fsproto(fs, &igmp);
 }
index 5eb6671..7d7b5f4 100644 (file)
@@ -244,7 +244,7 @@ rbootp(Ipifc *ifc)
        done = 0;
        recv = 0;
 
-       kproc("rcvbootp", rcvbootp, (void*)dfd, KPDUPFDG);
+       ktask("rcvbootp", rcvbootp, (void *)dfd);
 
        /*
         * broadcast bootp's till we get a reply,
index 35e3b5d..2009f77 100644 (file)
@@ -40,7 +40,7 @@ loopbackbind(struct Ipifc *ifc, int unused_int, char **unused_char_pp_t)
        ifc->arg = lb;
        ifc->mbps = 1000;
 
-       kproc("loopbackread", loopbackread, ifc, 0);
+       ktask("loopbackread", loopbackread, ifc);
 
 }
 
index c201656..f90f16a 100644 (file)
@@ -61,7 +61,7 @@ netdevbind(struct Ipifc *ifc, int argc, char **argv)
 
        ifc->arg = er;
 
-       kproc("netdevread", netdevread, ifc, 0);
+       ktask("netdevread", netdevread, ifc);
 }
 
 /*
index bf4a188..54eab8f 100644 (file)
@@ -116,7 +116,7 @@ init(PPP* ppp)
                ppp->ipcp->proto = Pipcp;
                ppp->ipcp->state = Sclosed;
 
-               kproc("ppptimer", ppptimer, ppp, KPDUPPG|KPDUPFDG);
+               ktask("ppptimer", ppptimer, ppp);
        }
 
        pinit(ppp, ppp->lcp);
index ed4aec2..d21ae82 100644 (file)
@@ -85,7 +85,7 @@ pppbind(Ipifc *ifc, int argc, char **argv)
        if(pppopen(ppp, argv[2], ipaddr, remip, mtu, framing, chapname, secret) == nil)
                error("ppp open failed");
        poperror();
-       kproc("pppreader", pppreader, ifc, KPDUPPG|KPDUPFDG);
+       ktask("pppreader", pppreader, ifc);
 }
 
 static void
index 15b69b5..c5b8655 100644 (file)
@@ -205,7 +205,7 @@ rudpstartackproc(Proto *rudp)
                qlock(&rpriv->apl);
                if(rpriv->ackprocstarted == 0){
                        sprint(kpname, "#I%drudpack", rudp->f->dev);
-                       kproc(kpname, relackproc, rudp, 0);
+                       ktask(kpname, relackproc, rudp);
                        rpriv->ackprocstarted = 1;
                }
                qunlock(&rpriv->apl);
index c05756f..474920b 100644 (file)
@@ -866,7 +866,7 @@ tcpstart(Conv *s, int mode)
                qlock(&tpriv->apl);
                if(tpriv->ackprocstarted == 0){
                        sprint(kpname, "#I%dtcpack", s->p->f->dev);
-                       kproc(kpname, tcpackproc, s->p, 0);
+                       ktask(kpname, tcpackproc, s->p);
                        tpriv->ackprocstarted = 1;
                }
                qunlock(&tpriv->apl);
index 464a328..bf357c0 100644 (file)
@@ -26,6 +26,7 @@ spatch --sp-file scripts/spatch/scalar.cocci --in-place $1
 spatch --sp-file scripts/spatch/typedef.cocci --in-place $1
 spatch --sp-file scripts/spatch/locks.cocci --in-place $1
 spatch --sp-file scripts/spatch/rendez.cocci --in-place $1
+spatch --sp-file scripts/spatch/kproc.cocci --in-place $1
 # include fixing. Idempotent. 
 sh scripts/fixincludes $1
 # Scalars. Idempotent.
diff --git a/scripts/spatch/kproc.cocci b/scripts/spatch/kproc.cocci
new file mode 100644 (file)
index 0000000..ce3019a
--- /dev/null
@@ -0,0 +1,8 @@
+@@
+expression KP0;
+expression KP1;
+expression KP2;
+expression KP3;
+@@
+-kproc(KP0, KP1, KP2, KP3);
++ktask(KP0, KP1, KP2);