Searched refs:curStatus (Results 1 – 2 of 2) sorted by relevance
138 val curStatus = status.getAndSet(STATUS_DONE) in <lambda>() constant139 if (curStatus < 0) LockSupport.unpark(threads[curStatus.inv()]) in <lambda>()288 val curStatus = status.get() in <lambda>() constant289 … if (curStatus < 0 || curStatus == STATUS_DONE) return // some other thread paused or done in <lambda>()290 pausedEpoch = curStatus + 1 in <lambda>()292 if (status.compareAndSet(curStatus, newStatus)) { in <lambda>()426 val curStatus = status.get() in <lambda>() constant427 if (curStatus >= 0) return -1 // not paused in <lambda>()428 val thread = threads[curStatus.inv()] in <lambda>()430 if (curStatus == status.get()) return pausedEpoch in <lambda>()[all …]
396 curStatus = self.GetStatus(i)397 … if curStatus == STATUS_PENDING or curStatus == STATUS_PLAYING or curStatus == STATUS_QUEUED:404 curStatus = self.GetStatus(i)405 if curStatus == STATUS_QUEUED: