192 	spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags);  in enqueue_reassembly()
193 	list_add_tail(&recvmsg->list, &sc->recv_io.reassembly.list);  in enqueue_reassembly()
194 	sc->recv_io.reassembly.queue_length++;  in enqueue_reassembly()
202 	sc->recv_io.reassembly.data_length += data_length;  in enqueue_reassembly()
203 	spin_unlock_irqrestore(&sc->recv_io.reassembly.lock, flags);  in enqueue_reassembly()
208 	if (!list_empty(&sc->recv_io.reassembly.list))  in get_first_reassembly()
209 		return list_first_entry(&sc->recv_io.reassembly.list,  in get_first_reassembly()
225 	wake_up_all(&sc->recv_io.reassembly.wait_queue);  in smb_direct_disconnect_wake_up_all()
478 	ksmbd_debug(RDMA, "drain the reassembly queue\n");  in free_transport()
482 		spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags);  in free_transport()
486 			spin_unlock_irqrestore(&sc->recv_io.reassembly.lock, flags);  in free_transport()
489 			spin_unlock_irqrestore(&sc->recv_io.reassembly.lock, flags);  in free_transport()
492 	sc->recv_io.reassembly.data_length = 0;  in free_transport()
638 		sc->recv_io.reassembly.full_packet_received = true;  in recv_done()
676 			if (sc->recv_io.reassembly.full_packet_received)  in recv_done()
680 				sc->recv_io.reassembly.full_packet_received = false;  in recv_done()
682 				sc->recv_io.reassembly.full_packet_received = true;  in recv_done()
710 			wake_up(&sc->recv_io.reassembly.wait_queue);  in recv_done()
783 	 * No need to hold the reassembly queue lock all the time as we are  in smb_direct_read()
787 	if (sc->recv_io.reassembly.data_length >= size) {  in smb_direct_read()
800 		queue_length = sc->recv_io.reassembly.queue_length;  in smb_direct_read()
803 		offset = sc->recv_io.reassembly.first_entry_offset;  in smb_direct_read()
846 					spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags);  in smb_direct_read()
848 					spin_unlock_irqrestore(&sc->recv_io.reassembly.lock, flags);  in smb_direct_read()
861 		spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags);  in smb_direct_read()
862 		sc->recv_io.reassembly.data_length -= data_read;  in smb_direct_read()
863 		sc->recv_io.reassembly.queue_length -= queue_removed;  in smb_direct_read()
864 		spin_unlock_irqrestore(&sc->recv_io.reassembly.lock, flags);  in smb_direct_read()
866 		sc->recv_io.reassembly.first_entry_offset = offset;  in smb_direct_read()
869 			    data_read, sc->recv_io.reassembly.data_length,  in smb_direct_read()
870 			    sc->recv_io.reassembly.first_entry_offset);  in smb_direct_read()
876 	rc = wait_event_interruptible(sc->recv_io.reassembly.wait_queue,  in smb_direct_read()
877 				      sc->recv_io.reassembly.data_length >= size ||  in smb_direct_read()
2270 	spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags);  in smb_direct_prepare()
2271 	sc->recv_io.reassembly.queue_length--;  in smb_direct_prepare()
2273 	spin_unlock_irqrestore(&sc->recv_io.reassembly.lock, flags);  in smb_direct_prepare()