Lines Matching refs:txb
239 struct rxrpc_txbuf *txb, in rxrpc_queue_packet() argument
242 rxrpc_seq_t seq = txb->seq; in rxrpc_queue_packet()
243 bool poke, last = txb->flags & RXRPC_LAST_PACKET; in rxrpc_queue_packet()
247 ASSERTCMP(txb->seq, ==, call->tx_prepared + 1); in rxrpc_queue_packet()
252 txb->last_sent = ktime_get_real(); in rxrpc_queue_packet()
262 list_add_tail(&txb->call_link, &call->tx_sendmsg); in rxrpc_queue_packet()
283 struct rxrpc_txbuf *txb; in rxrpc_send_data() local
306 txb = call->tx_pending; in rxrpc_send_data()
308 if (txb) in rxrpc_send_data()
309 rxrpc_see_txbuf(txb, rxrpc_txbuf_see_send_more); in rxrpc_send_data()
338 if (!txb) { in rxrpc_send_data()
351 txb = call->conn->security->alloc_txbuf(call, remain, sk->sk_allocation); in rxrpc_send_data()
352 if (!txb) { in rxrpc_send_data()
362 size_t copy = min_t(size_t, txb->space, msg_data_left(msg)); in rxrpc_send_data()
365 if (!copy_from_iter_full(txb->kvec[0].iov_base + txb->offset, in rxrpc_send_data()
369 txb->space -= copy; in rxrpc_send_data()
370 txb->len += copy; in rxrpc_send_data()
371 txb->offset += copy; in rxrpc_send_data()
383 if (!txb->space || in rxrpc_send_data()
386 txb->flags |= RXRPC_LAST_PACKET; in rxrpc_send_data()
389 txb->flags |= RXRPC_MORE_PACKETS; in rxrpc_send_data()
391 ret = call->security->secure_packet(call, txb); in rxrpc_send_data()
395 txb->kvec[0].iov_len += txb->len; in rxrpc_send_data()
396 txb->len = txb->kvec[0].iov_len; in rxrpc_send_data()
397 rxrpc_queue_packet(rx, call, txb, notify_end_tx); in rxrpc_send_data()
398 txb = NULL; in rxrpc_send_data()
408 call->tx_pending = txb; in rxrpc_send_data()
413 rxrpc_put_txbuf(txb, rxrpc_txbuf_put_send_aborted); in rxrpc_send_data()