Lines Matching full:txb
242 struct rxrpc_txbuf *txb, in rxrpc_queue_packet() argument
246 rxrpc_seq_t seq = txb->seq; in rxrpc_queue_packet()
247 bool poke, last = txb->flags & RXRPC_LAST_PACKET; in rxrpc_queue_packet()
251 ASSERTCMP(txb->seq, ==, call->send_top + 1); in rxrpc_queue_packet()
265 sq->bufs[ix] = txb; in rxrpc_queue_packet()
266 /* Order send_top after the queue->next pointer and txb content. */ in rxrpc_queue_packet()
326 struct rxrpc_txbuf *txb; in rxrpc_send_data() local
356 txb = call->tx_pending; in rxrpc_send_data()
358 if (txb) in rxrpc_send_data()
359 rxrpc_see_txbuf(txb, rxrpc_txbuf_see_send_more); in rxrpc_send_data()
388 if (!txb) { in rxrpc_send_data()
408 txb = call->conn->security->alloc_txbuf(call, remain, sk->sk_allocation); in rxrpc_send_data()
409 if (!txb) { in rxrpc_send_data()
419 size_t copy = umin(txb->space, msg_data_left(msg)); in rxrpc_send_data()
422 if (!copy_from_iter_full(txb->data + txb->offset, in rxrpc_send_data()
426 txb->space -= copy; in rxrpc_send_data()
427 txb->len += copy; in rxrpc_send_data()
428 txb->offset += copy; in rxrpc_send_data()
440 if (!txb->space || in rxrpc_send_data()
443 txb->flags |= RXRPC_LAST_PACKET; in rxrpc_send_data()
445 ret = call->security->secure_packet(call, txb); in rxrpc_send_data()
448 rxrpc_queue_packet(rx, call, txb, notify_end_tx); in rxrpc_send_data()
449 txb = NULL; in rxrpc_send_data()
459 call->tx_pending = txb; in rxrpc_send_data()
464 rxrpc_put_txbuf(txb, rxrpc_txbuf_put_send_aborted); in rxrpc_send_data()