Lines Matching refs:port
96 struct nvmet_tcp_port *port;
360 if (len > cmd->req.port->inline_data_size)
543 len && len <= cmd->req.port->inline_data_size &&
901 data_len > cmd->req.port->inline_data_size) {
1302 c->req.port = queue->port->nport;
1562 static int nvmet_tcp_alloc_queue(struct nvmet_tcp_port *port,
1575 queue->port = port;
1624 struct nvmet_tcp_port *port =
1630 ret = kernel_accept(port->sock, &newsock, O_NONBLOCK);
1636 ret = nvmet_tcp_alloc_queue(port, newsock);
1646 struct nvmet_tcp_port *port;
1649 port = sk->sk_user_data;
1650 if (!port)
1654 schedule_work(&port->accept_work);
1661 struct nvmet_tcp_port *port;
1665 port = kzalloc(sizeof(*port), GFP_KERNEL);
1666 if (!port)
1684 nport->disc_addr.trsvcid, &port->addr);
1686 pr_err("malformed ip/port passed: %s:%s\n",
1691 port->nport = nport;
1692 INIT_WORK(&port->accept_work, nvmet_tcp_accept_work);
1693 if (port->nport->inline_data_size < 0)
1694 port->nport->inline_data_size = NVMET_TCP_DEF_INLINE_DATA_SIZE;
1696 ret = sock_create(port->addr.ss_family, SOCK_STREAM,
1697 IPPROTO_TCP, &port->sock);
1703 port->sock->sk->sk_user_data = port;
1704 port->data_ready = port->sock->sk->sk_data_ready;
1705 port->sock->sk->sk_data_ready = nvmet_tcp_listen_data_ready;
1706 sock_set_reuseaddr(port->sock->sk);
1707 tcp_sock_set_nodelay(port->sock->sk);
1709 sock_set_priority(port->sock->sk, so_priority);
1711 ret = kernel_bind(port->sock, (struct sockaddr *)&port->addr,
1712 sizeof(port->addr));
1714 pr_err("failed to bind port socket %d\n", ret);
1718 ret = kernel_listen(port->sock, 128);
1720 pr_err("failed to listen %d on port sock\n", ret);
1724 nport->priv = port;
1725 pr_info("enabling port %d (%pISpc)\n",
1726 le16_to_cpu(nport->disc_addr.portid), &port->addr);
1731 sock_release(port->sock);
1733 kfree(port);
1737 static void nvmet_tcp_destroy_port_queues(struct nvmet_tcp_port *port)
1743 if (queue->port == port)
1750 struct nvmet_tcp_port *port = nport->priv;
1752 write_lock_bh(&port->sock->sk->sk_callback_lock);
1753 port->sock->sk->sk_data_ready = port->data_ready;
1754 port->sock->sk->sk_user_data = NULL;
1755 write_unlock_bh(&port->sock->sk->sk_callback_lock);
1756 cancel_work_sync(&port->accept_work);
1761 nvmet_tcp_destroy_port_queues(port);
1763 sock_release(port->sock);
1764 kfree(port);
1799 struct nvmet_tcp_port *port = nport->priv;
1801 if (inet_addr_is_any((struct sockaddr *)&port->addr)) {