Completed DC_processEvents.

git-svn-id: svn+ssh://cvs.lpds.sztaki.hu/var/lib/svn/szdg/dcapi/trunk@453 a7169a2c-3604-0410-bc95-c702d8d87f7a
This commit is contained in:
vida 2006-04-11 14:22:44 +00:00 committed by Adam Visegradi
parent 71e68bdd21
commit 1eb1502222
1 changed files with 19 additions and 13 deletions

View File

@ -9,31 +9,39 @@
int DC_processEvents(int timeout)
{
int retval;
static time_t start, current;
if (!_dc_resultcb || !_dc_subresultcb || !_dc_messagecb)
{
DC_log(LOG_ERR, "DC_processEvents: callbacks are not set up");
return DC_ERR_CONFIG;
}
_DC_searchForEvents();
DC_log(LOG_INFO, "DC_processEvents: Searching for events ...");
return 0;
}
start = time(NULL);
while (1)
{
retval = _DC_searchForEvents(); /* implemted in rm.c */
if (retval)
return retval;
/* Look for a single result that matches the filter */
static DC_Event *look_for_results(const char *wuFilter, const char *wuName,
int timeout)
{
DC_Event *event = NULL;
return event;
current = time(NULL);
if (current - start > timeout)
{
DC_log(LOG_INFO, "DC_processEvents: timeout is over ... returning");
return 0;
}
sleep(sleep_interval);
}
}
DC_Event *DC_waitEvent(const char *wuFilter, int timeout)
{
DC_Event *event;
event = look_for_results(wuFilter, NULL, timeout);
// event = look_for_results(wuFilter, NULL, timeout);
return event;
}
@ -42,8 +50,6 @@ DC_Event *DC_waitWUEvent(DC_Workunit *wu, int timeout)
{
DC_Event *event;
event = look_for_results(NULL, wu->name, timeout);
return event;
}