Searched refs:cv (Results 1 - 25 of 39) sorted by relevance

12

/vbox/src/libs/xpcom18a4/nsprpub/pr/src/md/windows/
H A Dw95cv.c62 AddThreadToCVWaitQueueInternal(PRThread *thred, struct _MDCVar *cv) argument
64 PR_ASSERT((cv->waitTail != NULL && cv->waitHead != NULL)
65 || (cv->waitTail == NULL && cv->waitHead == NULL));
66 cv->nwait += 1;
69 thred->md.prev = cv->waitTail;
70 if (cv->waitHead == NULL) {
71 cv->waitHead = thred;
73 cv
119 _MDCVar *cv = notified->cv[index].cv; local
243 _PR_MD_NEW_CV(_MDCVar *cv) argument
253 _PR_MD_FREE_CV(_MDCVar *cv) argument
262 _PR_MD_WAIT_CV(_MDCVar *cv, _MDLock *lock, PRIntervalTime timeout ) argument
327 _PR_MD_NOTIFY_CV(_MDCVar *cv, _MDLock *lock) argument
333 _PR_MD_NOTIFYALL_CV(_MDCVar *cv, _MDLock *lock) argument
[all...]
/vbox/src/libs/xpcom18a4/nsprpub/pr/src/cplus/
H A Drccv.cpp50 cv = PR_NewCondVar(lock->lock);
51 PR_ASSERT(NULL != cv);
57 if (NULL != cv) PR_DestroyCondVar(cv);
63 PR_ASSERT(NULL != cv);
64 if (NULL == cv)
70 rv = PR_WaitCondVar(cv, timeout.interval);
76 return PR_NotifyCondVar(cv);
81 return PR_NotifyAllCondVar(cv);
86 if (NULL == cv)
[all...]
H A Drccv.h79 PRCondVar *cv; local
/vbox/src/libs/xpcom18a4/nsprpub/pr/src/md/os2/
H A Dos2cv.c98 AddThreadToCVWaitQueueInternal(PRThread *thred, struct _MDCVar *cv) argument
100 PR_ASSERT((cv->waitTail != NULL && cv->waitHead != NULL)
101 || (cv->waitTail == NULL && cv->waitHead == NULL));
102 cv->nwait += 1;
105 thred->md.prev = cv->waitTail;
106 if (cv->waitHead == NULL) {
107 cv->waitHead = thred;
109 cv
155 _MDCVar *cv = notified->cv[index].cv; local
282 _PR_MD_NEW_CV(_MDCVar *cv) argument
292 _PR_MD_FREE_CV(_MDCVar *cv) argument
302 _PR_MD_WAIT_CV(_MDCVar *cv, _MDLock *lock, PRIntervalTime timeout ) argument
381 _PR_MD_NOTIFY_CV(_MDCVar *cv, _MDLock *lock) argument
428 _PR_MD_NOTIFYALL_CV(_MDCVar *cv, _MDLock *lock) argument
[all...]
/vbox/src/libs/xpcom18a4/nsprpub/pr/tests/
H A Ddceemu.c73 PRCondVar *cv = PRP_NewNakedCondVar(); local
84 rv = PRP_NakedNotify(cv);
88 rv = PRP_NakedBroadcast(cv);
92 rv = PRP_NakedWait(cv, ml, tenmsecs);
98 rv = PRP_NakedNotify(cv);
102 rv = PRP_NakedBroadcast(cv);
106 PRP_DestroyNakedCondVar(cv);
H A Dmany_cv.c72 PRCondVar **cv = NULL; local
107 cv = (PRCondVar**)PR_CALLOC(sizeof(PRCondVar*) * cvs);
108 PR_ASSERT(NULL != cv);
112 cv[index] = PR_NewCondVar(ml);
113 PR_ASSERT(NULL != cv[index]);
122 if (0 == ran) PR_NotifyAllCondVar(cv[nl]);
124 PR_NotifyCondVar(cv[nl]);
130 PR_DestroyCondVar(cv[index]);
132 PR_DELETE(cv);
H A Dlogger.c78 PRCondVar *cv; local
83 cv = PR_NewCondVar(ml);
89 PR_WaitCondVar(cv, PR_SecondsToInterval(1));
94 PR_DestroyCondVar(cv);
H A Dalarm.c177 PRCondVar *cv = PR_NewCondVar(ml); local
186 PR_ASSERT(PR_WaitCondVar(cv, interval) == PR_SUCCESS);
191 PR_DestroyCondVar(cv);
200 PRCondVar *cv; member in struct:AlarmData
218 rv = PR_NotifyCondVar(ad->cv);
225 PR_WaitCondVar(ad->cv, interval);
265 PRCondVar *cv = PR_NewCondVar(ml); local
268 ad.cv = cv;
285 PR_WaitCondVar(cv, PR_INTERVAL_NO_TIMEOU
340 PRCondVar *cv = PR_NewCondVar(ml); local
393 PRCondVar *cv = PR_NewCondVar(ml); local
[all...]
H A Dconcur.c69 PRCondVar *cv; member in struct:Context
86 PR_WaitCondVar(context->cv, PR_INTERVAL_NO_TIMEOUT);
130 context.cv = PR_NewCondVar(context.ml);
157 PR_NotifyCondVar(context.cv);
179 PR_DestroyCondVar(context.cv);
H A Dntioto.c98 PRCondVar *cv; variable
147 PR_WaitCondVar( cv, PR_INTERVAL_NO_TIMEOUT );
153 PR_NotifyCondVar( cv );
166 PR_WaitCondVar( cv, PR_INTERVAL_NO_TIMEOUT );
170 PR_NotifyCondVar( cv );
263 cv = PR_NewCondVar( ml );
308 PR_DestroyCondVar(cv);
H A Dintrupt.c67 static PRCondVar *cv = NULL; variable
80 rv = PR_WaitCondVar(cv, PR_INTERVAL_NO_TIMEOUT);
100 rv = PR_WaitCondVar(cv, 10);
112 rv = PR_WaitCondVar(cv, 10);
128 rv = PR_WaitCondVar(cv, 10);
148 rv = PR_WaitCondVar(cv, 10);
211 rv = PR_WaitCondVar(cv, PR_SecondsToInterval(4));
259 cv = PR_NewCondVar(ml);
334 PR_DestroyCondVar(cv);
H A Dswitch.c74 PRCondVar *cv; member in struct:Shared
104 status = PR_WaitCondVar(shared->cv, PR_INTERVAL_NO_TIMEOUT);
108 PR_NotifyCondVar(shared->next->cv);
176 home.cv = PR_NewCondVar(home.ml);
187 shared->cv = PR_NewCondVar(home.ml);
209 PR_NotifyCondVar(shared->cv);
212 status = PR_WaitCondVar(home.cv, PR_INTERVAL_NO_TIMEOUT);
254 PR_DestroyCondVar(shared->cv);
259 PR_DestroyCondVar(home.cv);
H A Dranfile.c82 PRCondVar *cv; member in struct:Hammer_s
238 PR_NotifyCondVar(cd->cv);
247 static PRCondVar *cv; variable
337 cv = PR_NewCondVar(ml);
355 hammer[active].cv = cv;
368 PR_WaitCondVar(cv, interleave); /* start new ones slowly */
390 PR_WaitCondVar(cv, PR_INTERVAL_NO_TIMEOUT);
420 PR_DestroyCondVar(cv);
H A Dinrval.c149 PRCondVar *cv = PR_NewCondVar(ml); local
155 rv = PR_WaitCondVar(cv, ticks);
166 PR_DestroyCondVar(cv);
H A Dlazyinit.c78 PRCondVar *cv = NULL; local
H A Dtmoacc.c62 PRCondVar *cv; member in struct:Shared
175 PR_NotifyCondVar(shared->cv);
217 shared->cv = PR_NewCondVar(shared->ml);
284 PR_WaitCondVar(shared->cv, PR_INTERVAL_NO_TIMEOUT);
315 PR_DestroyCondVar(shared->cv);
/vbox/src/VBox/Additions/x11/x11include/xproto-7.0.18/X11/
H A DXthreads.h56 # define xcondition_init(cv) condition_init(cv)
57 # define xcondition_clear(cv) condition_clear(cv)
58 # define xcondition_wait(cv,m) condition_wait(cv,m)
59 # define xcondition_signal(cv) condition_signal(cv)
60 # define xcondition_broadcast(cv) condition_broadcast(cv)
[all...]
/vbox/src/libs/xpcom18a4/nsprpub/pr/src/bthreads/
H A Dbtcvar.c56 PRCondVar *cv = PR_NEW( PRCondVar ); local
58 if( NULL != cv )
60 cv->lock = lock;
61 cv->sem = create_sem(0, "CVSem");
62 cv->handshakeSem = create_sem(0, "CVHandshake");
63 cv->signalSem = create_sem( 0, "CVSignal");
64 cv->signalBenCount = 0;
65 cv->ns = cv->nw = 0;
66 PR_ASSERT( cv
[all...]
/vbox/src/libs/xpcom18a4/nsprpub/pr/src/cplus/tests/
H A Dinterval.cpp55 RCCondition cv(&ml);
65 cv.SetTimeout(timeout);
71 rv = cv.Wait();
108 cv.SetTimeout(timeout);
116 rv = cv.Wait();
H A Dranfile.cpp96 RCCondition *cv; member in class:HammerData
159 cv = cond;
272 cv->Notify();
314 RCCondition cv(&ml);
356 cv.SetTimeout(interleave);
376 hammer[active] = new Hammer(thread_scope, &ml, &cv, limit);
399 while (hammer[poll]->action < HammerData::sg_done) cv.Wait();
/vbox/src/libs/xpcom18a4/nsprpub/pr/src/pthreads/
H A Dptsynch.c120 PRCondVar *cv = notified->cv[index].cv; local
121 PR_ASSERT(NULL != cv);
122 PR_ASSERT(0 != notified->cv[index].times);
123 if (-1 == notified->cv[index].times)
125 rv = pthread_cond_broadcast(&cv->cv);
130 while (notified->cv[index].times-- > 0)
132 rv = pthread_cond_signal(&cv
247 pt_TimedWait( pthread_cond_t *cv, pthread_mutex_t *ml, PRIntervalTime timeout) argument
328 PRCondVar *cv = PR_NEW(PRCondVar); local
1062 PRCondVar *cv; local
[all...]
H A Dptthread.c74 PRCondVar *cv; /* used to signal global things */ member in struct:_PT_Bookeeping
236 PR_WaitCondVar(pt_book.cv, PR_INTERVAL_NO_TIMEOUT);
242 PR_NotifyAllCondVar(pt_book.cv);
543 PR_NotifyAllCondVar(pt_book.cv);
568 PR_NotifyAllCondVar(pt_book.cv);
791 PRCondVar *cv; local
797 cv = thred->waiting;
798 if ((NULL != cv) && !thred->interrupt_blocked)
801 (void)PR_AtomicIncrement(&cv->notify_pending);
802 rv = pthread_cond_broadcast(&cv
848 PRCondVar *cv; local
[all...]
/vbox/src/recompiler/
H A Dcutils.c181 int cv; /* results of compare (bottom / top) */ local
374 cv = cmp(b_par, m2);
375 if (cv > 0) {
378 if (cv == 0) {
393 cv = cmp(t_par, m2);
394 if (cv < 0) {
397 if (cv == 0) {
/vbox/src/libs/xpcom18a4/nsprpub/pr/src/threads/
H A Dprcthr.c142 PRCondVar *cv; local
146 cv = PR_NewCondVar(_pr_sleeplock);
147 PR_ASSERT(cv != NULL);
153 rv = PR_WaitCondVar(cv, timeout - delta);
156 PR_DestroyCondVar(cv);
/vbox/src/libs/xpcom18a4/nsprpub/pr/src/misc/
H A Dprinit.c797 PRCondVar *cv; member in struct:__anon17244
803 mod_init.cv = PR_NewCondVar(mod_init.ml);
804 PR_ASSERT(NULL != mod_init.cv);
811 PR_DestroyCondVar(mod_init.cv);
812 mod_init.cv = NULL;
826 PR_NotifyAllCondVar(mod_init.cv);
831 PR_WaitCondVar(mod_init.cv, PR_INTERVAL_NO_TIMEOUT);
851 PR_NotifyAllCondVar(mod_init.cv);
856 PR_WaitCondVar(mod_init.cv, PR_INTERVAL_NO_TIMEOUT);

Completed in 76 milliseconds

12