siginfo_t siginfo;
frescan_ss_t id;
frescan_network_t net;
- frescan_server_data_t *server;
+ frescan_ss_data_t *server;
struct itimerspec timerdata;
net = (frescan_network_t)(uint32_t)arg;
siginfo.si_value.sival_int); // the server id
id = siginfo.si_value.sival_int;
- server = &the_servers_pool[net][id];
+ server = &frescan_data[net].ss_data[id];
DEBUG(FRESCAN_REPLENSH_ENABLE_DEBUG,
"id:%u current_prio:%u\n", id, server->current_priority);
return ret;
}
- ret = fosa_thread_create(&the_networks[net].repl_thread_id,
+ ret = fosa_thread_create(&frescan_data[net].repl_thread_id,
&attr,
frescan_repl_thread,
(void *)(uint32_t)net);
*/
int frescan_replenishment_program(frescan_network_t net,
- frescan_ss_t ss,
+ frescan_ss_t id,
const struct timespec *timestamp)
{
int ret;
frescan_repl_op_t *repl = NULL;
struct itimerspec timerdata;
- frescan_server_data_t *server;
+ frescan_ss_data_t *server;
struct list_head *pos;
struct timespec now;
assert(ret == 0);
#endif
- server = &the_servers_pool[net][ss];
+ server = &frescan_data[net].ss_data[id];
// extract the head
list_for_each(pos, &server->replenishments.repl_list) {