Source-Changes-HG archive

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index][Old Index]

[src/trunk]: src/sys/rump/librump/rumpuser Add scheduling points around the i...



details:   https://anonhg.NetBSD.org/src/rev/94d46573239d
branches:  trunk
changeset: 748907:94d46573239d
user:      pooka <pooka%NetBSD.org@localhost>
date:      Mon Nov 09 18:00:26 2009 +0000

description:
Add scheduling points around the iothread call to biodone()

diffstat:

 sys/rump/librump/rumpuser/rumpuser_pth.c |  9 ++++++---
 1 files changed, 6 insertions(+), 3 deletions(-)

diffs (38 lines):

diff -r b1c7cc5a8fae -r 94d46573239d sys/rump/librump/rumpuser/rumpuser_pth.c
--- a/sys/rump/librump/rumpuser/rumpuser_pth.c  Mon Nov 09 17:11:29 2009 +0000
+++ b/sys/rump/librump/rumpuser/rumpuser_pth.c  Mon Nov 09 18:00:26 2009 +0000
@@ -1,4 +1,4 @@
-/*     $NetBSD: rumpuser_pth.c,v 1.36 2009/10/15 00:28:47 pooka Exp $  */
+/*     $NetBSD: rumpuser_pth.c,v 1.37 2009/11/09 18:00:26 pooka Exp $  */
 
 /*
  * Copyright (c) 2007 Antti Kantee.  All Rights Reserved.
@@ -30,7 +30,7 @@
 
 #include <sys/cdefs.h>
 #if !defined(lint)
-__RCSID("$NetBSD: rumpuser_pth.c,v 1.36 2009/10/15 00:28:47 pooka Exp $");
+__RCSID("$NetBSD: rumpuser_pth.c,v 1.37 2009/11/09 18:00:26 pooka Exp $");
 #endif /* !lint */
 
 #ifdef __linux__
@@ -131,7 +131,7 @@
        struct rumpuser_aio *rua;
        rump_biodone_fn biodone = arg;
        ssize_t rv;
-       int error;
+       int error, dummy;
 
        NOFAIL_ERRNO(pthread_mutex_lock(&rumpuser_aio_mtx.pthmtx));
        for (;;) {
@@ -168,7 +168,10 @@
 #endif
                        }
                }
+               rumpuser__klock(0);
                biodone(rua->rua_bp, rv, error);
+               rumpuser__kunlock(0, &dummy);
+               assert(dummy == 0);
                        
                rua->rua_bp = NULL;
 



Home | Main Index | Thread Index | Old Index