Lines Matching refs:txb
239 struct rxrpc_txbuf *txb,
242 rxrpc_seq_t seq = txb->seq;
243 bool last = test_bit(RXRPC_TXBUF_LAST, &txb->flags), poke;
247 ASSERTCMP(txb->seq, ==, call->tx_prepared + 1);
252 txb->last_sent = ktime_get_real();
262 list_add_tail(&txb->call_link, &call->tx_sendmsg);
283 struct rxrpc_txbuf *txb;
332 txb = call->tx_pending;
334 if (txb)
335 rxrpc_see_txbuf(txb, rxrpc_txbuf_see_send_more);
338 if (!txb) {
360 txb = rxrpc_alloc_txbuf(call, RXRPC_PACKET_TYPE_DATA,
362 if (!txb)
365 txb->offset = offset;
366 txb->space -= offset;
367 txb->space = min_t(size_t, chunk, txb->space);
374 size_t copy = min_t(size_t, txb->space, msg_data_left(msg));
377 if (!copy_from_iter_full(txb->data + txb->offset, copy,
381 txb->space -= copy;
382 txb->len += copy;
383 txb->offset += copy;
395 if (!txb->space ||
398 txb->wire.flags |= RXRPC_LAST_PACKET;
399 __set_bit(RXRPC_TXBUF_LAST, &txb->flags);
403 txb->wire.flags |= RXRPC_MORE_PACKETS;
405 ret = call->security->secure_packet(call, txb);
409 rxrpc_queue_packet(rx, call, txb, notify_end_tx);
410 txb = NULL;
420 call->tx_pending = txb;
425 rxrpc_put_txbuf(txb, rxrpc_txbuf_put_send_aborted);