Lines Matching refs:posted
198 INIT_WORK(&sc->recv_io.posted.refill_work, smbdirect_connection_recv_io_refill_work); in smbdirect_connection_negotiation_done()
606 queue_work(sc->workqueues.refill, &sc->recv_io.posted.refill_work); in smbdirect_connection_put_recv_io()
1147 queue_work(sc->workqueues.refill, &sc->recv_io.posted.refill_work); in smbdirect_connection_send_single_iter()
1622 atomic_dec(&sc->recv_io.posted.count); in smbdirect_connection_recv_io_done()
1657 queue_work(sc->workqueues.refill, &sc->recv_io.posted.refill_work); in smbdirect_connection_recv_io_done()
1671 disable_work(&sc->recv_io.posted.refill_work); in smbdirect_connection_recv_io_done()
1679 int posted = 0; in smbdirect_connection_recv_io_refill() local
1706 missing = (int)sc->recv_io.credits.target - atomic_read(&sc->recv_io.posted.count); in smbdirect_connection_recv_io_refill()
1707 while (posted < missing) { in smbdirect_connection_recv_io_refill()
1731 atomic_inc(&sc->recv_io.posted.count); in smbdirect_connection_recv_io_refill()
1732 posted += 1; in smbdirect_connection_recv_io_refill()
1736 if (posted == 0) in smbdirect_connection_recv_io_refill()
1739 atomic_add(posted, &sc->recv_io.credits.available); in smbdirect_connection_recv_io_refill()
1770 return posted; in smbdirect_connection_recv_io_refill()
1776 container_of(work, struct smbdirect_socket, recv_io.posted.refill_work); in smbdirect_connection_recv_io_refill_work()
1777 int posted; in smbdirect_connection_recv_io_refill_work() local
1779 posted = smbdirect_connection_recv_io_refill(sc); in smbdirect_connection_recv_io_refill_work()
1780 if (unlikely(posted < 0)) { in smbdirect_connection_recv_io_refill_work()
1781 smbdirect_socket_schedule_cleanup(sc, posted); in smbdirect_connection_recv_io_refill_work()
1784 if (posted > 0) { in smbdirect_connection_recv_io_refill_work()