Lines Matching refs:peer
221 if_mtu = call->peer->if_mtu - call->peer->hdrsize; in rxrpc_fill_out_ack()
222 if (call->peer->ackr_adv_pmtud) { in rxrpc_fill_out_ack()
223 max_mtu = umax(call->peer->max_data, rxrpc_rx_mtu); in rxrpc_fill_out_ack()
261 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_ack_packet()
262 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_ack_packet()
278 call->peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_ack_packet()
289 call->peer->pmtud_pending = false; in rxrpc_send_ack_packet()
290 call->peer->pmtud_probing = true; in rxrpc_send_ack_packet()
328 size_t probe_mtu = call->peer->pmtud_trial + sizeof(struct rxrpc_wire_header); in rxrpc_send_ACK()
388 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_abort_packet()
389 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_abort_packet()
414 conn->peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_abort_packet()
669 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_data_packet()
670 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_data_packet()
679 len >= sizeof(struct rxrpc_wire_header) + call->peer->max_data) { in rxrpc_send_data_packet()
701 conn->peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_data_packet()
714 conn->peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_data_packet()
744 _leave(" = %d [%u]", ret, call->peer->max_data); in rxrpc_send_data_packet()
760 msg.msg_name = &conn->peer->srx.transport; in rxrpc_send_conn_abort()
761 msg.msg_namelen = conn->peer->srx.transport_len; in rxrpc_send_conn_abort()
800 conn->peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_conn_abort()
876 void rxrpc_send_keepalive(struct rxrpc_peer *peer) in rxrpc_send_keepalive() argument
886 msg.msg_name = &peer->srx.transport; in rxrpc_send_keepalive()
887 msg.msg_namelen = peer->srx.transport_len; in rxrpc_send_keepalive()
892 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()
912 ret = do_udp_sendmsg(peer->local->socket, &msg, len); in rxrpc_send_keepalive()
914 trace_rxrpc_tx_fail(peer->debug_id, 0, ret, in rxrpc_send_keepalive()
917 trace_rxrpc_tx_packet(peer->debug_id, &whdr, in rxrpc_send_keepalive()
920 peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_keepalive()
954 msg.msg_name = &conn->peer->srx.transport; in rxrpc_send_response()
955 msg.msg_namelen = conn->peer->srx.transport_len; in rxrpc_send_response()
976 conn->peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_response()