Lines Matching defs:tx
1025 ksock_tx_t *tx;
1273 list_for_each_entry_safe(tx, txtmp, &peer->ksnp_tx_queue, tx_list) {
1274 if (conn->ksnc_proto->pro_match_tx(conn, tx, tx->tx_nonblk) == SOCKNAL_MATCH_NO)
1277 list_del (&tx->tx_list);
1278 ksocknal_queue_tx_locked (tx, conn);
1447 ksock_tx_t *tx;
1453 list_for_each_entry(tx, &peer->ksnp_tx_queue,
1455 ksocknal_tx_prep(conn, tx);
1513 ksock_tx_t *tx;
1523 list_for_each_entry_safe(tx, tmp, &peer->ksnp_zc_req_list, tx_zc_list) {
1524 if (tx->tx_conn != conn)
1527 LASSERT (tx->tx_msg.ksm_zc_cookies[0] != 0);
1529 tx->tx_msg.ksm_zc_cookies[0] = 0;
1530 tx->tx_zc_aborted = 1; /* mark it as not-acked */
1531 list_del(&tx->tx_zc_list);
1532 list_add(&tx->tx_zc_list, &zlist);
1538 tx = list_entry(zlist.next, ksock_tx_t, tx_zc_list);
1540 list_del(&tx->tx_zc_list);
1541 ksocknal_tx_decref(tx);
1561 /* a closing conn is always ready to tx */
2239 ksock_tx_t *tx;
2246 tx = list_entry(zlist.next, ksock_tx_t, tx_list);
2247 list_del(&tx->tx_list);
2248 LIBCFS_FREE(tx, tx->tx_desc_size);