Lines Matching refs:reassembly
231 wake_up_interruptible(&sc->recv_io.reassembly.wait_queue); in smbd_conn_upcall()
480 sc->recv_io.reassembly.full_packet_received = true; in recv_done()
493 if (sc->recv_io.reassembly.full_packet_received) in recv_done()
497 sc->recv_io.reassembly.full_packet_received = false; in recv_done()
499 sc->recv_io.reassembly.full_packet_received = true; in recv_done()
534 wake_up_interruptible(&sc->recv_io.reassembly.wait_queue); in recv_done()
1136 spin_lock(&sc->recv_io.reassembly.lock); in enqueue_reassembly()
1137 list_add_tail(&response->list, &sc->recv_io.reassembly.list); in enqueue_reassembly()
1138 sc->recv_io.reassembly.queue_length++; in enqueue_reassembly()
1146 sc->recv_io.reassembly.data_length += data_length; in enqueue_reassembly()
1147 spin_unlock(&sc->recv_io.reassembly.lock); in enqueue_reassembly()
1162 if (!list_empty(&sc->recv_io.reassembly.list)) { in _get_first_reassembly()
1164 &sc->recv_io.reassembly.list, in _get_first_reassembly()
1232 INIT_LIST_HEAD(&sc->recv_io.reassembly.list); in allocate_receive_buffers()
1233 spin_lock_init(&sc->recv_io.reassembly.lock); in allocate_receive_buffers()
1234 sc->recv_io.reassembly.data_length = 0; in allocate_receive_buffers()
1235 sc->recv_io.reassembly.queue_length = 0; in allocate_receive_buffers()
1343 spin_lock_irqsave(&sc->recv_io.reassembly.lock, flags); in smbd_destroy()
1348 &sc->recv_io.reassembly.lock, flags); in smbd_destroy()
1352 &sc->recv_io.reassembly.lock, flags); in smbd_destroy()
1354 sc->recv_io.reassembly.data_length = 0; in smbd_destroy()
1650 init_waitqueue_head(&sc->recv_io.reassembly.wait_queue); in _smbd_get_connection()
1789 sc->recv_io.reassembly.data_length); in smbd_recv()
1790 if (sc->recv_io.reassembly.data_length >= size) { in smbd_recv()
1802 queue_length = sc->recv_io.reassembly.queue_length; in smbd_recv()
1805 offset = sc->recv_io.reassembly.first_entry_offset; in smbd_recv()
1853 &sc->recv_io.reassembly.lock); in smbd_recv()
1856 &sc->recv_io.reassembly.lock); in smbd_recv()
1875 spin_lock_irq(&sc->recv_io.reassembly.lock); in smbd_recv()
1876 sc->recv_io.reassembly.data_length -= data_read; in smbd_recv()
1877 sc->recv_io.reassembly.queue_length -= queue_removed; in smbd_recv()
1878 spin_unlock_irq(&sc->recv_io.reassembly.lock); in smbd_recv()
1880 sc->recv_io.reassembly.first_entry_offset = offset; in smbd_recv()
1882 data_read, sc->recv_io.reassembly.data_length, in smbd_recv()
1883 sc->recv_io.reassembly.first_entry_offset); in smbd_recv()
1890 sc->recv_io.reassembly.wait_queue, in smbd_recv()
1891 sc->recv_io.reassembly.data_length >= size || in smbd_recv()