|
|
@ -1826,10 +1826,10 @@ internal_get(inputctx* ictx, const struct timespec* ts, ncinput* ni){
|
|
|
|
if(ts == NULL){
|
|
|
|
if(ts == NULL){
|
|
|
|
pthread_cond_wait(&ictx->icond, &ictx->ilock);
|
|
|
|
pthread_cond_wait(&ictx->icond, &ictx->ilock);
|
|
|
|
}else{
|
|
|
|
}else{
|
|
|
|
if(pthread_cond_timedwait(&ictx->icond, &ictx->ilock, ts)){
|
|
|
|
int r = pthread_cond_timedwait(&ictx->icond, &ictx->ilock, ts);
|
|
|
|
if(errno == ETIMEDOUT){
|
|
|
|
if(r == ETIMEDOUT){
|
|
|
|
return 0;
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
}else if(r < 0){
|
|
|
|
inc_input_errors(ictx);
|
|
|
|
inc_input_errors(ictx);
|
|
|
|
return (uint32_t)-1;
|
|
|
|
return (uint32_t)-1;
|
|
|
|
}
|
|
|
|
}
|
|
|
|