Lines Matching refs:pending
804 spin_lock(&ptl->pending.lock); in ssh_ptl_pending_push()
808 spin_unlock(&ptl->pending.lock); in ssh_ptl_pending_push()
821 atomic_inc(&ptl->pending.count); in ssh_ptl_pending_push()
822 list_add_tail(&ssh_packet_get(p)->pending_node, &ptl->pending.head); in ssh_ptl_pending_push()
825 spin_unlock(&ptl->pending.lock); in ssh_ptl_pending_push()
835 spin_lock(&ptl->pending.lock); in ssh_ptl_pending_remove()
838 spin_unlock(&ptl->pending.lock); in ssh_ptl_pending_remove()
843 atomic_dec(&ptl->pending.count); in ssh_ptl_pending_remove()
845 spin_unlock(&ptl->pending.lock); in ssh_ptl_pending_remove()
888 return !atomic_read(&ptl->pending.count); in ssh_ptl_tx_can_process()
899 return atomic_read(&ptl->pending.count) < SSH_PTL_MAX_PENDING; in ssh_ptl_tx_can_process()
1198 spin_lock(&ptl->pending.lock); in ssh_ptl_ack_pop()
1199 list_for_each_entry_safe(p, n, &ptl->pending.head, pending_node) { in ssh_ptl_ack_pop()
1226 atomic_dec(&ptl->pending.count); in ssh_ptl_ack_pop()
1232 spin_unlock(&ptl->pending.lock); in ssh_ptl_ack_pop()
1295 if (atomic_read(&ptl->pending.count) < SSH_PTL_MAX_PENDING) in ssh_ptl_acknowledge()
1345 (atomic_read(&ptl->pending.count) < SSH_PTL_MAX_PENDING)) in ssh_ptl_submit()
1368 lockdep_assert_held(&packet->ptl->pending.lock); in __ssh_ptl_resubmit()
1414 spin_lock(&ptl->pending.lock); in ssh_ptl_resubmit_pending()
1417 list_for_each_entry(p, &ptl->pending.head, pending_node) { in ssh_ptl_resubmit_pending()
1427 spin_unlock(&ptl->pending.lock); in ssh_ptl_resubmit_pending()
1481 if (atomic_read(&p->ptl->pending.count) < SSH_PTL_MAX_PENDING) in ssh_ptl_cancel()
1492 lockdep_assert_held(&p->ptl->pending.lock); in ssh_packet_get_expiration()
1511 trace_ssam_ptl_timeout_reap(atomic_read(&ptl->pending.count)); in ssh_ptl_timeout_reap()
1521 spin_lock(&ptl->pending.lock); in ssh_ptl_timeout_reap()
1523 list_for_each_entry_safe(p, n, &ptl->pending.head, pending_node) { in ssh_ptl_timeout_reap()
1569 atomic_dec(&ptl->pending.count); in ssh_ptl_timeout_reap()
1573 spin_unlock(&ptl->pending.lock); in ssh_ptl_timeout_reap()
1979 spin_lock(&ptl->pending.lock); in ssh_ptl_shutdown()
1980 list_for_each_entry_safe(p, n, &ptl->pending.head, pending_node) { in ssh_ptl_shutdown()
1988 atomic_set(&ptl->pending.count, 0); in ssh_ptl_shutdown()
1989 spin_unlock(&ptl->pending.lock); in ssh_ptl_shutdown()
2037 spin_lock_init(&ptl->pending.lock); in ssh_ptl_init()
2038 INIT_LIST_HEAD(&ptl->pending.head); in ssh_ptl_init()
2039 atomic_set_release(&ptl->pending.count, 0); in ssh_ptl_init()