batman-adv: convert time_after instances to has_timed_out
authorMarek Lindner <lindner_marek@yahoo.de>
Tue, 20 Dec 2011 11:30:40 +0000 (19:30 +0800)
committerMarek Lindner <lindner_marek@yahoo.de>
Thu, 16 Feb 2012 18:50:20 +0000 (02:50 +0800)
To increase readability the has_timed_out() functions has been introduced.
This patch converts existing time_after() calls to use this wrapper
function (if applicable).
This patch also converts all timeouts to miliseconds to be consistent.

Signed-off-by: Marek Lindner <lindner_marek@yahoo.de>
Signed-off-by: Simon Wunderlich <siwu@hrz.tu-chemnitz.de>
net/batman-adv/gateway_client.c
net/batman-adv/main.h
net/batman-adv/originator.c
net/batman-adv/routing.c
net/batman-adv/soft-interface.c
net/batman-adv/translation-table.c
net/batman-adv/vis.c
net/batman-adv/vis.h

index 24403a7350f75fb5767e8855041c31b8d166fea9..df5631e1f2a59052e3e8c0317e40b208e4d7798c 100644 (file)
@@ -396,7 +396,7 @@ void gw_node_purge(struct bat_priv *bat_priv)
 {
        struct gw_node *gw_node, *curr_gw;
        struct hlist_node *node, *node_tmp;
-       unsigned long timeout = 2 * PURGE_TIMEOUT * HZ;
+       unsigned long timeout = msecs_to_jiffies(2 * PURGE_TIMEOUT);
        int do_deselect = 0;
 
        curr_gw = gw_get_selected_gw_node(bat_priv);
index 586afafb1b67b06b67361d40923f8ec87c3adbd1..ecfed88d0d43cc75964f13d43fdbb7605593be28 100644 (file)
 
 /* purge originators after time in seconds if no valid packet comes in
  * -> TODO: check influence on TQ_LOCAL_WINDOW_SIZE */
-#define PURGE_TIMEOUT 200
-#define TT_LOCAL_TIMEOUT 3600 /* in seconds */
-#define TT_CLIENT_ROAM_TIMEOUT 600
+#define PURGE_TIMEOUT 200000 /* 200 seconds */
+#define TT_LOCAL_TIMEOUT 3600000 /* in miliseconds */
+#define TT_CLIENT_ROAM_TIMEOUT 600000 /* in miliseconds */
 /* sliding packet range of received originator messages in sequence numbers
  * (should be a multiple of our word size) */
 #define TQ_LOCAL_WINDOW_SIZE 64
-#define TT_REQUEST_TIMEOUT 3 /* seconds we have to keep pending tt_req */
+#define TT_REQUEST_TIMEOUT 3000 /* miliseconds we have to keep
+                                * pending tt_req */
 
 #define TQ_GLOBAL_WINDOW_SIZE 5
 #define TQ_LOCAL_BIDRECT_SEND_MINIMUM 1
@@ -56,8 +57,8 @@
 
 #define TT_OGM_APPEND_MAX 3 /* number of OGMs sent with the last tt diff */
 
-#define ROAMING_MAX_TIME 20 /* Time in which a client can roam at most
-                            * ROAMING_MAX_COUNT times */
+#define ROAMING_MAX_TIME 20000 /* Time in which a client can roam at most
+                               * ROAMING_MAX_COUNT times in miliseconds*/
 #define ROAMING_MAX_COUNT 5
 
 #define NO_FLAGS 0
index 847ff7e98a61bb08b9be4d75c585eb89aeceb31e..1161f27ad8ccf907e3dcbe0d965a026b86806ad4 100644 (file)
@@ -282,8 +282,7 @@ static bool purge_orig_neighbors(struct bat_priv *bat_priv,
        hlist_for_each_entry_safe(neigh_node, node, node_tmp,
                                  &orig_node->neigh_list, list) {
 
-               if ((time_after(jiffies,
-                       neigh_node->last_valid + PURGE_TIMEOUT * HZ)) ||
+               if ((has_timed_out(neigh_node->last_valid, PURGE_TIMEOUT)) ||
                    (neigh_node->if_incoming->if_status == IF_INACTIVE) ||
                    (neigh_node->if_incoming->if_status == IF_NOT_IN_USE) ||
                    (neigh_node->if_incoming->if_status == IF_TO_BE_REMOVED)) {
@@ -327,9 +326,7 @@ static bool purge_orig_node(struct bat_priv *bat_priv,
 {
        struct neigh_node *best_neigh_node;
 
-       if (time_after(jiffies,
-               orig_node->last_valid + 2 * PURGE_TIMEOUT * HZ)) {
-
+       if (has_timed_out(orig_node->last_valid, 2 * PURGE_TIMEOUT)) {
                bat_dbg(DBG_BATMAN, bat_priv,
                        "Originator timeout: originator %pM, last_valid %lu\n",
                        orig_node->orig, (orig_node->last_valid / HZ));
@@ -372,8 +369,8 @@ static void _purge_orig(struct bat_priv *bat_priv)
                                continue;
                        }
 
-                       if (time_after(jiffies, orig_node->last_frag_packet +
-                                               msecs_to_jiffies(FRAG_TIMEOUT)))
+                       if (has_timed_out(orig_node->last_frag_packet,
+                                         FRAG_TIMEOUT))
                                frag_list_free(&orig_node->frag_list);
                }
                spin_unlock_bh(list_lock);
index b72d7f3b3c6aaafa7a47e558cbfcc4a0092fb945..c1e45c0bb1867778bf0d7b4e3fcd4d9699ecd09b 100644 (file)
@@ -231,8 +231,7 @@ int window_protected(struct bat_priv *bat_priv, int32_t seq_num_diff,
 {
        if ((seq_num_diff <= -TQ_LOCAL_WINDOW_SIZE)
                || (seq_num_diff >= EXPECTED_SEQNO_RANGE)) {
-               if (time_after(jiffies, *last_reset +
-                       msecs_to_jiffies(RESET_PROTECTION_MS))) {
+               if (has_timed_out(*last_reset, RESET_PROTECTION_MS)) {
 
                        *last_reset = jiffies;
                        bat_dbg(DBG_BATMAN, bat_priv,
index b5aecd5e45ccea4f8f21d509e5b59bfacb13a5d5..c41dac3bbf8146ad903a0db2ecf1b507a4dff1ad 100644 (file)
@@ -396,8 +396,8 @@ void softif_neigh_purge(struct bat_priv *bat_priv)
                hlist_for_each_entry_safe(softif_neigh, node_tmp, node_tmp2,
                                          &softif_neigh_vid->softif_neigh_list,
                                          list) {
-                       if ((!time_after(jiffies, softif_neigh->last_seen +
-                               msecs_to_jiffies(SOFTIF_NEIGH_TIMEOUT))) &&
+                       if ((!has_timed_out(softif_neigh->last_seen,
+                                          SOFTIF_NEIGH_TIMEOUT)) &&
                            (atomic_read(&bat_priv->mesh_state) == MESH_ACTIVE))
                                continue;
 
index a84e80409f9b1dd880e01b1e0473203162b6241f..ff9a1b33c13677ca5e7bc866028c2fad4a270dab 100644 (file)
@@ -413,7 +413,7 @@ static void tt_local_purge(struct bat_priv *bat_priv)
                                continue;
 
                        if (!has_timed_out(tt_local_entry->last_seen,
-                                          TT_LOCAL_TIMEOUT * 1000))
+                                          TT_LOCAL_TIMEOUT))
                                continue;
 
                        tt_local_set_pending(bat_priv, tt_local_entry,
@@ -751,7 +751,7 @@ static void tt_global_roam_purge(struct bat_priv *bat_priv)
                        if (!(tt_global_entry->common.flags & TT_CLIENT_ROAM))
                                continue;
                        if (!has_timed_out(tt_global_entry->roam_at,
-                                          TT_CLIENT_ROAM_TIMEOUT * 1000))
+                                          TT_CLIENT_ROAM_TIMEOUT))
                                continue;
 
                        bat_dbg(DBG_TT, bat_priv, "Deleting global "
@@ -970,8 +970,7 @@ static void tt_req_purge(struct bat_priv *bat_priv)
 
        spin_lock_bh(&bat_priv->tt_req_list_lock);
        list_for_each_entry_safe(node, safe, &bat_priv->tt_req_list, list) {
-               if (has_timed_out(node->issued_at,
-                                 TT_REQUEST_TIMEOUT * 1000)) {
+               if (has_timed_out(node->issued_at, TT_REQUEST_TIMEOUT)) {
                        list_del(&node->list);
                        kfree(node);
                }
@@ -990,7 +989,7 @@ static struct tt_req_node *new_tt_req_node(struct bat_priv *bat_priv,
        list_for_each_entry(tt_req_node_tmp, &bat_priv->tt_req_list, list) {
                if (compare_eth(tt_req_node_tmp, orig_node) &&
                    !has_timed_out(tt_req_node_tmp->issued_at,
-                                  TT_REQUEST_TIMEOUT * 1000))
+                                  TT_REQUEST_TIMEOUT))
                        goto unlock;
        }
 
@@ -1583,8 +1582,7 @@ static void tt_roam_purge(struct bat_priv *bat_priv)
 
        spin_lock_bh(&bat_priv->tt_roam_list_lock);
        list_for_each_entry_safe(node, safe, &bat_priv->tt_roam_list, list) {
-               if (!has_timed_out(node->first_time,
-                                  ROAMING_MAX_TIME * 1000))
+               if (!has_timed_out(node->first_time, ROAMING_MAX_TIME))
                        continue;
 
                list_del(&node->list);
@@ -1611,8 +1609,7 @@ static bool tt_check_roam_count(struct bat_priv *bat_priv,
                if (!compare_eth(tt_roam_node->addr, client))
                        continue;
 
-               if (has_timed_out(tt_roam_node->first_time,
-                                 ROAMING_MAX_TIME * 1000))
+               if (has_timed_out(tt_roam_node->first_time, ROAMING_MAX_TIME))
                        continue;
 
                if (!atomic_dec_not_zero(&tt_roam_node->counter))
index ac7e66100590b3df8e20e96e96593f239c50f823..4f4b2a0c2d7b10247c6db4aa0fda5225ec19bbcf 100644 (file)
@@ -714,8 +714,7 @@ static void purge_vis_packets(struct bat_priv *bat_priv)
                        if (info == bat_priv->my_vis_info)
                                continue;
 
-                       if (time_after(jiffies,
-                                      info->first_seen + VIS_TIMEOUT * HZ)) {
+                       if (has_timed_out(info->first_seen, VIS_TIMEOUT)) {
                                hlist_del(node);
                                send_list_del(info);
                                kref_put(&info->refcount, free_info);
index 31b820d07f232ac474911e2cd159a54fed73612c..851bc4f1e35844da7cdd09caa33468a6dc8f135b 100644 (file)
@@ -22,7 +22,8 @@
 #ifndef _NET_BATMAN_ADV_VIS_H_
 #define _NET_BATMAN_ADV_VIS_H_
 
-#define VIS_TIMEOUT            200     /* timeout of vis packets in seconds */
+#define VIS_TIMEOUT            200000  /* timeout of vis packets
+                                        * in miliseconds */
 
 int vis_seq_print_text(struct seq_file *seq, void *offset);
 void receive_server_sync_packet(struct bat_priv *bat_priv,