Lines Matching refs:port
132 struct nvmet_tcp_port *port;
396 if (len > cmd->req.port->inline_data_size)
562 len && len <= cmd->req.port->inline_data_size &&
936 data_len > cmd->req.port->inline_data_size) {
1362 c->req.port = queue->port->nport;
1635 static int nvmet_tcp_alloc_queue(struct nvmet_tcp_port *port,
1648 queue->port = port;
1697 struct nvmet_tcp_port *port =
1703 ret = kernel_accept(port->sock, &newsock, O_NONBLOCK);
1709 ret = nvmet_tcp_alloc_queue(port, newsock);
1719 struct nvmet_tcp_port *port;
1724 port = sk->sk_user_data;
1725 if (!port)
1729 queue_work(nvmet_wq, &port->accept_work);
1736 struct nvmet_tcp_port *port;
1740 port = kzalloc(sizeof(*port), GFP_KERNEL);
1741 if (!port)
1759 nport->disc_addr.trsvcid, &port->addr);
1761 pr_err("malformed ip/port passed: %s:%s\n",
1766 port->nport = nport;
1767 INIT_WORK(&port->accept_work, nvmet_tcp_accept_work);
1768 if (port->nport->inline_data_size < 0)
1769 port->nport->inline_data_size = NVMET_TCP_DEF_INLINE_DATA_SIZE;
1771 ret = sock_create(port->addr.ss_family, SOCK_STREAM,
1772 IPPROTO_TCP, &port->sock);
1778 port->sock->sk->sk_user_data = port;
1779 port->data_ready = port->sock->sk->sk_data_ready;
1780 port->sock->sk->sk_data_ready = nvmet_tcp_listen_data_ready;
1781 sock_set_reuseaddr(port->sock->sk);
1782 tcp_sock_set_nodelay(port->sock->sk);
1784 sock_set_priority(port->sock->sk, so_priority);
1786 ret = kernel_bind(port->sock, (struct sockaddr *)&port->addr,
1787 sizeof(port->addr));
1789 pr_err("failed to bind port socket %d\n", ret);
1793 ret = kernel_listen(port->sock, 128);
1795 pr_err("failed to listen %d on port sock\n", ret);
1799 nport->priv = port;
1800 pr_info("enabling port %d (%pISpc)\n",
1801 le16_to_cpu(nport->disc_addr.portid), &port->addr);
1806 sock_release(port->sock);
1808 kfree(port);
1812 static void nvmet_tcp_destroy_port_queues(struct nvmet_tcp_port *port)
1818 if (queue->port == port)
1825 struct nvmet_tcp_port *port = nport->priv;
1827 write_lock_bh(&port->sock->sk->sk_callback_lock);
1828 port->sock->sk->sk_data_ready = port->data_ready;
1829 port->sock->sk->sk_user_data = NULL;
1830 write_unlock_bh(&port->sock->sk->sk_callback_lock);
1831 cancel_work_sync(&port->accept_work);
1836 nvmet_tcp_destroy_port_queues(port);
1838 sock_release(port->sock);
1839 kfree(port);
1872 struct nvmet_tcp_port *port = nport->priv;
1874 if (inet_addr_is_any((struct sockaddr *)&port->addr)) {