Lines Matching defs:conn
81 static size_t rxrpc_fill_out_ack(struct rxrpc_connection *conn,
123 mtu = conn->peer->if_mtu;
124 mtu -= conn->peer->hdrsize;
189 struct rxrpc_connection *conn;
200 conn = call->conn;
211 n = rxrpc_fill_out_ack(conn, call, txb, &rwind);
219 serial = rxrpc_get_next_serial(conn);
235 ret = do_udp_sendmsg(conn->local->socket, &msg, len);
262 struct rxrpc_connection *conn;
282 conn = call->conn;
290 pkt.whdr.epoch = htonl(conn->proto.epoch);
295 pkt.whdr.flags = conn->out_clientflag;
305 serial = rxrpc_get_next_serial(conn);
309 ret = do_udp_sendmsg(conn->local->socket, &msg, sizeof(pkt));
310 conn->peer->last_tx_at = ktime_get_seconds();
327 struct rxrpc_connection *conn = call->conn;
337 serial = rxrpc_get_next_serial(conn);
340 if (test_bit(RXRPC_CONN_PROBING_FOR_UPGRADE, &conn->flags) &&
427 ret = do_udp_sendmsg(conn->local->socket, &msg, len);
428 conn->peer->last_tx_at = ktime_get_seconds();
494 switch (conn->local->srx.transport.family) {
497 rxrpc_local_dont_fragment(conn->local, false);
499 ret = do_udp_sendmsg(conn->local->socket, &msg, len);
500 conn->peer->last_tx_at = ktime_get_seconds();
502 rxrpc_local_dont_fragment(conn->local, true);
525 void rxrpc_send_conn_abort(struct rxrpc_connection *conn)
535 msg.msg_name = &conn->peer->srx.transport;
536 msg.msg_namelen = conn->peer->srx.transport_len;
541 whdr.epoch = htonl(conn->proto.epoch);
542 whdr.cid = htonl(conn->proto.cid);
546 whdr.flags = conn->out_clientflag;
548 whdr.securityIndex = conn->security_ix;
550 whdr.serviceId = htons(conn->service_id);
552 word = htonl(conn->abort_code);
561 serial = rxrpc_get_next_serial(conn);
565 ret = do_udp_sendmsg(conn->local->socket, &msg, len);
567 trace_rxrpc_tx_fail(conn->debug_id, serial, ret,
573 trace_rxrpc_tx_packet(conn->debug_id, &whdr, rxrpc_tx_point_conn_abort);
575 conn->peer->last_tx_at = ktime_get_seconds();