Searched refs:RINOK_THREAD (Results 1 – 3 of 3) sorted by relevance
36 #define RINOK_THREAD(x) { if ((x) != 0) return SZ_ERROR_THREAD; } macro128 RINOK_THREAD(Event_Wait(&mtc->readEvent)) in ThreadFunc2()229 RINOK_THREAD(Event_Set(&mtc->readEvent)) in ThreadFunc2()258 RINOK_THREAD(Event_Set(&mtc->writeEvents[bi])) in ThreadFunc2()316 RINOK_THREAD(Semaphore_Release1(&mtc->blocksSemaphore)) in ThreadFunc2()491 RINOK_THREAD(ArEvent_OptCreate_And_Reset(&p->writeEvents[i])); in MtCoder_Code()494 RINOK_THREAD(ArEvent_OptCreate_And_Reset(&p->finishedEvent)); in MtCoder_Code()498 RINOK_THREAD(ArEvent_OptCreate_And_Reset(&p->readEvent)); in MtCoder_Code()502 RINOK_THREAD(Semaphore_Close(&p->blocksSemaphore)); in MtCoder_Code()504 RINOK_THREAD(Semaphore_Create(&p->blocksSemaphore, numBlocksMax, numBlocksMax)); in MtCoder_Code()[all …]
102 #define RINOK_THREAD(x) { if ((x) != 0) return SZ_ERROR_THREAD; } macro109 RINOK_THREAD(CriticalSection_Init(&p->cs)); in MtSync_Create2()112 RINOK_THREAD(AutoResetEvent_CreateNotSignaled(&p->canStart)); in MtSync_Create2()113 RINOK_THREAD(AutoResetEvent_CreateNotSignaled(&p->wasStarted)); in MtSync_Create2()114 RINOK_THREAD(AutoResetEvent_CreateNotSignaled(&p->wasStopped)); in MtSync_Create2()116 RINOK_THREAD(Semaphore_Create(&p->freeSemaphore, numBlocks, numBlocks)); in MtSync_Create2()117 RINOK_THREAD(Semaphore_Create(&p->filledSemaphore, 0, numBlocks)); in MtSync_Create2()121 RINOK_THREAD(Thread_Create(&p->thread, startAddress, obj)); in MtSync_Create2()
80 #define RINOK_THREAD(x) RINOK(x) macro298 RINOK_THREAD(Event_Wait(&t->canRead)); in ThreadFunc2()608 RINOK_THREAD(Event_Set(&nextThread->canRead)) in ThreadFunc2()691 RINOK_THREAD(Event_Wait(&t->canWrite)); in ThreadFunc2()802 RINOK_THREAD(Event_Set(&nextThread->canWrite)); in ThreadFunc2()809 RINOK_THREAD(Event_Set(&p->threads[0].canWrite)); in ThreadFunc2()818 RINOK_THREAD(Event_Set(&p->threads[0].canRead)); in ThreadFunc2()