From 6f271946afa104952f56be86a9494eb8e1ec245e Mon Sep 17 00:00:00 2001 From: Johann Lombardi Date: Sat, 16 Jan 2010 15:21:28 +0100 Subject: [PATCH] b=21574 define ptlrpc_pinger_commit_expected for liblustre i=oleg i=andrew --- lustre/ptlrpc/pinger.c | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/lustre/ptlrpc/pinger.c b/lustre/ptlrpc/pinger.c index 68ac4e3..0f3bd3b 100644 --- a/lustre/ptlrpc/pinger.c +++ b/lustre/ptlrpc/pinger.c @@ -886,6 +886,21 @@ void ptlrpc_pinger_sending_on_import(struct obd_import *imp) #endif } +void ptlrpc_pinger_commit_expected(struct obd_import *imp) +{ +#ifdef ENABLE_PINGER + mutex_down(&pinger_sem); + ptlrpc_update_next_ping(imp, 1); + if (pinger_args.pd_set == NULL && + time_before(imp->imp_next_ping, pinger_args.pd_next_ping)) { + CDEBUG(D_HA, "set next ping to "CFS_TIME_T"(cur "CFS_TIME_T")\n", + imp->imp_next_ping, cfs_time_current()); + pinger_args.pd_next_ping = imp->imp_next_ping; + } + mutex_up(&pinger_sem); +#endif +} + int ptlrpc_add_timeout_client(int time, enum timeout_event event, timeout_cb_t cb, void *data, struct list_head *obd_list) -- 1.8.3.1