소스 검색

LockD: manage grace period per network namespace

Signed-off-by: Stanislav Kinsbursky <skinsbursky@parallels.com>
Signed-off-by: J. Bruce Fields <bfields@redhat.com>
Stanislav Kinsbursky 13 년 전
부모
커밋
66547b0251
2개의 변경된 파일13개의 추가작업 그리고 6개의 파일을 삭제
  1. 2 0
      fs/lockd/netns.h
  2. 11 6
      fs/lockd/svc.c

+ 2 - 0
fs/lockd/netns.h

@@ -7,6 +7,8 @@ struct lockd_net {
 	unsigned int nlmsvc_users;
 	unsigned int nlmsvc_users;
 	unsigned long next_gc;
 	unsigned long next_gc;
 	unsigned long nrhosts;
 	unsigned long nrhosts;
+
+	struct delayed_work grace_period_end;
 };
 };
 
 
 extern int lockd_net_id;
 extern int lockd_net_id;

+ 11 - 6
fs/lockd/svc.c

@@ -95,21 +95,22 @@ static void grace_ender(struct work_struct *not_used)
 	locks_end_grace(&lockd_manager);
 	locks_end_grace(&lockd_manager);
 }
 }
 
 
-static DECLARE_DELAYED_WORK(grace_period_end, grace_ender);
-
 static void set_grace_period(void)
 static void set_grace_period(void)
 {
 {
 	unsigned long grace_period = get_lockd_grace_period();
 	unsigned long grace_period = get_lockd_grace_period();
+	struct lockd_net *ln = net_generic(&init_net, lockd_net_id);
 
 
 	locks_start_grace(&lockd_manager);
 	locks_start_grace(&lockd_manager);
-	cancel_delayed_work_sync(&grace_period_end);
-	schedule_delayed_work(&grace_period_end, grace_period);
+	cancel_delayed_work_sync(&ln->grace_period_end);
+	schedule_delayed_work(&ln->grace_period_end, grace_period);
 }
 }
 
 
 static void restart_grace(void)
 static void restart_grace(void)
 {
 {
 	if (nlmsvc_ops) {
 	if (nlmsvc_ops) {
-		cancel_delayed_work_sync(&grace_period_end);
+		struct lockd_net *ln = net_generic(&init_net, lockd_net_id);
+
+		cancel_delayed_work_sync(&ln->grace_period_end);
 		locks_end_grace(&lockd_manager);
 		locks_end_grace(&lockd_manager);
 		nlmsvc_invalidate_all();
 		nlmsvc_invalidate_all();
 		set_grace_period();
 		set_grace_period();
@@ -124,6 +125,7 @@ lockd(void *vrqstp)
 {
 {
 	int		err = 0, preverr = 0;
 	int		err = 0, preverr = 0;
 	struct svc_rqst *rqstp = vrqstp;
 	struct svc_rqst *rqstp = vrqstp;
+	struct lockd_net *ln = net_generic(&init_net, lockd_net_id);
 
 
 	/* try_to_freeze() is called from svc_recv() */
 	/* try_to_freeze() is called from svc_recv() */
 	set_freezable();
 	set_freezable();
@@ -184,7 +186,7 @@ lockd(void *vrqstp)
 		svc_process(rqstp);
 		svc_process(rqstp);
 	}
 	}
 	flush_signals(current);
 	flush_signals(current);
-	cancel_delayed_work_sync(&grace_period_end);
+	cancel_delayed_work_sync(&ln->grace_period_end);
 	locks_end_grace(&lockd_manager);
 	locks_end_grace(&lockd_manager);
 	if (nlmsvc_ops)
 	if (nlmsvc_ops)
 		nlmsvc_invalidate_all();
 		nlmsvc_invalidate_all();
@@ -589,6 +591,9 @@ module_param(nlm_max_connections, uint, 0644);
 
 
 static int lockd_init_net(struct net *net)
 static int lockd_init_net(struct net *net)
 {
 {
+	struct lockd_net *ln = net_generic(net, lockd_net_id);
+
+	INIT_DELAYED_WORK(&ln->grace_period_end, grace_ender);
 	return 0;
 	return 0;
 }
 }