ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-01-22 20:38:05 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

another attempt to whip Monitor::wait into shape

Browse Source
This commit is contained in:
Joel Dice 2008-01-16 15:17:28 -07:00
parent bb85f5c94d
commit 7a7c36f8e0
2 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/posix.cpp
View File

@ -305,16 +305,13 @@ class MySystem: public System {
expect(s, rv == 0 or rv == EINTR); expect(s, rv == 0 or rv == EINTR);
} }
notified = ((t->flags & Notified) == Notified); notified = ((t->flags & Notified) != 0);
t->flags = 0; t->flags = 0;
t->next = 0;
if (t->r->interrupted()) { interrupted = t->r->interrupted();
if (interrupted) {
t->r->setInterrupted(false); t->r->setInterrupted(false);
interrupted = true;
} else {
interrupted = false;
} }
} }
@ -324,6 +321,8 @@ class MySystem: public System {
remove(t); remove(t);
} }
t->next = 0;
owner_ = t; owner_ = t;
this->depth = depth; this->depth = depth;

11
src/windows.cpp
View File

@ -275,16 +275,13 @@ class MySystem: public System {
r = WaitForSingleObject(t->mutex, INFINITE); r = WaitForSingleObject(t->mutex, INFINITE);
assert(s, r == WAIT_OBJECT_0); assert(s, r == WAIT_OBJECT_0);
notified = ((t->flags & Notified) == Notified); notified = ((t->flags & Notified) != 0);
t->flags = 0; t->flags = 0;
t->next = 0;
if (t->r->interrupted()) { interrupted = t->r->interrupted();
if (interrupted) {
t->r->setInterrupted(false); t->r->setInterrupted(false);
interrupted = true;
} else {
interrupted = false;
} }
} }
@ -295,6 +292,8 @@ class MySystem: public System {
remove(t); remove(t);
} }
t->next = 0;
owner_ = t; owner_ = t;
this->depth = depth; this->depth = depth;