Lines Matching defs:port
1278 struct spdk_nvmf_rdma_port *port;
1307 port = event->listen_id->context;
1309 event->listen_id, event->listen_id->verbs, port);
1326 port->device->attr.max_qp_wr, port->device->attr.max_qp_rd_atom);
1327 max_queue_depth = spdk_min(max_queue_depth, port->device->attr.max_qp_wr);
1328 max_read_depth = spdk_min(max_read_depth, port->device->attr.max_qp_init_rd_atom);
1375 rqpair->device = port->device;
2903 struct spdk_nvmf_rdma_port *port, *port_tmp;
2908 TAILQ_FOREACH_SAFE(port, &rtransport->retry_ports, link, port_tmp) {
2909 TAILQ_REMOVE(&rtransport->retry_ports, port, link);
2910 free(port);
2913 TAILQ_FOREACH_SAFE(port, &rtransport->ports, link, port_tmp) {
2914 TAILQ_REMOVE(&rtransport->ports, port, link);
2915 rdma_destroy_id(port->id);
2916 free(port);
2960 struct spdk_nvmf_rdma_port *port, *tmp_port;
2976 port = calloc(1, sizeof(*port));
2977 if (!port) {
2982 port->trid = trid;
2993 free(port);
3005 * 0: this results in ephemeral port which we don't want
3006 * > 65535: port too high
3011 free(port);
3018 free(port);
3022 rc = rdma_create_id(rtransport->event_channel, &port->id, port, RDMA_PS_TCP);
3026 free(port);
3030 rc = rdma_bind_addr(port->id, res->ai_addr);
3043 rdma_destroy_id(port->id);
3044 free(port);
3048 if (!port->id->verbs) {
3050 rdma_destroy_id(port->id);
3051 free(port);
3055 rc = rdma_listen(port->id, rtransport->rdma_opts.acceptor_backlog);
3058 rdma_destroy_id(port->id);
3059 free(port);
3064 if (device->context == port->id->verbs && device->is_ready) {
3065 port->device = device;
3069 if (!port->device) {
3071 port->id->verbs);
3072 rdma_destroy_id(port->id);
3073 free(port);
3078 SPDK_NOTICELOG("*** NVMe/RDMA Target Listening on %s port %s ***\n",
3081 TAILQ_INSERT_TAIL(&rtransport->ports, port, link);
3090 struct spdk_nvmf_rdma_port *port, *tmp;
3095 TAILQ_FOREACH_SAFE(port, &rtransport->retry_ports, link, tmp) {
3096 if (spdk_nvme_transport_id_compare(port->trid, trid) == 0) {
3097 TAILQ_REMOVE(&rtransport->retry_ports, port, link);
3098 free(port);
3103 TAILQ_FOREACH_SAFE(port, &rtransport->ports, link, tmp) {
3104 if (spdk_nvme_transport_id_compare(port->trid, trid) == 0) {
3106 port->trid->traddr, port->trid->trsvcid, need_retry);
3107 TAILQ_REMOVE(&rtransport->ports, port, link);
3108 rdma_destroy_id(port->id);
3109 port->id = NULL;
3110 port->device = NULL;
3112 TAILQ_INSERT_TAIL(&rtransport->retry_ports, port, link);
3114 free(port);
3349 struct spdk_nvmf_rdma_port *port, *tmp_port;
3359 TAILQ_FOREACH_SAFE(port, &rtransport->retry_ports, link, tmp_port) {
3360 rc = nvmf_rdma_listen(&rtransport->transport, port->trid, NULL);
3362 TAILQ_REMOVE(&rtransport->retry_ports, port, link);
3365 SPDK_ERRLOG("Found new IB device but port %s:%s is still failed(%d) to listen.\n",
3366 port->trid->traddr, port->trid->trsvcid, rc);
3368 TAILQ_INSERT_TAIL(&rtransport->retry_ports, port, link);
3371 SPDK_NOTICELOG("Port %s:%s come back\n", port->trid->traddr, port->trid->trsvcid);
3372 free(port);
3564 struct spdk_nvmf_rdma_port *port)
3573 if (rqpair->listen_id == port->id) {
3586 struct spdk_nvmf_rdma_port *port;
3591 TAILQ_FOREACH(port, &rtransport->ports, link) {
3592 if (port->id == event->id) {
3593 SPDK_ERRLOG("ADDR_CHANGE: IP %s:%s migrated\n", port->trid->traddr, port->trid->trsvcid);
3596 trid = port->trid;
3602 nvmf_rdma_disconnect_qpairs_on_port(rtransport, port);
3615 struct spdk_nvmf_rdma_port *port, *port_tmp;
3631 TAILQ_FOREACH_SAFE(port, &rtransport->ports, link, port_tmp) {
3632 if (port->device == device) {
3634 port->trid->traddr,
3635 port->trid->trsvcid,
3636 ibv_get_device_name(port->device->context->device));
3642 nvmf_rdma_stop_listen_ex(&rtransport->transport, port->trid, true);
3651 struct spdk_nvmf_rdma_port *port, *tmp_port;
3654 port = event->id->context;
3661 * we are handling a port event here.
3664 if (port == tmp_port && port->device && !port->device->need_destroy) {
3665 port->device->need_destroy = true;
3666 nvmf_rdma_handle_device_removal(rtransport, port->device);
4945 uint16_t port;
4962 port = ntohs(rdma_get_dst_port(id));
4964 port = ntohs(rdma_get_src_port(id));
4966 snprintf(trid->trsvcid, sizeof(trid->trsvcid), "%u", port);
4975 port = ntohs(rdma_get_dst_port(id));
4977 port = ntohs(rdma_get_src_port(id));
4979 snprintf(trid->trsvcid, sizeof(trid->trsvcid), "%u", port);