diff options
| -rw-r--r-- | libglusterfs/src/gfdb/gfdb_sqlite3.c | 18 | ||||
| -rw-r--r-- | xlators/cluster/dht/src/tier.c | 4 | 
2 files changed, 20 insertions, 2 deletions
diff --git a/libglusterfs/src/gfdb/gfdb_sqlite3.c b/libglusterfs/src/gfdb/gfdb_sqlite3.c index 349ff60f541..5f4a0fc94ae 100644 --- a/libglusterfs/src/gfdb/gfdb_sqlite3.c +++ b/libglusterfs/src/gfdb/gfdb_sqlite3.c @@ -726,6 +726,15 @@ gf_sqlite3_find_recently_changed_files(void *db_conn,                  goto out;          } +        /*Clear freq counters of un-selected data*/ +        ret = gf_sql_clear_counters(sql_conn); +        if (ret) { +                gf_msg (GFDB_STR_SQLITE3, GF_LOG_ERROR, 0, +                        LG_MSG_CLEAR_COUNTER_FAILED, "Failed clearing" +                        " counters!"); +                goto out; +        } +          ret = 0;  out:          sqlite3_finalize(prep_stmt); @@ -811,6 +820,15 @@ gf_sqlite3_find_unchanged_for_time (void *db_conn,                  goto out;          } +        /*Clear freq counters of un-selected data*/ +        ret = gf_sql_clear_counters(sql_conn); +        if (ret) { +                gf_msg (GFDB_STR_SQLITE3, GF_LOG_ERROR, 0, +                        LG_MSG_CLEAR_COUNTER_FAILED, "Failed clearing" +                        " counters!"); +                goto out; +        } +          ret = 0;  out:          sqlite3_finalize(prep_stmt); diff --git a/xlators/cluster/dht/src/tier.c b/xlators/cluster/dht/src/tier.c index 66a08d10801..26c96a89039 100644 --- a/xlators/cluster/dht/src/tier.c +++ b/xlators/cluster/dht/src/tier.c @@ -508,7 +508,7 @@ tier_process_brick_cbk (dict_t *brick_dict, char *key, data_t *value,                                                          write_freq_threshold,                                          query_cbk_args->defrag->                                                          read_freq_threshold, -                                        _gf_false); +                                        _gf_true);                  }          } else {                  if (query_cbk_args->defrag->write_freq_threshold == 0 && @@ -527,7 +527,7 @@ tier_process_brick_cbk (dict_t *brick_dict, char *key, data_t *value,                                  query_cbk_args->defrag->                                  write_freq_threshold,                                  query_cbk_args->defrag->read_freq_threshold, -                                _gf_false); +                                _gf_true);                  }          }          if (ret) {  | 
