X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=drl%2Fdrl_state.h;h=7715a36389f1f95662db95217c241af7a61d630b;hb=d21104e4fb6400d420027b865833cae78697cda3;hp=2b1ec5e68282fb867b31bd0b9721c665653ce4eb;hpb=0be9704d6b24d09ebd55beedec52758cb88c570b;p=distributedratelimiting.git 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.