diff --git a/src/db/callback.c b/src/db/callback.c index 9b4e87f84..600981038 100644 --- a/src/db/callback.c +++ b/src/db/callback.c @@ -143,7 +143,6 @@ static void wdCallback(void *pind) int ind = *(int *)pind; taskwdRemove(callbackTaskId[ind]); if(!callbackRestart)return; - threadDestroy(callbackTaskId[ind]); semBinaryDestroy(callbackSem[ind]); ringDelete(callbackQ[ind]); start(ind); @@ -166,5 +165,14 @@ void callbackRequestProcessCallback(CALLBACK *pCallback, callbackSetUser(pRec, pCallback); callbackRequest(pCallback); } + +void callbackRequestDelayed(CALLBACK *pCallback,double seconds) +{ + printf("callbackRequestDelayed not yet implemented\n"); +} - +void callbackRequestProcessCallbackDelayed(CALLBACK *pCallback, + int Priority, void *pRec,double seconds) +{ + printf("callbackRequestDelayed not yet implemented\n"); +} diff --git a/src/db/callback.h b/src/db/callback.h index 04f42d5e4..a8cb9542f 100644 --- a/src/db/callback.h +++ b/src/db/callback.h @@ -65,14 +65,19 @@ typedef void (*CALLBACKFUNC)(); #ifdef __STDC__ long callbackInit(); -void callbackRequest(CALLBACK *); +void callbackRequest(CALLBACK *pCallback); void callbackRequestProcessCallback(CALLBACK *pCallback, int Priority, void *pRec); +void callbackRequestDelayed(CALLBACK *pCallback,double seconds); +void callbackRequestProcessCallbackDelayed(CALLBACK *pCallback, + int Priority, void *pRec,double seconds); int callbackSetQueueSize(int size); #else long callbackInit(); void callbackRequest(); void callbackRequestProcessCallback(); +void callbackRequestDelayed(); +void callbackRequestProcessCallbackDelayed(); int callbackSetQueueSize(); #endif /*__STDC__*/