Lines Matching defs:call
19 struct rxrpc_txbuf *rxrpc_alloc_txbuf(struct rxrpc_call *call, u8 packet_type,
29 txb->call_debug_id = call->debug_id;
36 txb->seq = call->tx_prepared + 1;
37 txb->wire.epoch = htonl(call->conn->proto.epoch);
38 txb->wire.cid = htonl(call->cid);
39 txb->wire.callNumber = htonl(call->call_id);
42 txb->wire.flags = call->conn->out_clientflag;
44 txb->wire.securityIndex = call->security_ix;
46 txb->wire.serviceId = htons(call->dest_srx.srx_service);
105 void rxrpc_shrink_call_tx_buffer(struct rxrpc_call *call)
108 rxrpc_seq_t hard_ack = smp_load_acquire(&call->acks_hard_ack);
111 _enter("%x/%x/%x", call->tx_bottom, call->acks_hard_ack, call->tx_top);
113 while ((txb = list_first_entry_or_null(&call->tx_buffer,
115 hard_ack = smp_load_acquire(&call->acks_hard_ack);
119 if (txb->seq != call->tx_bottom + 1)
121 ASSERTCMP(txb->seq, ==, call->tx_bottom + 1);
122 smp_store_release(&call->tx_bottom, call->tx_bottom + 1);
125 trace_rxrpc_txqueue(call, rxrpc_txqueue_dequeue);
128 if (after(call->acks_hard_ack, call->tx_bottom + 128))
133 wake_up(&call->waitq);