unsigned int size; /* maximum number of sticky sessions in table */
unsigned int current; /* number of sticky sessions currently in table */
int nopurge; /* if non-zero, don't purge sticky sessions when full */
- int exp_next; /* next expiration date (ticks) */
int expire; /* time to live for sticky sessions (milliseconds) */
int data_size; /* the size of the data that is prepended *before* stksess */
int data_ofs[STKTABLE_DATA_TYPES]; /* negative offsets of present data types, or 0 if absent */
if (!t->expire)
return;
- /* set both t->exp_next and the task's expire to the newest
- * expiration date.
- */
- old_exp = HA_ATOMIC_LOAD(&t->exp_next);
- do {
- new_exp = tick_first(expire, old_exp);
- } while (new_exp != old_exp &&
- !HA_ATOMIC_CAS(&t->exp_next, &old_exp, new_exp) &&
- __ha_cpu_relax());
-
+ /* set the task's expire to the newest expiration date. */
old_exp = HA_ATOMIC_LOAD(&t->exp_task->expire);
do {
- new_exp = HA_ATOMIC_LOAD(&t->exp_next);
+ new_exp = tick_first(expire, old_exp);
} while (new_exp != old_exp &&
!HA_ATOMIC_CAS(&t->exp_task->expire, &old_exp, new_exp) &&
__ha_cpu_relax());
struct stksess *ts;
struct eb32_node *eb;
int looped = 0;
+ int exp_next;
HA_RWLOCK_WRLOCK(STK_TABLE_LOCK, &t->lock);
eb = eb32_lookup_ge(&t->exps, now_ms - TIMER_LOOK_BACK);
if (likely(tick_is_lt(now_ms, eb->key))) {
/* timer not expired yet, revisit it later */
- t->exp_next = eb->key;
+ exp_next = eb->key;
goto out_unlock;
}
}
/* We have found no task to expire in any tree */
- t->exp_next = TICK_ETERNITY;
+ exp_next = TICK_ETERNITY;
out_unlock:
HA_RWLOCK_WRUNLOCK(STK_TABLE_LOCK, &t->lock);
- return t->exp_next;
+ return exp_next;
}
/*
t->pool = create_pool("sticktables", sizeof(struct stksess) + round_ptr_size(t->data_size) + t->key_size, MEM_F_SHARED);
- t->exp_next = TICK_ETERNITY;
if ( t->expire ) {
t->exp_task = task_new_anywhere();
if (!t->exp_task)