Lines Matching defs:pg

116 iscsi_poll_group_add_conn(struct spdk_iscsi_poll_group *pg, struct spdk_iscsi_conn *conn)
120 	rc = spdk_sock_group_add_sock(pg->sock_group, conn->sock, iscsi_conn_sock_cb, conn);
127 	STAILQ_INSERT_TAIL(&pg->connections, conn, pg_link);
131 iscsi_poll_group_remove_conn(struct spdk_iscsi_poll_group *pg, struct spdk_iscsi_conn *conn)
136 	rc = spdk_sock_group_remove_sock(pg->sock_group, conn->sock);
142 	STAILQ_REMOVE(&pg->connections, conn, spdk_iscsi_conn, pg_link);
163 	iscsi_poll_group_add_conn(conn->pg, conn);
172 	struct spdk_iscsi_poll_group *pg;
253 	pg = TAILQ_FIRST(&g_iscsi.poll_group_head);
254 	if (pg == NULL) {
260 	conn->pg = pg;
262 	spdk_thread_send_msg(spdk_io_channel_get_thread(spdk_io_channel_from_ctx(pg)),
491 	assert(spdk_io_channel_get_thread(spdk_io_channel_from_ctx(conn->pg)) ==
511 	spdk_thread_send_msg(spdk_io_channel_get_thread(spdk_io_channel_from_ctx(conn->pg)),
590 				assert(target->pg != NULL);
591 				target->pg->num_active_targets--;
600 	assert(spdk_io_channel_get_thread(spdk_io_channel_from_ctx(conn->pg)) ==
628 	iscsi_poll_group_remove_conn(conn->pg, conn);
824 		thread = spdk_io_channel_get_thread(spdk_io_channel_from_ctx(conn->pg));
920 			thread = spdk_io_channel_get_thread(spdk_io_channel_from_ctx(xconn->pg));
1532 	iscsi_poll_group_add_conn(conn->pg, conn);
1538 	struct spdk_iscsi_poll_group *pg, *idle_pg = NULL;
1541 	TAILQ_FOREACH(pg, &g_iscsi.poll_group_head, link) {
1542 		if (pg->num_active_targets == 0) {
1543 			return pg;
1544 		} else if (pg->num_active_targets < min_num_targets) {
1545 			min_num_targets = pg->num_active_targets;
1546 			idle_pg = pg;
1556 	struct spdk_iscsi_poll_group	*pg;
1574 		pg = iscsi_get_idlest_poll_group();
1575 		assert(pg != NULL);
1577 		pg->num_active_targets++;
1579 		/* Save the pg in the target node so it can be used for any other connections to this target node. */
1580 		target->pg = pg;
1585 		pg = target->pg;
1591 	assert(spdk_io_channel_get_thread(spdk_io_channel_from_ctx(conn->pg)) ==
1595 	iscsi_poll_group_remove_conn(conn->pg, conn);
1597 	conn->pg = pg;
1600 	spdk_thread_send_msg(spdk_io_channel_get_thread(spdk_io_channel_from_ctx(pg)),