ksmbd: work 1

Signed-off-by: Namjae Jeon <linkinjeon@kernel.org>

Author: namjaejeon

oplock.c

@@ -139,6 +139,7 @@ static void free_opinfo_rcu(struct rcu_head *rcu)
 {
 	struct oplock_info *opinfo = container_of(rcu, struct oplock_info, rcu);
 
+	pr_err("%s:%d, opinfo : %p, refcount : %d\n", __func__, __LINE__, opinfo, atomic_read(&opinfo->refcount));
 	if (!atomic_dec_and_test(&opinfo->refcount))
 		return;
 
@@ -166,6 +167,7 @@ static struct oplock_info *opinfo_get_list(struct ksmbd_inode *ci)
 	opinfo = list_first_entry_or_null(&ci->m_op_list, struct oplock_info,
 					  op_entry);
 	if (opinfo) {
+		pr_err("%s:%d\n", __func__, __LINE__);
 		if (opinfo->conn == NULL ||
 		    !atomic_inc_not_zero(&opinfo->refcount))
 			opinfo = NULL;
@@ -186,6 +188,11 @@ void opinfo_put(struct oplock_info *opinfo)
 	if (!opinfo)
 		return;
 
+	pr_err("%s:%d, opinfo : %p, refcount : %d\n", __func__, __LINE__, opinfo, atomic_read(&opinfo->refcount));
+//	if (!atomic_dec_and_test(&opinfo->refcount))
+//		return;
+
+//	pr_err("%s:%d, call rcu opinfo : %p, refcount : %d\n", __func__, __LINE__, opinfo, atomic_read(&opinfo->refcount));
 	call_rcu(&opinfo->rcu, free_opinfo_rcu);
 }
 
@@ -1211,6 +1218,7 @@ int find_same_lease_key(struct ksmbd_session *sess, struct ksmbd_inode *ci,
 found:
 	rcu_read_lock();
 	list_for_each_entry_rcu(opinfo, &lb->lease_list, lease_entry) {
+		pr_err("%s:%d\n", __func__, __LINE__);
 		if (!atomic_inc_not_zero(&opinfo->refcount))
 			continue;
 		rcu_read_unlock();
@@ -1324,6 +1332,7 @@ void smb_send_parent_lease_break_noti(struct ksmbd_file *fp,
 		    (!(lctx->flags & SMB2_LEASE_FLAG_PARENT_LEASE_KEY_SET_LE) ||
 		     !compare_guid_key(opinfo, fp->conn->ClientGUID,
 				      lctx->parent_lease_key))) {
+		pr_err("%s:%d\n", __func__, __LINE__);
 			if (!atomic_inc_not_zero(&opinfo->refcount))
 				continue;
 
@@ -1363,6 +1372,7 @@ void smb_lazy_parent_lease_break_close(struct ksmbd_file *fp)
 			continue;
 
 		if (opinfo->o_lease->state != SMB2_OPLOCK_LEVEL_NONE) {
+		pr_err("%s:%d\n", __func__, __LINE__);
 			if (!atomic_inc_not_zero(&opinfo->refcount))
 				continue;
 
@@ -1515,6 +1525,7 @@ int smb_grant_oplock(struct ksmbd_work *work, int req_op_level, u64 pid,
 
 	return 0;
 err_out:
+	pr_err("%s:%d\n", __func__, __LINE__);
 	free_opinfo(opinfo);
 	return err;
 }
@@ -1558,20 +1569,27 @@ void smb_break_all_levII_oplock(struct ksmbd_work *work, struct ksmbd_file *fp,
 	struct ksmbd_inode *ci;
 	struct ksmbd_conn *conn = work->conn;
 
+//	return;
+
 	if (!test_share_config_flag(work->tcon->share_conf,
 				    KSMBD_SHARE_FLAG_OPLOCKS))
 		return;
 
 	ci = fp->f_ci;
 	op = opinfo_get(fp);
-
+#if 0
 	down_read(&ci->m_lock);
 	list_for_each_entry(brk_op, &ci->m_op_list, op_entry) {
 		if (brk_op->conn == NULL)
 			continue;
 
-		if (!atomic_inc_not_zero(&brk_op->refcount))
+		pr_err("%s:%d, brk_op : %p, refcount : %d\n", __func__, __LINE__, brk_op, atomic_read(&brk_op->refcount));
+		rcu_read_lock();
+		if (!atomic_inc_not_zero(&brk_op->refcount)) {
+			rcu_read_unlock();
 			continue;
+		}
+		rcu_read_unlock();
 
 		if (ksmbd_conn_releasing(brk_op->conn)) {
 			opinfo_put(brk_op);
@@ -1636,10 +1654,14 @@ void smb_break_all_levII_oplock(struct ksmbd_work *work, struct ksmbd_file *fp,
 		brk_op->open_trunc = is_trunc;
 		oplock_break(brk_op, SMB2_OPLOCK_LEVEL_NONE, NULL);
 next:
-		opinfo_put(brk_op);
+		pr_err("%s:%d, brk_op : %p refcount : %d\n", __func__, __LINE__, brk_op, atomic_read(&brk_op->refcount));
+//		opinfo_put(brk_op);
+		atomic_dec(&brk_op->refcount);
 	}
 	up_read(&ci->m_lock);
-
+#endif
+	if (op)
+		pr_err("%s:%d, op : %p refcount : %d\n", __func__, __LINE__, op, atomic_read(&op->refcount));
 	if (op)
 		opinfo_put(op);
 }
@@ -2061,6 +2083,7 @@ struct oplock_info *lookup_lease_in_table(struct ksmbd_conn *conn,
 found:
 	rcu_read_lock();
 	list_for_each_entry_rcu(opinfo, &lt->lease_list, lease_entry) {
+		pr_err("%s:%d\n", __func__, __LINE__);
 		if (!atomic_inc_not_zero(&opinfo->refcount))
 			continue;
 		rcu_read_unlock();