Lines Matching defs:conn
69 static size_t rxrpc_fill_out_ack(struct rxrpc_connection *conn,
119 mtu = conn->params.peer->if_mtu;
120 mtu -= conn->params.peer->hdrsize;
182 struct rxrpc_connection *conn;
199 conn = call->conn;
207 pkt->whdr.epoch = htonl(conn->proto.epoch);
212 pkt->whdr.flags = RXRPC_SLOW_START_OK | conn->out_clientflag;
230 n = rxrpc_fill_out_ack(conn, call, pkt, &hard_ack, &top, reason);
244 serial = atomic_inc_return(&conn->serial);
256 ret = kernel_sendmsg(conn->params.local->socket, &msg, iov, 2, len);
257 conn->params.peer->last_tx_at = ktime_get_seconds();
288 struct rxrpc_connection *conn;
308 conn = call->conn;
316 pkt.whdr.epoch = htonl(conn->proto.epoch);
321 pkt.whdr.flags = conn->out_clientflag;
331 serial = atomic_inc_return(&conn->serial);
334 ret = kernel_sendmsg(conn->params.local->socket,
336 conn->params.peer->last_tx_at = ktime_get_seconds();
353 struct rxrpc_connection *conn = call->conn;
371 serial = atomic_inc_return(&conn->serial);
373 whdr.epoch = htonl(conn->proto.epoch);
385 if (test_bit(RXRPC_CONN_PROBING_FOR_UPGRADE, &conn->flags) &&
437 down_read(&conn->params.local->defrag_sem);
451 ret = kernel_sendmsg(conn->params.local->socket, &msg, iov, 2, len);
452 conn->params.peer->last_tx_at = ktime_get_seconds();
454 up_read(&conn->params.local->defrag_sem);
513 down_write(&conn->params.local->defrag_sem);
521 switch (conn->params.local->srx.transport.family) {
524 ip_sock_set_mtu_discover(conn->params.local->socket->sk,
526 ret = kernel_sendmsg(conn->params.local->socket, &msg,
528 conn->params.peer->last_tx_at = ktime_get_seconds();
530 ip_sock_set_mtu_discover(conn->params.local->socket->sk,
548 up_write(&conn->params.local->defrag_sem);