Skip to content

Commit

Permalink
Update: Merge from auto_rec_mini
Browse files Browse the repository at this point in the history
  • Loading branch information
@ysan
ysan committed Oct 23, 2023
1 parent fea971f commit 7cdf52a
Showing 1 changed file with 78 additions and 37 deletions.
115 changes: 78 additions & 37 deletions threadmgr/threadmgr.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ typedef enum {

typedef enum {
EN_MONI_TYPE_INIT = 0,
EN_MONI_TYPE_DEBUG,
EN_MONI_TYPE_DEUnexpected,
EN_MONI_TYPE_DESTROY,

} EN_MONI_TYPE;
Expand Down Expand Up @@ -813,6 +813,7 @@ static void setupSignalPerThread (void)

sa.sa_handler = (void *) _signalHandler;
sigemptyset (&sa.sa_mask);
sa.sa_flags = 0;

void *stack_mem = malloc (2 * SIGSTKSZ);
stack_t ss;
Expand Down Expand Up @@ -1589,23 +1590,31 @@ static ST_QUE_WORKER check2deQueWorker (uint8_t nThreadIdx, bool isGetOut)
* 見送り
*/
THM_INNER_LOG_I (
"enAct is EN_THM_ACT_WAIT @REQUEST_QUE (from[%s:%s] to[%s:%s] reqId[0x%x]) ---> through\n",
"enAct is EN_THM_ACT_WAIT @REQUEST_QUE (from[%s(%d):%s(%d)] to[%s(%d):%s(%d)] reqId[0x%x]) ---> through\n",
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
pstQueWorker->nSrcThreadIdx,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
pstQueWorker->nSrcSeqIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);

} else {
/* ありえない */
THM_INNER_LOG_E (
"BUG: enAct is [%d] @REQUEST_QUE (from[%s:%s] to[%s:%s] reqId[0x%x])\n",
"Unexpected: enAct is [%d] @REQUEST_QUE (from[%s(%d):%s(%d)] to[%s(%d):%s(%d)] reqId[0x%x])\n",
getSeqInfo(nThreadIdx, nSeqIdx)->enAct,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
pstQueWorker->nSrcThreadIdx,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
pstQueWorker->nSrcSeqIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);
}
Expand All @@ -1621,11 +1630,15 @@ static ST_QUE_WORKER check2deQueWorker (uint8_t nThreadIdx, bool isGetOut)
/* シーケンスによってはありえる */
/* リプライ待たずに進むようなシーケンスとか... */
THM_INNER_FORCE_LOG_I (
"enAct is EN_THM_ACT_INIT @REPLY_QUE (from[%s:%s] to[%s:%s] reqId[0x%x]) ---> drop\n",
"enAct is EN_THM_ACT_INIT @REPLY_QUE (from[%s(%d):%s(%d)] to[%s(%d):%s(%d)] reqId[0x%x]) ---> drop\n",
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
pstQueWorker->nSrcThreadIdx,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
pstQueWorker->nSrcSeqIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);

Expand Down Expand Up @@ -1664,22 +1677,30 @@ static ST_QUE_WORKER check2deQueWorker (uint8_t nThreadIdx, bool isGetOut)
/* リプライ待たずに進むようなシーケンスとか... */
#ifndef _MULTI_REQUESTING
THM_INNER_LOG_I (
"enAct is EN_THM_ACT_WAIT reqId unmatch:[%d:%d] @REPLY_QUE (from[%s:%s] to[%s:%s] reqId[0x%x]) ---> drop\n",
"enAct is EN_THM_ACT_WAIT reqId unmatch:[%d:%d] @REPLY_QUE (from[%s(%d):%s(%d)] to[%s(%d):%s(%d)] reqId[0x%x]) ---> drop\n",
pstQueWorker->nReqId,
getSeqInfo (nThreadIdx, nSeqIdx)->nReqId,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
pstQueWorker->nSrcThreadIdx,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
pstQueWorker->nSrcSeqIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);
#else
THM_INNER_LOG_I (
"enAct is EN_THM_ACT_WAIT reqId unmatch @REPLY_QUE (from[%s:%s] to[%s:%s] reqId[0x%x]) ---> drop\n",
"enAct is EN_THM_ACT_WAIT reqId unmatch @REPLY_QUE (from[%s(%d):%s(%d)] to[%s(%d):%s(%d)] reqId[0x%x]) ---> drop\n",
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
pstQueWorker->nSrcThreadIdx,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
pstQueWorker->nSrcSeqIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);
#endif
Expand All @@ -1691,12 +1712,16 @@ static ST_QUE_WORKER check2deQueWorker (uint8_t nThreadIdx, bool isGetOut)
} else {
/* ありえない */
THM_INNER_LOG_E (
"BUG: enAct is [%d] @REPLY_QUE (from[%s:%s] to[%s:%s] reqId[0x%x])\n",
"Unexpected: enAct is [%d] @REPLY_QUE (from[%s(%d):%s](%d) to[%s(%d):%s(%d)] reqId[0x%x])\n",
getSeqInfo (nThreadIdx, nSeqIdx)->enAct,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
pstQueWorker->nSrcThreadIdx,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
pstQueWorker->nSrcSeqIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);
}
Expand Down Expand Up @@ -1751,22 +1776,30 @@ static ST_QUE_WORKER check2deQueWorker (uint8_t nThreadIdx, bool isGetOut)
/* リプライ待たずに進むようなシーケンスとか... */
#ifndef _MULTI_REQUESTING
THM_INNER_LOG_I (
"enAct is EN_THM_ACT_WAIT reqId unmatch:[%d:%d] @REQ_TIMEOUT_QUE (from[%s:%s] to[%s:%s] reqId[0x%x]) ---> drop\n",
"enAct is EN_THM_ACT_WAIT reqId unmatch:[%d:%d] @REQ_TIMEOUT_QUE (from[%s(%d):%s(%d)] to[%s(%d):%s(%d)] reqId[0x%x]) ---> drop\n",
pstQueWorker->nReqId,
getSeqInfo (nThreadIdx, nSeqIdx)->nReqId
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
pstQueWorker->nSrcThreadIdx,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
pstQueWorker->nSrcSeqIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);
#else
THM_INNER_LOG_I (
"enAct is EN_THM_ACT_WAIT reqId unmatch:[%d:%d] @REQ_TIMEOUT_QUE (from[%s:%s] to[%s:%s] reqId[0x%x]) ---> drop\n",
"enAct is EN_THM_ACT_WAIT reqId notfound @REQ_TIMEOUT_QUE (from[%s(%d):%s(%d)] to[%s(%d):%s(%d)] reqId[0x%x]) ---> drop\n",
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
pstQueWorker->nSrcThreadIdx,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
pstQueWorker->nSrcSeqIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);
#endif
Expand All @@ -1780,11 +1813,15 @@ static ST_QUE_WORKER check2deQueWorker (uint8_t nThreadIdx, bool isGetOut)
/* シーケンスによってはありえる */
/* リプライ待たずに進むようなシーケンスとか... */
THM_INNER_FORCE_LOG_I (
"enAct is not EN_THM_ACT_WAIT @REQ_TIMEOUT_QUE (from[%s:%s] to[%s:%s] reqId[0x%x]) ---> drop\n",
"enAct is not EN_THM_ACT_WAIT @REQ_TIMEOUT_QUE (from[%s(%d):%s(%d)] to[%s(%d):%s(%d)] reqId[0x%x]) ---> drop\n",
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
pstQueWorker->nSrcThreadIdx,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
pstQueWorker->nSrcSeqIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);

Expand All @@ -1796,12 +1833,16 @@ static ST_QUE_WORKER check2deQueWorker (uint8_t nThreadIdx, bool isGetOut)
} else {
/* ありえないはず */
THM_INNER_LOG_E (
"BUG: reqIdInfo.timeout.enState is unexpected [%d] @REQ_TIMEOUT_QUE (from[%s:%s] to[%s:%s] reqId[0x%x])\n",
"Unexpected: reqIdInfo.timeout.enState is unexpected [%d] @REQ_TIMEOUT_QUE (from[%s(%d):%s(%d)] to[%s(%d):%s(%d)] reqId[0x%x])\n",
enTimeoutState,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
pstQueWorker->nSrcThreadIdx,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
pstQueWorker->nSrcSeqIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);
}
Expand All @@ -1828,25 +1869,25 @@ static ST_QUE_WORKER check2deQueWorker (uint8_t nThreadIdx, bool isGetOut)
} else {
/* ありえるのか? ありえないはず... */
THM_INNER_LOG_E (
"BUG: enAct is EN_THM_ACT_WAIT unexpect timeout.enState:[%d] @SEQ_TIMEOUT_QUE (from[%s:%s] to[%s:%s] reqId[0x%x])\n",
"Unexpected: enAct is EN_THM_ACT_WAIT unexpect timeout.enState:[%d] @SEQ_TIMEOUT_QUE (to[%s(%d):%s(%d)] reqId[0x%x])\n",
getSeqInfo(nThreadIdx, nSeqIdx)->timeout.enState,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);
}

} else {
/* ありえないはず */
THM_INNER_LOG_E (
"BUG: enAct is [%d] @SEQ_TIMEOUT_QUE (from[%s:%s] to[%s:%s] reqId[0x%x])\n",
"Unexpected: enAct is [%d] @SEQ_TIMEOUT_QUE (to[%s(%d):%s(%d)] reqId[0x%x])\n",
getSeqInfo (nThreadIdx, nSeqIdx)->enAct,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pszName,
gpstThmRegTbl [pstQueWorker->nSrcThreadIdx]->pstSeqArray[pstQueWorker->nSrcSeqIdx].pszName,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pszName,
pstQueWorker->nDestThreadIdx,
gpstThmRegTbl [pstQueWorker->nDestThreadIdx]->pstSeqArray[pstQueWorker->nDestSeqIdx].pszName,
pstQueWorker->nDestSeqIdx,
pstQueWorker->nReqId
);
}
Expand All @@ -1863,7 +1904,7 @@ static ST_QUE_WORKER check2deQueWorker (uint8_t nThreadIdx, bool isGetOut)


} else {
THM_INNER_LOG_E ("BUG: unexpected queType.\n");
THM_INNER_LOG_E ("Unexpected: unexpected queType.\n");
}
} else {
//THM_INNER_LOG_E( "not use\n" );
Expand Down Expand Up @@ -2032,7 +2073,7 @@ static void *baseThread (void *pArg)
break;

default:
THM_INNER_LOG_E ("BUG: pthread_cond_timedwait() => unexpected return value [%d]\n", nRtn);
THM_INNER_LOG_E ("Unexpected: pthread_cond_timedwait() => unexpected return value [%d]\n", nRtn);
break;
}

Expand All @@ -2048,7 +2089,7 @@ static void *baseThread (void *pArg)
stRtnQue = deQueBase (true);
if (stRtnQue.isUsed) {
switch (stRtnQue.enMoniType) {
case EN_MONI_TYPE_DEBUG:
case EN_MONI_TYPE_DEUnexpected:
dumpInnerInfo ();
dumpRequestIdInfo ();
dumpExtInfoList ();
Expand Down Expand Up @@ -2129,7 +2170,7 @@ static void *sigwaitThread (void *pArg)
switch (nSig) {
case SIGQUIT:
THM_INNER_FORCE_LOG_I ("catch SIGQUIT\n");
requestBaseThread (EN_MONI_TYPE_DEBUG);
requestBaseThread (EN_MONI_TYPE_DEUnexpected);
break;
case SIGINT:
case SIGTERM:
Expand All @@ -2139,7 +2180,7 @@ static void *sigwaitThread (void *pArg)
isDestroy = true;
break;
default:
THM_INNER_LOG_E ("BUG: unexpected signal.\n");
THM_INNER_LOG_E ("Unexpected: unexpected signal.\n");
break;
}
} else {
Expand Down Expand Up @@ -2210,7 +2251,7 @@ static void checkWaitWorkerThread (ST_INNER_INFO *pstInnerInfo)
THM_INNER_LOG_D ("timeout cond wait (reqTimeout)\n");

if (!pstReqIdInfo) {
THM_INNER_LOG_E ("BUG: pstReqIdInfo is null !!!\n");
THM_INNER_LOG_E ("Unexpected: pstReqIdInfo is null !!!\n");
goto _F_END;
}
pstReqIdInfo->timeout.enState = EN_TIMEOUT_STATE_MEAS_COND_TIMEDWAIT;
Expand All @@ -2220,7 +2261,7 @@ static void checkWaitWorkerThread (ST_INNER_INFO *pstInnerInfo)
THM_INNER_LOG_D ("timeout cond wait (seqTimeout)\n");

if (!pstSeqInfo) {
THM_INNER_LOG_E ("BUG: pstSeqInfo is null !!!\n");
THM_INNER_LOG_E ("Unexpected: pstSeqInfo is null !!!\n");
goto _F_END;
}
pstSeqInfo->timeout.enState = EN_TIMEOUT_STATE_MEAS_COND_TIMEDWAIT;
Expand All @@ -2243,14 +2284,14 @@ static void checkWaitWorkerThread (ST_INNER_INFO *pstInnerInfo)
isNeedWait = false;
if (enTimeout == EN_NEAREST_TIMEOUT_REQ) {
if (!pstReqIdInfo) {
THM_INNER_LOG_E ("BUG: pstReqIdInfo is null !!!\n");
THM_INNER_LOG_E ("Unexpected: pstReqIdInfo is null !!!\n");
goto _F_END;
}
pstReqIdInfo->timeout.enState = EN_TIMEOUT_STATE_MEAS;

} else {
if (!pstSeqInfo) {
THM_INNER_LOG_E ("BUG: pstSeqInfo is null !!!\n");
THM_INNER_LOG_E ("Unexpected: pstSeqInfo is null !!!\n");
goto _F_END;
}
pstSeqInfo->timeout.enState = EN_TIMEOUT_STATE_MEAS;
Expand All @@ -2265,15 +2306,15 @@ static void checkWaitWorkerThread (ST_INNER_INFO *pstInnerInfo)
isNeedWait = false;
if (enTimeout == EN_NEAREST_TIMEOUT_REQ) {
if (!pstReqIdInfo) {
THM_INNER_LOG_E ("BUG: pstReqIdInfo is null !!!\n");
THM_INNER_LOG_E ("Unexpected: pstReqIdInfo is null !!!\n");
goto _F_END;
}
pstReqIdInfo->timeout.enState = EN_TIMEOUT_STATE_PASSED;
enQueReqTimeout (pstInnerInfo->nThreadIdx, pstReqIdInfo->nId);

} else {
if (!pstSeqInfo) {
THM_INNER_LOG_E ("BUG: pstSeqInfo is null !!!\n");
THM_INNER_LOG_E ("Unexpected: pstSeqInfo is null !!!\n");
goto _F_END;
}
pstSeqInfo->timeout.enState = EN_TIMEOUT_STATE_PASSED;
Expand All @@ -2287,7 +2328,7 @@ static void checkWaitWorkerThread (ST_INNER_INFO *pstInnerInfo)

default:
isNeedWait = false;
THM_INNER_LOG_E ("BUG: pthread_cond_timedwait() => unexpected return value [%d]\n", nRtn);
THM_INNER_LOG_E ("Unexpected: pthread_cond_timedwait() => unexpected return value [%d]\n", nRtn);
break;
}
}
Expand Down Expand Up @@ -2651,7 +2692,7 @@ static void *workerThread (void *pArg)
break;

default:
THM_INNER_LOG_E ("BUG: unexpected queType.\n");
THM_INNER_LOG_E ("Unexpected: unexpected queType.\n");
break;
}

Expand Down Expand Up @@ -3078,7 +3119,7 @@ bool requestSync (uint8_t nThreadIdx, uint8_t nSeqIdx, uint8_t *pMsg, size_t msg
// break;

default:
THM_INNER_LOG_E ("BUG: pthread_cond_timedwait() => unexpected return value [%d]\n", nRtn);
THM_INNER_LOG_E ("Unexpected: pthread_cond_timedwait() => unexpected return value [%d]\n", nRtn);
break;
}

Expand Down Expand Up @@ -3754,7 +3795,7 @@ static void enableReqTimeout (uint8_t nThreadIdx, uint32_t nReqId, uint32_t nTim
pthread_mutex_lock (&gMutexOpeRequestId [nThreadIdx]);

if (gstRequestIdInfo [nThreadIdx][nReqId].timeout.enState != EN_TIMEOUT_STATE_INIT) {
THM_INNER_LOG_E ("BUG: timeout.enState != EN_TIMEOUT_STATE_INIT\n");
THM_INNER_LOG_E ("Unexpected: timeout.enState != EN_TIMEOUT_STATE_INIT\n");

/* unlock */
pthread_mutex_unlock (&gMutexOpeRequestId [nThreadIdx]);
Expand Down Expand Up @@ -3862,7 +3903,7 @@ static bool isReqTimeoutFromRequestId (uint8_t nThreadIdx, uint32_t nReqId)

} else {
/* ありえない */
THM_INNER_LOG_E ("BUG: diff_nsec is minus value.\n");
THM_INNER_LOG_E ("Unexpected: diff_nsec is minus value.\n");
}

} else {
Expand Down Expand Up @@ -4674,7 +4715,7 @@ static bool isSeqTimeoutFromSeqIdx (uint8_t nThreadIdx, uint8_t nSeqIdx)

} else {
/* ありえない */
THM_INNER_LOG_E ("BUG: diff_nsec is minus value.\n");
THM_INNER_LOG_E ("Unexpected: diff_nsec is minus value.\n");
}

} else {
Expand Down Expand Up @@ -4777,7 +4818,7 @@ static void checkSeqTimeoutFromCondTimedwait (uint8_t nThreadIdx)

if (n != 1) {
/* 複数存在した... バグ */
THM_INNER_LOG_E ("BUG: state(EN_TIMEOUT_STATE_MEAS_COND_TIMEDWAIT) is multiple. n=[%d]\n", n);
THM_INNER_LOG_E ("Unexpected: state(EN_TIMEOUT_STATE_MEAS_COND_TIMEDWAIT) is multiple. n=[%d]\n", n);
return;
}

Expand All @@ -4804,7 +4845,7 @@ static void checkSeqTimeoutFromNotCondTimedwait (uint8_t nThreadIdx)

if (n != 1) {
/* 複数存在した... バグ */
THM_INNER_LOG_E ("BUG: state(EN_TIMEOUT_STATE_MEAS_COND_TIMEDWAIT) is multiple. n=[%d]\n", n);
THM_INNER_LOG_E ("Unexpected: state(EN_TIMEOUT_STATE_MEAS_COND_TIMEDWAIT) is multiple. n=[%d]\n", n);
return;
}
}
Expand Down Expand Up @@ -4929,7 +4970,7 @@ static bool isLock (uint8_t nThreadIdx)
}

if (n >= 2) {
THM_INNER_LOG_E ("BUG: Multiple seq locked.\n");
THM_INNER_LOG_E ("Unexpected: Multiple seq locked.\n");
}

return r;
Expand Down

0 comments on commit 7cdf52a

Please sign in to comment.