qio: remove qproduce()
[akaros.git] / kern / drivers / dev / mnt.c
index fbff606..b9036cc 100644 (file)
@@ -188,7 +188,7 @@ long mntversion(struct chan *c, char *version, int msize, int returnlen)
                }
                if (returnlen > 0) {
                        if (returnlen < k)
-                               error(ENAMETOOLONG, NULL);
+                               error(ENAMETOOLONG, ERROR_FIXME);
                        memmove(version, buf, k);
                }
                return k;
@@ -285,7 +285,7 @@ long mntversion(struct chan *c, char *version, int msize, int returnlen)
        k = strlen(f.version);
        if (returnlen > 0) {
                if (returnlen < k)
-                       error(ENAMETOOLONG, NULL);
+                       error(ENAMETOOLONG, ERROR_FIXME);
                memmove(version, f.version, k);
        }
 
@@ -304,7 +304,7 @@ struct chan *mntauth(struct chan *c, char *spec)
                mntversion(c, VERSION9P, MAXRPC, 0);
                m = c->mux;
                if (m == NULL)
-                       error(EINVAL, NULL);
+                       error(EINVAL, ERROR_FIXME);
        }
 
        c = mntchan();
@@ -366,7 +366,7 @@ static struct chan *mntattach(char *muxattach)
                mntversion(c, NULL, 0, 0);
                m = c->mux;
                if (m == NULL)
-                       error(EINVAL, NULL);
+                       error(EINVAL, ERROR_FIXME);
        }
 
        c = mntchan();
@@ -440,7 +440,7 @@ static struct walkqid *mntwalk(struct chan *c, struct chan *nc, char **name,
                error(EFAIL, "devmnt: too many name elements");
        alloc = 0;
        wq = kzmalloc(sizeof(struct walkqid) + nname * sizeof(struct qid),
-                                 KMALLOC_WAIT);
+                                 MEM_WAIT);
        if (waserror()) {
                if (alloc && wq->clone != NULL)
                        cclose(wq->clone);
@@ -515,7 +515,7 @@ static int mntstat(struct chan *c, uint8_t * dp, int n)
        struct mntrpc *r;
 
        if (n < BIT16SZ)
-               error(EINVAL, NULL);
+               error(EINVAL, ERROR_FIXME);
        m = mntchk(c);
        r = mntralloc(c, m->msize);
        if (waserror()) {
@@ -825,7 +825,7 @@ void mountrpc(struct mnt *m, struct mntrpc *r)
                        } else
                                error(EFAIL, r->reply.ename);
                case Rflush:
-                       error(EINTR, NULL);
+                       error(EINTR, ERROR_FIXME);
                default:
                        if (t == r->request.type + 1)
                                break;
@@ -839,7 +839,7 @@ void mountrpc(struct mnt *m, struct mntrpc *r)
                                ("mnt: proc %s %lu: mismatch from %s %s rep 0x%p tag %d fid %d T%d R%d rp %d\n",
                                 "current->text", "current->pid", sn, cn, r, r->request.tag,
                                 r->request.fid, r->request.type, r->reply.type, r->reply.tag);
-                       error(EPROTO, NULL);
+                       error(EPROTO, ERROR_FIXME);
        }
 }
 
@@ -878,7 +878,7 @@ void mountio(struct mnt *m, struct mntrpc *r)
        if (n < 0)
                panic("bad message type in mountio");
        if (devtab[m->c->type].write(m->c, r->rpc, n, 0) != n)
-               error(EIO, NULL);
+               error(EIO, ERROR_FIXME);
 /*     r->stime = fastticks(NULL); */
        r->reqlen = n;
 
@@ -899,7 +899,7 @@ void mountio(struct mnt *m, struct mntrpc *r)
        spin_unlock(&m->lock);
        while (r->done == 0) {
                if (mntrpcread(m, r) < 0)
-                       error(EIO, NULL);
+                       error(EIO, ERROR_FIXME);
                mountmux(m, r);
        }
        mntgate(m);
@@ -984,7 +984,7 @@ int mntrpcread(struct mnt *m, struct mntrpc *r)
                        l = &(b->next);
                } else {
                        /* split block and put unused bit back */
-                       nb = allocb(i - len);
+                       nb = block_alloc(i - len, MEM_WAIT);
                        memmove(nb->wp, b->rp + len, i - len);
                        b->wp = b->rp + len;
                        nb->wp += i - len;
@@ -1121,7 +1121,7 @@ struct mntrpc *mntralloc(struct chan *c, uint32_t msize)
                 * The header is split from the data buffer as
                 * mountmux may swap the buffer with another header.
                 */
-               new->rpc = kzmalloc(msize, KMALLOC_WAIT);
+               new->rpc = kzmalloc(msize, MEM_WAIT);
                if (new->rpc == NULL) {
                        kfree(new);
                        spin_unlock(&mntalloc.l);
@@ -1139,7 +1139,7 @@ struct mntrpc *mntralloc(struct chan *c, uint32_t msize)
                mntalloc.nrpcfree--;
                if (new->rpclen < msize) {
                        kfree(new->rpc);
-                       new->rpc = kzmalloc(msize, KMALLOC_WAIT);
+                       new->rpc = kzmalloc(msize, MEM_WAIT);
                        if (new->rpc == NULL) {
                                kfree(new);
                                mntalloc.nrpcused--;