Lines Matching refs:peer

101 	mtu = conn->params.peer->if_mtu;  in rxrpc_fill_out_ack()
102 mtu -= conn->params.peer->hdrsize; in rxrpc_fill_out_ack()
144 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_ack_packet()
145 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_ack_packet()
206 conn->params.peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_ack_packet()
270 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_abort_packet()
271 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_abort_packet()
296 conn->params.peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_abort_packet()
352 msg.msg_name = &call->peer->srx.transport; in rxrpc_send_data_packet()
353 msg.msg_namelen = call->peer->srx.transport_len; in rxrpc_send_data_packet()
371 (call->peer->rtt_usage < 3 && sp->hdr.seq & 1) || in rxrpc_send_data_packet()
372 ktime_before(ktime_add_ms(call->peer->rtt_last_req, 1000), in rxrpc_send_data_packet()
389 if (iov[1].iov_len >= call->peer->maxdata) in rxrpc_send_data_packet()
405 conn->params.peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_data_packet()
422 call->peer->rtt_last_req = skb->tstamp; in rxrpc_send_data_packet()
424 if (call->peer->rtt_usage > 1) { in rxrpc_send_data_packet()
427 ack_lost_at = nsecs_to_jiffies(2 * call->peer->rtt); in rxrpc_send_data_packet()
452 _leave(" = %d [%u]", ret, call->peer->maxdata); in rxrpc_send_data_packet()
474 conn->params.peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_data_packet()
492 conn->params.peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_data_packet()
594 void rxrpc_send_keepalive(struct rxrpc_peer *peer) in rxrpc_send_keepalive() argument
604 msg.msg_name = &peer->srx.transport; in rxrpc_send_keepalive()
605 msg.msg_namelen = peer->srx.transport_len; in rxrpc_send_keepalive()
610 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()
631 ret = kernel_sendmsg(peer->local->socket, &msg, iov, 2, len); in rxrpc_send_keepalive()
633 trace_rxrpc_tx_fail(peer->debug_id, 0, ret, in rxrpc_send_keepalive()
636 trace_rxrpc_tx_packet(peer->debug_id, &whdr, in rxrpc_send_keepalive()
639 peer->last_tx_at = ktime_get_seconds(); in rxrpc_send_keepalive()