void
internal_lock_mutex(iMux* mux)
{
- assert(blockInts == 1);
+ assert(blockInts > 0);
if (mux->holder == 0)
{
{
thread* tid;
- assert(blockInts == 1);
+ assert(blockInts > 0);
assert(mux->holder == currentThread);
exceptionptr = native_new_and_init(class_java_lang_IllegalMonitorStateException);
}
- assert(blockInts == 1);
+ assert(blockInts > 0);
count = mux->count;
mux->holder = 0;
exceptionptr = native_new_and_init(class_java_lang_IllegalMonitorStateException);
}
- assert(blockInts == 1);
+ assert(blockInts > 0);
/* Remove one thread from cv list */
if (cv->cvWaiters != 0) {
exceptionptr = native_new_and_init(class_java_lang_IllegalMonitorStateException);
}
- assert(blockInts == 1);
+ assert(blockInts > 0);
/* Find the end of the cv list */
if (cv->cvWaiters) {
DBG( printf("suspendOnQThread %p %p\n", tid, queue); );
- assert(blockInts == 1);
+ assert(blockInts > 0);
if (CONTEXT(tid).status != THREAD_SUSPENDED)
{
void
internal_lock_mutex(iMux* mux)
{
- assert(blockInts == 1);
+ assert(blockInts > 0);
if (mux->holder == 0)
{
{
thread* tid;
- assert(blockInts == 1);
+ assert(blockInts > 0);
assert(mux->holder == currentThread);
exceptionptr = native_new_and_init(class_java_lang_IllegalMonitorStateException);
}
- assert(blockInts == 1);
+ assert(blockInts > 0);
count = mux->count;
mux->holder = 0;
exceptionptr = native_new_and_init(class_java_lang_IllegalMonitorStateException);
}
- assert(blockInts == 1);
+ assert(blockInts > 0);
/* Remove one thread from cv list */
if (cv->cvWaiters != 0) {
exceptionptr = native_new_and_init(class_java_lang_IllegalMonitorStateException);
}
- assert(blockInts == 1);
+ assert(blockInts > 0);
/* Find the end of the cv list */
if (cv->cvWaiters) {
DBG( printf("suspendOnQThread %p %p\n", tid, queue); );
- assert(blockInts == 1);
+ assert(blockInts > 0);
if (CONTEXT(tid).status != THREAD_SUSPENDED)
{