179 	wake_up_all(&sc->recv_io.reassembly.wait_queue);  in smbd_disconnect_wake_up_all()
695 		sc->recv_io.reassembly.full_packet_received = true;  in recv_done()
731 			if (sc->recv_io.reassembly.full_packet_received)  in recv_done()
735 				sc->recv_io.reassembly.full_packet_received = false;  in recv_done()
737 				sc->recv_io.reassembly.full_packet_received = true;  in recv_done()
774 		 * reassembly queue and wake up the reading thread  in recv_done()
781 			wake_up(&sc->recv_io.reassembly.wait_queue);  in recv_done()
1397  * layer. All the inncoming payload go to the reassembly queue, regardless of
1398  * if reassembly is required. The uuper layer code reads from the queue for all
1400  * Put a received packet to the reassembly queue
1411 	spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags);  in enqueue_reassembly()
1412 	list_add_tail(&response->list, &sc->recv_io.reassembly.list);  in enqueue_reassembly()
1413 	sc->recv_io.reassembly.queue_length++;  in enqueue_reassembly()
1421 	sc->recv_io.reassembly.data_length += data_length;  in enqueue_reassembly()
1422 	spin_unlock_irqrestore(&sc->recv_io.reassembly.lock, flags);  in enqueue_reassembly()
1427  * Get the first entry at the front of reassembly queue
1435 	if (!list_empty(&sc->recv_io.reassembly.list)) {  in _get_first_reassembly()
1437 			&sc->recv_io.reassembly.list,  in _get_first_reassembly()
1625 	/* It's not possible for upper layer to get to reassembly */  in smbd_destroy()
1626 	log_rdma_event(INFO, "drain the reassembly queue\n");  in smbd_destroy()
1628 		spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags);  in smbd_destroy()
1633 				&sc->recv_io.reassembly.lock, flags);  in smbd_destroy()
1637 				&sc->recv_io.reassembly.lock, flags);  in smbd_destroy()
1639 	sc->recv_io.reassembly.data_length = 0;  in smbd_destroy()
2062  * Receive data from the transport's receive reassembly queue
2063  * All the incoming data packets are placed in reassembly queue
2068  * Note: this implementation copies the data from reassembly queue to receive
2071  * borrow the buffer from reassembly queue, and return it after data is
2090 	 * No need to hold the reassembly queue lock all the time as we are  in smbd_recv()
2094 	log_read(INFO, "size=%zd sc->recv_io.reassembly.data_length=%d\n", size,  in smbd_recv()
2095 		sc->recv_io.reassembly.data_length);  in smbd_recv()
2096 	if (sc->recv_io.reassembly.data_length >= size) {  in smbd_recv()
2109 		queue_length = sc->recv_io.reassembly.queue_length;  in smbd_recv()
2112 		offset = sc->recv_io.reassembly.first_entry_offset;  in smbd_recv()
2160 						&sc->recv_io.reassembly.lock, flags);  in smbd_recv()
2163 						&sc->recv_io.reassembly.lock, flags);  in smbd_recv()
2181 		spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags);  in smbd_recv()
2182 		sc->recv_io.reassembly.data_length -= data_read;  in smbd_recv()
2183 		sc->recv_io.reassembly.queue_length -= queue_removed;  in smbd_recv()
2184 		spin_unlock_irqrestore(&sc->recv_io.reassembly.lock, flags);  in smbd_recv()
2186 		sc->recv_io.reassembly.first_entry_offset = offset;  in smbd_recv()
2188 			 data_read, sc->recv_io.reassembly.data_length,  in smbd_recv()
2189 			 sc->recv_io.reassembly.first_entry_offset);  in smbd_recv()
2196 		sc->recv_io.reassembly.wait_queue,  in smbd_recv()
2197 		sc->recv_io.reassembly.data_length >= size ||  in smbd_recv()