Commit e990f1c6 authored by NeilBrown's avatar NeilBrown Committed by Greg Kroah-Hartman

staging: lustre: libcfs: discard cfs_time_shift().

This function simply multiplies by HZ and adds jiffies.
This is simple enough to be opencoded, and doing so
makes the code easier to read.

Same for cfs_time_shift_64()
Signed-off-by: default avatarNeilBrown <neilb@suse.com>
Reviewed-by: default avatarJames Simmons <jsimmons@infradead.org>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent b0fdb570
...@@ -50,11 +50,6 @@ static inline int cfs_time_aftereq(unsigned long t1, unsigned long t2) ...@@ -50,11 +50,6 @@ static inline int cfs_time_aftereq(unsigned long t1, unsigned long t2)
return time_before_eq(t2, t1); return time_before_eq(t2, t1);
} }
static inline unsigned long cfs_time_shift(int seconds)
{
return jiffies + seconds * HZ;
}
/* /*
* return valid time-out based on user supplied one. Currently we only check * return valid time-out based on user supplied one. Currently we only check
* that time-out is not shorted than allowed. * that time-out is not shorted than allowed.
......
...@@ -65,11 +65,6 @@ static inline long cfs_duration_sec(long d) ...@@ -65,11 +65,6 @@ static inline long cfs_duration_sec(long d)
return d / msecs_to_jiffies(MSEC_PER_SEC); return d / msecs_to_jiffies(MSEC_PER_SEC);
} }
static inline u64 cfs_time_shift_64(int seconds)
{
return get_jiffies_64() + (u64)seconds * HZ;
}
static inline int cfs_time_before_64(u64 t1, u64 t2) static inline int cfs_time_before_64(u64 t1, u64 t2)
{ {
return (__s64)t2 - (__s64)t1 > 0; return (__s64)t2 - (__s64)t1 > 0;
......
...@@ -1446,7 +1446,7 @@ static int kiblnd_create_fmr_pool(struct kib_fmr_poolset *fps, ...@@ -1446,7 +1446,7 @@ static int kiblnd_create_fmr_pool(struct kib_fmr_poolset *fps,
if (rc) if (rc)
goto out_fpo; goto out_fpo;
fpo->fpo_deadline = cfs_time_shift(IBLND_POOL_DEADLINE); fpo->fpo_deadline = jiffies + IBLND_POOL_DEADLINE * HZ;
fpo->fpo_owner = fps; fpo->fpo_owner = fps;
*pp_fpo = fpo; *pp_fpo = fpo;
...@@ -1619,7 +1619,7 @@ int kiblnd_fmr_pool_map(struct kib_fmr_poolset *fps, struct kib_tx *tx, ...@@ -1619,7 +1619,7 @@ int kiblnd_fmr_pool_map(struct kib_fmr_poolset *fps, struct kib_tx *tx,
spin_lock(&fps->fps_lock); spin_lock(&fps->fps_lock);
version = fps->fps_version; version = fps->fps_version;
list_for_each_entry(fpo, &fps->fps_pool_list, fpo_list) { list_for_each_entry(fpo, &fps->fps_pool_list, fpo_list) {
fpo->fpo_deadline = cfs_time_shift(IBLND_POOL_DEADLINE); fpo->fpo_deadline = jiffies + IBLND_POOL_DEADLINE * HZ;
fpo->fpo_map_count++; fpo->fpo_map_count++;
if (fpo->fpo_is_fmr) { if (fpo->fpo_is_fmr) {
...@@ -1743,7 +1743,7 @@ int kiblnd_fmr_pool_map(struct kib_fmr_poolset *fps, struct kib_tx *tx, ...@@ -1743,7 +1743,7 @@ int kiblnd_fmr_pool_map(struct kib_fmr_poolset *fps, struct kib_tx *tx,
fps->fps_version++; fps->fps_version++;
list_add_tail(&fpo->fpo_list, &fps->fps_pool_list); list_add_tail(&fpo->fpo_list, &fps->fps_pool_list);
} else { } else {
fps->fps_next_retry = cfs_time_shift(IBLND_POOL_RETRY); fps->fps_next_retry = jiffies + IBLND_POOL_RETRY * HZ;
} }
spin_unlock(&fps->fps_lock); spin_unlock(&fps->fps_lock);
...@@ -1764,7 +1764,7 @@ static void kiblnd_init_pool(struct kib_poolset *ps, struct kib_pool *pool, int ...@@ -1764,7 +1764,7 @@ static void kiblnd_init_pool(struct kib_poolset *ps, struct kib_pool *pool, int
memset(pool, 0, sizeof(*pool)); memset(pool, 0, sizeof(*pool));
INIT_LIST_HEAD(&pool->po_free_list); INIT_LIST_HEAD(&pool->po_free_list);
pool->po_deadline = cfs_time_shift(IBLND_POOL_DEADLINE); pool->po_deadline = jiffies + IBLND_POOL_DEADLINE * HZ;
pool->po_owner = ps; pool->po_owner = ps;
pool->po_size = size; pool->po_size = size;
} }
...@@ -1899,7 +1899,7 @@ struct list_head *kiblnd_pool_alloc_node(struct kib_poolset *ps) ...@@ -1899,7 +1899,7 @@ struct list_head *kiblnd_pool_alloc_node(struct kib_poolset *ps)
continue; continue;
pool->po_allocated++; pool->po_allocated++;
pool->po_deadline = cfs_time_shift(IBLND_POOL_DEADLINE); pool->po_deadline = jiffies + IBLND_POOL_DEADLINE * HZ;
node = pool->po_free_list.next; node = pool->po_free_list.next;
list_del(node); list_del(node);
...@@ -1947,7 +1947,7 @@ struct list_head *kiblnd_pool_alloc_node(struct kib_poolset *ps) ...@@ -1947,7 +1947,7 @@ struct list_head *kiblnd_pool_alloc_node(struct kib_poolset *ps)
if (!rc) { if (!rc) {
list_add_tail(&pool->po_list, &ps->ps_pool_list); list_add_tail(&pool->po_list, &ps->ps_pool_list);
} else { } else {
ps->ps_next_retry = cfs_time_shift(IBLND_POOL_RETRY); ps->ps_next_retry = jiffies + IBLND_POOL_RETRY * HZ;
CERROR("Can't allocate new %s pool because out of memory\n", CERROR("Can't allocate new %s pool because out of memory\n",
ps->ps_name); ps->ps_name);
} }
......
...@@ -3700,13 +3700,13 @@ kiblnd_failover_thread(void *arg) ...@@ -3700,13 +3700,13 @@ kiblnd_failover_thread(void *arg)
LASSERT(dev->ibd_failover); LASSERT(dev->ibd_failover);
dev->ibd_failover = 0; dev->ibd_failover = 0;
if (rc >= 0) { /* Device is OK or failover succeed */ if (rc >= 0) { /* Device is OK or failover succeed */
dev->ibd_next_failover = cfs_time_shift(3); dev->ibd_next_failover = jiffies + 3 * HZ;
continue; continue;
} }
/* failed to failover, retry later */ /* failed to failover, retry later */
dev->ibd_next_failover = dev->ibd_next_failover =
cfs_time_shift(min(dev->ibd_failed_failover, 10)); jiffies + min(dev->ibd_failed_failover, 10) * HZ;
if (kiblnd_dev_can_failover(dev)) { if (kiblnd_dev_can_failover(dev)) {
list_add_tail(&dev->ibd_fail_list, list_add_tail(&dev->ibd_fail_list,
&kiblnd_data.kib_failed_devs); &kiblnd_data.kib_failed_devs);
......
...@@ -1287,7 +1287,7 @@ ksocknal_create_conn(struct lnet_ni *ni, struct ksock_route *route, ...@@ -1287,7 +1287,7 @@ ksocknal_create_conn(struct lnet_ni *ni, struct ksock_route *route,
conn->ksnc_tx_last_post = jiffies; conn->ksnc_tx_last_post = jiffies;
/* Set the deadline for the outgoing HELLO to drain */ /* Set the deadline for the outgoing HELLO to drain */
conn->ksnc_tx_bufnob = sock->sk->sk_wmem_queued; conn->ksnc_tx_bufnob = sock->sk->sk_wmem_queued;
conn->ksnc_tx_deadline = cfs_time_shift(*ksocknal_tunables.ksnd_timeout); conn->ksnc_tx_deadline = jiffies + *ksocknal_tunables.ksnd_timeout * HZ;
mb(); /* order with adding to peer's conn list */ mb(); /* order with adding to peer's conn list */
list_add(&conn->ksnc_list, &peer->ksnp_conns); list_add(&conn->ksnc_list, &peer->ksnp_conns);
...@@ -1852,7 +1852,7 @@ ksocknal_query(struct lnet_ni *ni, lnet_nid_t nid, unsigned long *when) ...@@ -1852,7 +1852,7 @@ ksocknal_query(struct lnet_ni *ni, lnet_nid_t nid, unsigned long *when)
if (bufnob < conn->ksnc_tx_bufnob) { if (bufnob < conn->ksnc_tx_bufnob) {
/* something got ACKed */ /* something got ACKed */
conn->ksnc_tx_deadline = conn->ksnc_tx_deadline =
cfs_time_shift(*ksocknal_tunables.ksnd_timeout); jiffies + *ksocknal_tunables.ksnd_timeout * HZ;
peer->ksnp_last_alive = now; peer->ksnp_last_alive = now;
conn->ksnc_tx_bufnob = bufnob; conn->ksnc_tx_bufnob = bufnob;
} }
......
...@@ -221,7 +221,7 @@ ksocknal_transmit(struct ksock_conn *conn, struct ksock_tx *tx) ...@@ -221,7 +221,7 @@ ksocknal_transmit(struct ksock_conn *conn, struct ksock_tx *tx)
* something got ACKed * something got ACKed
*/ */
conn->ksnc_tx_deadline = conn->ksnc_tx_deadline =
cfs_time_shift(*ksocknal_tunables.ksnd_timeout); jiffies + *ksocknal_tunables.ksnd_timeout * HZ;
conn->ksnc_peer->ksnp_last_alive = jiffies; conn->ksnc_peer->ksnp_last_alive = jiffies;
conn->ksnc_tx_bufnob = bufnob; conn->ksnc_tx_bufnob = bufnob;
mb(); mb();
...@@ -269,7 +269,7 @@ ksocknal_recv_iter(struct ksock_conn *conn) ...@@ -269,7 +269,7 @@ ksocknal_recv_iter(struct ksock_conn *conn)
conn->ksnc_peer->ksnp_last_alive = jiffies; conn->ksnc_peer->ksnp_last_alive = jiffies;
conn->ksnc_rx_deadline = conn->ksnc_rx_deadline =
cfs_time_shift(*ksocknal_tunables.ksnd_timeout); jiffies + *ksocknal_tunables.ksnd_timeout * HZ;
mb(); /* order with setting rx_started */ mb(); /* order with setting rx_started */
conn->ksnc_rx_started = 1; conn->ksnc_rx_started = 1;
...@@ -405,7 +405,7 @@ ksocknal_check_zc_req(struct ksock_tx *tx) ...@@ -405,7 +405,7 @@ ksocknal_check_zc_req(struct ksock_tx *tx)
/* ZC_REQ is going to be pinned to the peer */ /* ZC_REQ is going to be pinned to the peer */
tx->tx_deadline = tx->tx_deadline =
cfs_time_shift(*ksocknal_tunables.ksnd_timeout); jiffies + *ksocknal_tunables.ksnd_timeout * HZ;
LASSERT(!tx->tx_msg.ksm_zc_cookies[0]); LASSERT(!tx->tx_msg.ksm_zc_cookies[0]);
...@@ -677,7 +677,7 @@ ksocknal_queue_tx_locked(struct ksock_tx *tx, struct ksock_conn *conn) ...@@ -677,7 +677,7 @@ ksocknal_queue_tx_locked(struct ksock_tx *tx, struct ksock_conn *conn)
if (list_empty(&conn->ksnc_tx_queue) && !bufnob) { if (list_empty(&conn->ksnc_tx_queue) && !bufnob) {
/* First packet starts the timeout */ /* First packet starts the timeout */
conn->ksnc_tx_deadline = conn->ksnc_tx_deadline =
cfs_time_shift(*ksocknal_tunables.ksnd_timeout); jiffies + *ksocknal_tunables.ksnd_timeout * HZ;
if (conn->ksnc_tx_bufnob > 0) /* something got ACKed */ if (conn->ksnc_tx_bufnob > 0) /* something got ACKed */
conn->ksnc_peer->ksnp_last_alive = jiffies; conn->ksnc_peer->ksnp_last_alive = jiffies;
conn->ksnc_tx_bufnob = 0; conn->ksnc_tx_bufnob = 0;
...@@ -858,7 +858,7 @@ ksocknal_launch_packet(struct lnet_ni *ni, struct ksock_tx *tx, ...@@ -858,7 +858,7 @@ ksocknal_launch_packet(struct lnet_ni *ni, struct ksock_tx *tx,
ksocknal_find_connecting_route_locked(peer)) { ksocknal_find_connecting_route_locked(peer)) {
/* the message is going to be pinned to the peer */ /* the message is going to be pinned to the peer */
tx->tx_deadline = tx->tx_deadline =
cfs_time_shift(*ksocknal_tunables.ksnd_timeout); jiffies + *ksocknal_tunables.ksnd_timeout * HZ;
/* Queue the message until a connection is established */ /* Queue the message until a connection is established */
list_add_tail(&tx->tx_list, &peer->ksnp_tx_queue); list_add_tail(&tx->tx_list, &peer->ksnp_tx_queue);
...@@ -2308,7 +2308,7 @@ ksocknal_send_keepalive_locked(struct ksock_peer *peer) ...@@ -2308,7 +2308,7 @@ ksocknal_send_keepalive_locked(struct ksock_peer *peer)
* retry 10 secs later, so we wouldn't put pressure * retry 10 secs later, so we wouldn't put pressure
* on this peer if we failed to send keepalive this time * on this peer if we failed to send keepalive this time
*/ */
peer->ksnp_send_keepalive = cfs_time_shift(10); peer->ksnp_send_keepalive = jiffies + 10 * HZ;
conn = ksocknal_find_conn_locked(peer, NULL, 1); conn = ksocknal_find_conn_locked(peer, NULL, 1);
if (conn) { if (conn) {
......
...@@ -169,9 +169,9 @@ lnet_drop_rule_add(struct lnet_fault_attr *attr) ...@@ -169,9 +169,9 @@ lnet_drop_rule_add(struct lnet_fault_attr *attr)
rule->dr_attr = *attr; rule->dr_attr = *attr;
if (attr->u.drop.da_interval) { if (attr->u.drop.da_interval) {
rule->dr_time_base = cfs_time_shift(attr->u.drop.da_interval); rule->dr_time_base = jiffies + attr->u.drop.da_interval * HZ;
rule->dr_drop_time = cfs_time_shift( rule->dr_drop_time = jiffies +
prandom_u32_max(attr->u.drop.da_interval)); prandom_u32_max(attr->u.drop.da_interval) * HZ;
} else { } else {
rule->dr_drop_at = prandom_u32_max(attr->u.drop.da_rate); rule->dr_drop_at = prandom_u32_max(attr->u.drop.da_rate);
} }
...@@ -279,9 +279,9 @@ lnet_drop_rule_reset(void) ...@@ -279,9 +279,9 @@ lnet_drop_rule_reset(void)
if (attr->u.drop.da_rate) { if (attr->u.drop.da_rate) {
rule->dr_drop_at = prandom_u32_max(attr->u.drop.da_rate); rule->dr_drop_at = prandom_u32_max(attr->u.drop.da_rate);
} else { } else {
rule->dr_drop_time = cfs_time_shift( rule->dr_drop_time = jiffies +
prandom_u32_max(attr->u.drop.da_interval)); prandom_u32_max(attr->u.drop.da_interval) * HZ;
rule->dr_time_base = cfs_time_shift(attr->u.drop.da_interval); rule->dr_time_base = jiffies + attr->u.drop.da_interval * HZ;
} }
spin_unlock(&rule->dr_lock); spin_unlock(&rule->dr_lock);
} }
...@@ -513,7 +513,7 @@ delay_rule_match(struct lnet_delay_rule *rule, lnet_nid_t src, ...@@ -513,7 +513,7 @@ delay_rule_match(struct lnet_delay_rule *rule, lnet_nid_t src,
list_add_tail(&msg->msg_list, &rule->dl_msg_list); list_add_tail(&msg->msg_list, &rule->dl_msg_list);
msg->msg_delay_send = round_timeout( msg->msg_delay_send = round_timeout(
cfs_time_shift(attr->u.delay.la_latency)); jiffies + attr->u.delay.la_latency * HZ);
if (rule->dl_msg_send == -1) { if (rule->dl_msg_send == -1) {
rule->dl_msg_send = msg->msg_delay_send; rule->dl_msg_send = msg->msg_delay_send;
mod_timer(&rule->dl_timer, rule->dl_msg_send); mod_timer(&rule->dl_timer, rule->dl_msg_send);
...@@ -767,9 +767,9 @@ lnet_delay_rule_add(struct lnet_fault_attr *attr) ...@@ -767,9 +767,9 @@ lnet_delay_rule_add(struct lnet_fault_attr *attr)
rule->dl_attr = *attr; rule->dl_attr = *attr;
if (attr->u.delay.la_interval) { if (attr->u.delay.la_interval) {
rule->dl_time_base = cfs_time_shift(attr->u.delay.la_interval); rule->dl_time_base = jiffies + attr->u.delay.la_interval * HZ;
rule->dl_delay_time = cfs_time_shift( rule->dl_delay_time = jiffies +
prandom_u32_max(attr->u.delay.la_interval)); prandom_u32_max(attr->u.delay.la_interval) * HZ;
} else { } else {
rule->dl_delay_at = prandom_u32_max(attr->u.delay.la_rate); rule->dl_delay_at = prandom_u32_max(attr->u.delay.la_rate);
} }
...@@ -920,9 +920,9 @@ lnet_delay_rule_reset(void) ...@@ -920,9 +920,9 @@ lnet_delay_rule_reset(void)
rule->dl_delay_at = prandom_u32_max(attr->u.delay.la_rate); rule->dl_delay_at = prandom_u32_max(attr->u.delay.la_rate);
} else { } else {
rule->dl_delay_time = rule->dl_delay_time =
cfs_time_shift(prandom_u32_max( jiffies + prandom_u32_max(
attr->u.delay.la_interval)); attr->u.delay.la_interval) * HZ;
rule->dl_time_base = cfs_time_shift(attr->u.delay.la_interval); rule->dl_time_base = jiffies + attr->u.delay.la_interval * HZ;
} }
spin_unlock(&rule->dl_lock); spin_unlock(&rule->dl_lock);
} }
......
...@@ -1026,7 +1026,7 @@ lnet_ping_router_locked(struct lnet_peer *rtr) ...@@ -1026,7 +1026,7 @@ lnet_ping_router_locked(struct lnet_peer *rtr)
if (!rtr->lp_ping_deadline) { if (!rtr->lp_ping_deadline) {
rtr->lp_ping_deadline = rtr->lp_ping_deadline =
cfs_time_shift(router_ping_timeout); jiffies + router_ping_timeout * HZ;
} }
lnet_net_unlock(rtr->lp_cpt); lnet_net_unlock(rtr->lp_cpt);
......
...@@ -118,7 +118,7 @@ static void ldlm_expired_completion_wait(struct ldlm_lock *lock, __u32 conn_cnt) ...@@ -118,7 +118,7 @@ static void ldlm_expired_completion_wait(struct ldlm_lock *lock, __u32 conn_cnt)
lock->l_last_activity)); lock->l_last_activity));
if (cfs_time_after(jiffies, next_dump)) { if (cfs_time_after(jiffies, next_dump)) {
last_dump = next_dump; last_dump = next_dump;
next_dump = cfs_time_shift(300); next_dump = jiffies + 300 * HZ;
ldlm_namespace_dump(D_DLMTRACE, ldlm_namespace_dump(D_DLMTRACE,
ldlm_lock_to_ns(lock)); ldlm_lock_to_ns(lock));
if (last_dump == 0) if (last_dump == 0)
......
...@@ -1323,7 +1323,7 @@ void ldlm_namespace_dump(int level, struct ldlm_namespace *ns) ...@@ -1323,7 +1323,7 @@ void ldlm_namespace_dump(int level, struct ldlm_namespace *ns)
ldlm_res_hash_dump, ldlm_res_hash_dump,
(void *)(unsigned long)level, 0); (void *)(unsigned long)level, 0);
spin_lock(&ns->ns_lock); spin_lock(&ns->ns_lock);
ns->ns_next_dump = cfs_time_shift(10); ns->ns_next_dump = jiffies + 10 * HZ;
spin_unlock(&ns->ns_lock); spin_unlock(&ns->ns_lock);
} }
......
...@@ -257,7 +257,7 @@ static int client_common_fill_super(struct super_block *sb, char *md, char *dt) ...@@ -257,7 +257,7 @@ static int client_common_fill_super(struct super_block *sb, char *md, char *dt)
* available * available
*/ */
err = obd_statfs(NULL, sbi->ll_md_exp, osfs, err = obd_statfs(NULL, sbi->ll_md_exp, osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_FOR_MDT0); OBD_STATFS_FOR_MDT0);
if (err) if (err)
goto out_md_fid; goto out_md_fid;
...@@ -1675,7 +1675,7 @@ int ll_statfs(struct dentry *de, struct kstatfs *sfs) ...@@ -1675,7 +1675,7 @@ int ll_statfs(struct dentry *de, struct kstatfs *sfs)
/* Some amount of caching on the client is allowed */ /* Some amount of caching on the client is allowed */
rc = ll_statfs_internal(sb, &osfs, rc = ll_statfs_internal(sb, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
0); 0);
if (rc) if (rc)
return rc; return rc;
......
...@@ -53,7 +53,7 @@ static ssize_t blocksize_show(struct kobject *kobj, struct attribute *attr, ...@@ -53,7 +53,7 @@ static ssize_t blocksize_show(struct kobject *kobj, struct attribute *attr,
int rc; int rc;
rc = ll_statfs_internal(sbi->ll_sb, &osfs, rc = ll_statfs_internal(sbi->ll_sb, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) if (!rc)
return sprintf(buf, "%u\n", osfs.os_bsize); return sprintf(buf, "%u\n", osfs.os_bsize);
...@@ -71,7 +71,7 @@ static ssize_t kbytestotal_show(struct kobject *kobj, struct attribute *attr, ...@@ -71,7 +71,7 @@ static ssize_t kbytestotal_show(struct kobject *kobj, struct attribute *attr,
int rc; int rc;
rc = ll_statfs_internal(sbi->ll_sb, &osfs, rc = ll_statfs_internal(sbi->ll_sb, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) { if (!rc) {
__u32 blk_size = osfs.os_bsize >> 10; __u32 blk_size = osfs.os_bsize >> 10;
...@@ -96,7 +96,7 @@ static ssize_t kbytesfree_show(struct kobject *kobj, struct attribute *attr, ...@@ -96,7 +96,7 @@ static ssize_t kbytesfree_show(struct kobject *kobj, struct attribute *attr,
int rc; int rc;
rc = ll_statfs_internal(sbi->ll_sb, &osfs, rc = ll_statfs_internal(sbi->ll_sb, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) { if (!rc) {
__u32 blk_size = osfs.os_bsize >> 10; __u32 blk_size = osfs.os_bsize >> 10;
...@@ -121,7 +121,7 @@ static ssize_t kbytesavail_show(struct kobject *kobj, struct attribute *attr, ...@@ -121,7 +121,7 @@ static ssize_t kbytesavail_show(struct kobject *kobj, struct attribute *attr,
int rc; int rc;
rc = ll_statfs_internal(sbi->ll_sb, &osfs, rc = ll_statfs_internal(sbi->ll_sb, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) { if (!rc) {
__u32 blk_size = osfs.os_bsize >> 10; __u32 blk_size = osfs.os_bsize >> 10;
...@@ -146,7 +146,7 @@ static ssize_t filestotal_show(struct kobject *kobj, struct attribute *attr, ...@@ -146,7 +146,7 @@ static ssize_t filestotal_show(struct kobject *kobj, struct attribute *attr,
int rc; int rc;
rc = ll_statfs_internal(sbi->ll_sb, &osfs, rc = ll_statfs_internal(sbi->ll_sb, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) if (!rc)
return sprintf(buf, "%llu\n", osfs.os_files); return sprintf(buf, "%llu\n", osfs.os_files);
...@@ -164,7 +164,7 @@ static ssize_t filesfree_show(struct kobject *kobj, struct attribute *attr, ...@@ -164,7 +164,7 @@ static ssize_t filesfree_show(struct kobject *kobj, struct attribute *attr,
int rc; int rc;
rc = ll_statfs_internal(sbi->ll_sb, &osfs, rc = ll_statfs_internal(sbi->ll_sb, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) if (!rc)
return sprintf(buf, "%llu\n", osfs.os_ffree); return sprintf(buf, "%llu\n", osfs.os_ffree);
......
...@@ -523,7 +523,7 @@ static void ll_agl_trigger(struct inode *inode, struct ll_statahead_info *sai) ...@@ -523,7 +523,7 @@ static void ll_agl_trigger(struct inode *inode, struct ll_statahead_info *sai)
* affect the performance. * affect the performance.
*/ */
if (lli->lli_glimpse_time != 0 && if (lli->lli_glimpse_time != 0 &&
time_before(cfs_time_shift(-1), lli->lli_glimpse_time)) { time_before(jiffies - 1 * HZ, lli->lli_glimpse_time)) {
up_write(&lli->lli_glimpse_sem); up_write(&lli->lli_glimpse_sem);
lli->lli_agl_index = 0; lli->lli_agl_index = 0;
iput(inode); iput(inode);
......
...@@ -876,7 +876,7 @@ static int lmv_iocontrol(unsigned int cmd, struct obd_export *exp, ...@@ -876,7 +876,7 @@ static int lmv_iocontrol(unsigned int cmd, struct obd_export *exp,
return -EFAULT; return -EFAULT;
rc = obd_statfs(NULL, tgt->ltd_exp, &stat_buf, rc = obd_statfs(NULL, tgt->ltd_exp, &stat_buf,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
0); 0);
if (rc) if (rc)
return rc; return rc;
......
...@@ -1063,7 +1063,7 @@ static int lov_iocontrol(unsigned int cmd, struct obd_export *exp, int len, ...@@ -1063,7 +1063,7 @@ static int lov_iocontrol(unsigned int cmd, struct obd_export *exp, int len,
/* got statfs data */ /* got statfs data */
rc = obd_statfs(NULL, lov->lov_tgts[index]->ltd_exp, &stat_buf, rc = obd_statfs(NULL, lov->lov_tgts[index]->ltd_exp, &stat_buf,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
flags); flags);
if (rc) if (rc)
return rc; return rc;
......
...@@ -2104,7 +2104,7 @@ static int mdc_iocontrol(unsigned int cmd, struct obd_export *exp, int len, ...@@ -2104,7 +2104,7 @@ static int mdc_iocontrol(unsigned int cmd, struct obd_export *exp, int len,
} }
rc = mdc_statfs(NULL, obd->obd_self_export, &stat_buf, rc = mdc_statfs(NULL, obd->obd_self_export, &stat_buf,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
0); 0);
if (rc != 0) if (rc != 0)
goto out; goto out;
......
...@@ -407,7 +407,7 @@ static ssize_t blocksize_show(struct kobject *kobj, struct attribute *attr, ...@@ -407,7 +407,7 @@ static ssize_t blocksize_show(struct kobject *kobj, struct attribute *attr,
obd_kobj); obd_kobj);
struct obd_statfs osfs; struct obd_statfs osfs;
int rc = obd_statfs(NULL, obd->obd_self_export, &osfs, int rc = obd_statfs(NULL, obd->obd_self_export, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) if (!rc)
return sprintf(buf, "%u\n", osfs.os_bsize); return sprintf(buf, "%u\n", osfs.os_bsize);
...@@ -423,7 +423,7 @@ static ssize_t kbytestotal_show(struct kobject *kobj, struct attribute *attr, ...@@ -423,7 +423,7 @@ static ssize_t kbytestotal_show(struct kobject *kobj, struct attribute *attr,
obd_kobj); obd_kobj);
struct obd_statfs osfs; struct obd_statfs osfs;
int rc = obd_statfs(NULL, obd->obd_self_export, &osfs, int rc = obd_statfs(NULL, obd->obd_self_export, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) { if (!rc) {
__u32 blk_size = osfs.os_bsize >> 10; __u32 blk_size = osfs.os_bsize >> 10;
...@@ -446,7 +446,7 @@ static ssize_t kbytesfree_show(struct kobject *kobj, struct attribute *attr, ...@@ -446,7 +446,7 @@ static ssize_t kbytesfree_show(struct kobject *kobj, struct attribute *attr,
obd_kobj); obd_kobj);
struct obd_statfs osfs; struct obd_statfs osfs;
int rc = obd_statfs(NULL, obd->obd_self_export, &osfs, int rc = obd_statfs(NULL, obd->obd_self_export, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) { if (!rc) {
__u32 blk_size = osfs.os_bsize >> 10; __u32 blk_size = osfs.os_bsize >> 10;
...@@ -469,7 +469,7 @@ static ssize_t kbytesavail_show(struct kobject *kobj, struct attribute *attr, ...@@ -469,7 +469,7 @@ static ssize_t kbytesavail_show(struct kobject *kobj, struct attribute *attr,
obd_kobj); obd_kobj);
struct obd_statfs osfs; struct obd_statfs osfs;
int rc = obd_statfs(NULL, obd->obd_self_export, &osfs, int rc = obd_statfs(NULL, obd->obd_self_export, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) { if (!rc) {
__u32 blk_size = osfs.os_bsize >> 10; __u32 blk_size = osfs.os_bsize >> 10;
...@@ -492,7 +492,7 @@ static ssize_t filestotal_show(struct kobject *kobj, struct attribute *attr, ...@@ -492,7 +492,7 @@ static ssize_t filestotal_show(struct kobject *kobj, struct attribute *attr,
obd_kobj); obd_kobj);
struct obd_statfs osfs; struct obd_statfs osfs;
int rc = obd_statfs(NULL, obd->obd_self_export, &osfs, int rc = obd_statfs(NULL, obd->obd_self_export, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) if (!rc)
return sprintf(buf, "%llu\n", osfs.os_files); return sprintf(buf, "%llu\n", osfs.os_files);
...@@ -508,7 +508,7 @@ static ssize_t filesfree_show(struct kobject *kobj, struct attribute *attr, ...@@ -508,7 +508,7 @@ static ssize_t filesfree_show(struct kobject *kobj, struct attribute *attr,
obd_kobj); obd_kobj);
struct obd_statfs osfs; struct obd_statfs osfs;
int rc = obd_statfs(NULL, obd->obd_self_export, &osfs, int rc = obd_statfs(NULL, obd->obd_self_export, &osfs,
cfs_time_shift_64(-OBD_STATFS_CACHE_SECONDS), get_jiffies_64() - OBD_STATFS_CACHE_SECONDS * HZ,
OBD_STATFS_NODELAY); OBD_STATFS_NODELAY);
if (!rc) if (!rc)
return sprintf(buf, "%llu\n", osfs.os_ffree); return sprintf(buf, "%llu\n", osfs.os_ffree);
......
...@@ -269,7 +269,7 @@ static int class_attach(struct lustre_cfg *lcfg) ...@@ -269,7 +269,7 @@ static int class_attach(struct lustre_cfg *lcfg)
/* obd->obd_osfs_age must be set to a value in the distant /* obd->obd_osfs_age must be set to a value in the distant
* past to guarantee a fresh statfs is fetched on mount. * past to guarantee a fresh statfs is fetched on mount.
*/ */
obd->obd_osfs_age = cfs_time_shift_64(-1000); obd->obd_osfs_age = get_jiffies_64() - 1000 * HZ;
/* XXX belongs in setup not attach */ /* XXX belongs in setup not attach */
init_rwsem(&obd->obd_observer_link_sem); init_rwsem(&obd->obd_observer_link_sem);
......
...@@ -617,7 +617,7 @@ static void osc_announce_cached(struct client_obd *cli, struct obdo *oa, ...@@ -617,7 +617,7 @@ static void osc_announce_cached(struct client_obd *cli, struct obdo *oa,
void osc_update_next_shrink(struct client_obd *cli) void osc_update_next_shrink(struct client_obd *cli)
{ {
cli->cl_next_shrink_grant = cli->cl_next_shrink_grant =
cfs_time_shift(cli->cl_grant_shrink_interval); jiffies + cli->cl_grant_shrink_interval * HZ;
CDEBUG(D_CACHE, "next time %ld to shrink grant\n", CDEBUG(D_CACHE, "next time %ld to shrink grant\n",
cli->cl_next_shrink_grant); cli->cl_next_shrink_grant);
} }
......
...@@ -108,7 +108,7 @@ static void ptlrpc_update_next_ping(struct obd_import *imp, int soon) ...@@ -108,7 +108,7 @@ static void ptlrpc_update_next_ping(struct obd_import *imp, int soon)
at_get(&imp->imp_at.iat_net_latency)); at_get(&imp->imp_at.iat_net_latency));
time = min(time, dtime); time = min(time, dtime);
} }
imp->imp_next_ping = cfs_time_shift(time); imp->imp_next_ping = jiffies + time * HZ;
} }
static inline int imp_is_deactive(struct obd_import *imp) static inline int imp_is_deactive(struct obd_import *imp)
...@@ -120,9 +120,9 @@ static inline int imp_is_deactive(struct obd_import *imp) ...@@ -120,9 +120,9 @@ static inline int imp_is_deactive(struct obd_import *imp)
static inline int ptlrpc_next_reconnect(struct obd_import *imp) static inline int ptlrpc_next_reconnect(struct obd_import *imp)
{ {
if (imp->imp_server_timeout) if (imp->imp_server_timeout)
return cfs_time_shift(obd_timeout / 2); return jiffies + obd_timeout / 2 * HZ;
else else
return cfs_time_shift(obd_timeout); return jiffies + obd_timeout * HZ;
} }
static long pinger_check_timeout(unsigned long time) static long pinger_check_timeout(unsigned long time)
......
...@@ -922,7 +922,7 @@ static void ptlrpc_at_set_timer(struct ptlrpc_service_part *svcpt) ...@@ -922,7 +922,7 @@ static void ptlrpc_at_set_timer(struct ptlrpc_service_part *svcpt)
if (next <= 0) { if (next <= 0) {
ptlrpc_at_timer(&svcpt->scp_at_timer); ptlrpc_at_timer(&svcpt->scp_at_timer);
} else { } else {
mod_timer(&svcpt->scp_at_timer, cfs_time_shift(next)); mod_timer(&svcpt->scp_at_timer, jiffies + next * HZ);
CDEBUG(D_INFO, "armed %s at %+ds\n", CDEBUG(D_INFO, "armed %s at %+ds\n",
svcpt->scp_service->srv_name, next); svcpt->scp_service->srv_name, next);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment