kern_condvar.c

Version: - FREEBSD - FREEBSD-13-STABLE - FREEBSD-13-0 - FREEBSD-12-STABLE - FREEBSD-12-0 - FREEBSD-11-STABLE - FREEBSD-11-0 - FREEBSD-10-STABLE - FREEBSD-10-0 - FREEBSD-9-STABLE - FREEBSD-9-0 - FREEBSD-8-STABLE - FREEBSD-8-0 - FREEBSD-7-STABLE - FREEBSD-7-0 - FREEBSD-6-STABLE - FREEBSD-6-0 - FREEBSD-5-STABLE - FREEBSD-5-0 - FREEBSD-4-STABLE - FREEBSD-3-STABLE - FREEBSD22 - l41 - OPENBSD - linux-2.6 - MK84 - PLAN9 - xnu-8792
SearchContext: - none - 3 - 10

    1 #include <sys/condvar.h>
    2 #include <sys/spinlock2.h>
    3 #include <sys/systm.h>
    4 #include <sys/lock.h>
    5 
    6 void
    7 cv_init(struct cv *c, const char *desc)
    8 {
    9         c->cv_desc = desc;
   10         c->cv_waiters = 0;
   11         spin_init(&c->cv_lock);
   12 }
   13 
   14 void
   15 cv_destroy(struct cv *c)
   16 {
   17         spin_uninit(&c->cv_lock);
   18 }
   19 
   20 int
   21 _cv_timedwait(struct cv *c, struct lock *lk, int timo, int wakesig)
   22 {
   23         int flags = wakesig ? PCATCH : 0;
   24         int error;
   25 
   26         /*
   27          * Can interlock without critical section/spinlock as long
   28          * as we don't block before calling *sleep().  PINTERLOCKED
   29          * must be passed to the *sleep() to use the manual interlock
   30          * (else a new one is created which opens a timing race).
   31          */
   32         tsleep_interlock(c, flags);
   33 
   34         spin_lock(&c->cv_lock);
   35         c->cv_waiters++;
   36         spin_unlock(&c->cv_lock);
   37 
   38         if (lk)
   39                 error = lksleep(c, lk, flags | PINTERLOCKED, c->cv_desc, timo);
   40         else
   41                 error = tsleep(c, flags | PINTERLOCKED, c->cv_desc, timo);
   42 
   43         return (error);
   44 }
   45 
   46 void
   47 _cv_signal(struct cv *c, int broadcast)
   48 {
   49         spin_lock(&c->cv_lock);
   50         if (c->cv_waiters == 0) {
   51                 spin_unlock(&c->cv_lock);
   52         } else if (broadcast) {
   53                 c->cv_waiters = 0;
   54                 spin_unlock(&c->cv_lock);       /* must unlock first */
   55                 wakeup(c);
   56         } else {
   57                 c->cv_waiters--;
   58                 spin_unlock(&c->cv_lock);       /* must unlock first */
   59                 wakeup_one(c);
   60         }
   61 }
   62 
   63 int
   64 cv_has_waiters(const struct cv *c)
   65 {
   66         return (c->cv_waiters);
   67 }

Cache object: d1afc7ffbd965f1322bed23f52f44252

[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]

This page is part of the FreeBSD/Linux Linux Kernel Cross-Reference, and was automatically generated using a modified version of the LXR engine.

FreeBSD/Linux Kernel Cross Reference sys/kern/kern_condvar.c

FreeBSD/Linux Kernel Cross Reference
sys/kern/kern_condvar.c