From d7b7e13b73dd2cb88adf6148421f911aa8d44824 Mon Sep 17 00:00:00 2001 From: "Janet B. Anderson" Date: Wed, 15 May 1991 17:00:01 +0000 Subject: [PATCH] mrk+jba: fixed parms in ringbuf calls --- src/db/dbScan.c | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/src/db/dbScan.c b/src/db/dbScan.c index b85a8aa6d..fc3b5cda2 100644 --- a/src/db/dbScan.c +++ b/src/db/dbScan.c @@ -542,7 +542,7 @@ eventTask() semTake(&eventSem); /* process requests in the command ring buffer */ - while (rngNBytes(ioEventQ)>=sizeof(short)){ + while (rngNBytes(eventQ)>=sizeof(short)){ rngBufGet(eventQ,&event,sizeof(short)); /* find the event list */ @@ -648,7 +648,8 @@ callbackTask(){ semTake (&callbackSem); /* process requests in the command ring buffer */ - while (rngBufGet(callbackQ,&pcallback,sizeof(pcallback))) { + while(rngNBytes(callbackQ)>=sizeof(pcallback)) { + rngBufGet(callbackQ,&pcallback,sizeof(pcallback)); (*pcallback->callback)(pcallback); } } @@ -658,12 +659,8 @@ callbackTask(){ callbackRequest(pcallback) struct callback *pcallback; { - if(rngNBytes(ioEventQ)>=sizeof(pcallback)) { rngBufPut(callbackQ,&pcallback,sizeof(pcallback)); - logMsg("callbackQ full\n"); - } else { semGive(&callbackSem); - } } /*