Commit 0bcaf050 authored by Ziye Yang's avatar Ziye Yang Committed by Tomasz Zawadzki
Browse files

nvmf/tcp: Remove the await_req list. 



In my thought, this await_req will not have performance improvement,
and it makes the code more complicated, so remove it.

Signed-off-by: default avatarZiye Yang <ziye.yang@intel.com>
Change-Id: I97d86448fc273098d001a08d914ad45ddac07e16
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/5149


Community-CI: Broadcom CI
Community-CI: Mellanox Build Bot
Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarShuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: default avatarChangpeng Liu <changpeng.liu@intel.com>
Reviewed-by: default avatarAleksey Marchuk <alexeymar@mellanox.com>
parent 23a19169

lib/nvmf/tcp.c

+2 −22
Original line number Diff line number Diff line
@@ -268,7 +268,6 @@ struct spdk_nvmf_tcp_poll_group { 
	struct spdk_sock_group			*sock_group;



	TAILQ_HEAD(, spdk_nvmf_tcp_qpair)	qpairs;

	TAILQ_HEAD(, spdk_nvmf_tcp_qpair)	await_req;



	struct spdk_nvmf_tcp_control_msg_list	*control_msg_list;

};
@@ -1087,7 +1086,6 @@ nvmf_tcp_poll_group_create(struct spdk_nvmf_transport *transport) 
	}



	TAILQ_INIT(&tgroup->qpairs);

	TAILQ_INIT(&tgroup->await_req);



	ttransport = SPDK_CONTAINEROF(transport, struct spdk_nvmf_tcp_transport, transport);
@@ -1148,12 +1146,6 @@ nvmf_tcp_qpair_set_recv_state(struct spdk_nvmf_tcp_qpair *tqpair, 
		return;

	}



	if (tqpair->recv_state == NVME_TCP_PDU_RECV_STATE_AWAIT_REQ) {

		/* When leaving the await req state, move the qpair to the main list */

		TAILQ_REMOVE(&tqpair->group->await_req, tqpair, link);

		TAILQ_INSERT_TAIL(&tqpair->group->qpairs, tqpair, link);

	}



	SPDK_DEBUGLOG(nvmf_tcp, "tqpair(%p) recv state=%d\n", tqpair, state);

	tqpair->recv_state = state;
@@ -1161,10 +1153,7 @@ nvmf_tcp_qpair_set_recv_state(struct spdk_nvmf_tcp_qpair *tqpair, 
	case NVME_TCP_PDU_RECV_STATE_AWAIT_PDU_CH:

	case NVME_TCP_PDU_RECV_STATE_AWAIT_PDU_PSH:

	case NVME_TCP_PDU_RECV_STATE_AWAIT_PDU_PAYLOAD:

		break;

	case NVME_TCP_PDU_RECV_STATE_AWAIT_REQ:

		TAILQ_REMOVE(&tqpair->group->qpairs, tqpair, link);

		TAILQ_INSERT_TAIL(&tqpair->group->await_req, tqpair, link);

		break;

	case NVME_TCP_PDU_RECV_STATE_ERROR:

	case NVME_TCP_PDU_RECV_STATE_AWAIT_PDU_READY:
@@ -2534,11 +2523,7 @@ nvmf_tcp_poll_group_remove(struct spdk_nvmf_transport_poll_group *group, 
	assert(tqpair->group == tgroup);



	SPDK_DEBUGLOG(nvmf_tcp, "remove tqpair=%p from the tgroup=%p\n", tqpair, tgroup);

	if (tqpair->recv_state == NVME_TCP_PDU_RECV_STATE_AWAIT_REQ) {

		TAILQ_REMOVE(&tgroup->await_req, tqpair, link);

	} else {

	TAILQ_REMOVE(&tgroup->qpairs, tqpair, link);

	}



	rc = spdk_sock_group_remove_sock(tgroup->sock_group, tqpair->sock);

	if (rc != 0) {
@@ -2588,13 +2573,12 @@ nvmf_tcp_poll_group_poll(struct spdk_nvmf_transport_poll_group *group) 
	int rc;

	struct spdk_nvmf_request *req, *req_tmp;

	struct spdk_nvmf_tcp_req *tcp_req;

	struct spdk_nvmf_tcp_qpair *tqpair, *tqpair_tmp;

	struct spdk_nvmf_tcp_transport *ttransport = SPDK_CONTAINEROF(group->transport,

			struct spdk_nvmf_tcp_transport, transport);



	tgroup = SPDK_CONTAINEROF(group, struct spdk_nvmf_tcp_poll_group, group);



	if (spdk_unlikely(TAILQ_EMPTY(&tgroup->qpairs) && TAILQ_EMPTY(&tgroup->await_req))) {

	if (spdk_unlikely(TAILQ_EMPTY(&tgroup->qpairs))) {

		return 0;

	}
@@ -2610,10 +2594,6 @@ nvmf_tcp_poll_group_poll(struct spdk_nvmf_transport_poll_group *group) 
		SPDK_ERRLOG("Failed to poll sock_group=%p\n", tgroup->sock_group);

	}



	TAILQ_FOREACH_SAFE(tqpair, &tgroup->await_req, link, tqpair_tmp) {

		nvmf_tcp_sock_process(tqpair);

	}



	return rc;

}