X-Git-Url: http://git.onelab.eu/?p=distributedratelimiting.git;a=blobdiff_plain;f=drl%2Fdrl_state.h;h=7715a36389f1f95662db95217c241af7a61d630b;hp=2b1ec5e68282fb867b31bd0b9721c665653ce4eb;hb=19bf89f36a91be2fdd4a0b6c7099f7515507e1e1;hpb=a3995c9ac407020dcdc5c471191b767bb1667d2e diff --git a/drl/drl_state.h b/drl/drl_state.h index 2b1ec5e..7715a36 100644 --- a/drl/drl_state.h +++ b/drl/drl_state.h @@ -31,7 +31,7 @@ #define MAX_IDENTS (1024) #define MAX_LIMITERS (128) -#define REMOTE_AWOL_THRESHOLD (3) +#define REMOTE_AWOL_THRESHOLD (5) enum transports { UDP, TCP }; @@ -208,9 +208,13 @@ void free_comm(comm_t *comm); * @param aggregate The location at which the aggregate value will * be stored. * + * @param decayto When using a mesh comm fabric, limiters whose value + * has not been heard in several timesteps will decay to this value. + * Generally globallimit/N. + * * @returns 0 on success, EINVAL on error. */ -int read_comm(comm_t *comm, double *aggregate); +int read_comm(comm_t *comm, double *aggregate, double decayto); /** * Updates the locally observed value of an identity.