]> rtime.felk.cvut.cz Git - frescor/fna.git/blobdiff - src_frescan/frescan_servers_replenishments.c
config values
[frescor/fna.git] / src_frescan / frescan_servers_replenishments.c
index 3ae76abb7541e159cbdc2a08bc2815f5004e8182..b2e75f44045b8dfa88f85d5b1927a9e89cfaf567 100644 (file)
@@ -136,7 +136,7 @@ static void *frescan_repl_thread(void *arg)
         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;
@@ -164,7 +164,7 @@ static void *frescan_repl_thread(void *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);
@@ -239,7 +239,7 @@ int frescan_replenishments_init(frescan_network_t net)
                 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);
@@ -265,13 +265,13 @@ int frescan_replenishments_init(frescan_network_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;
 
@@ -280,7 +280,7 @@ int frescan_replenishment_program(frescan_network_t net,
         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) {