#include "dnxJobList.h"
Go to the source code of this file.
Data Structures | |
struct | DnxTimer |
DNX job expiration timer abstract type. More... | |
Functions | |
int | dnxTimerCreate (DnxJobList *joblist, int sleeptime, DnxTimer **ptimer) |
Create a new job list expiration timer object. | |
void | dnxTimerDestroy (DnxTimer *timer) |
Destroy an existing job list expiration timer object. |
The purpose of this thread is to monitor the age of service requests which are being actively executed by the worker nodes.
This requires access to the global Pending queue (which is also manipulated by the Dispatcher and Collector threads.)
Definition in file dnxTimer.h.
int dnxTimerCreate | ( | DnxJobList * | joblist, | |
int | sleeptime, | |||
DnxTimer ** | ptimer | |||
) |
Create a new job list expiration timer object.
[in] | joblist | - the job list that should be expired by the timer. |
[in] | sleeptime | - time between expiration checks, in milliseconds. |
[out] | ptimer | - the address of storage for returning the new object reference. |
Definition at line 166 of file dnxTimer.c.
References DNX_DEF_TIMER_SLEEP, DNX_ERR_MEMORY, DNX_ERR_THREAD, DNX_OK, dnxErrorString(), dnxLog(), dnxTimer(), iDnxTimer_::joblist, iDnxTimer_::sleepms, iDnxTimer_::tid, xfree, and xmalloc.
Referenced by dnxJobListCreate().
void dnxTimerDestroy | ( | DnxTimer * | timer | ) |
Destroy an existing job list expiration timer object.
[in] | timer | - the timer object to be destroyed. |
Definition at line 200 of file dnxTimer.c.
References iDnxTimer_::tid, and xfree.
Referenced by dnxJobListDestroy().