net/smc/af_smc.c

214 	if (smc->conn.tx_in_release_sock) {
215 		smc_tx_pending(&smc->conn);
216 		smc->conn.tx_in_release_sock = false;
304 			smc_conn_free(&smc->conn);
385 	INIT_DELAYED_WORK(&smc->conn.tx_work, smc_tx_work);
388 	spin_lock_init(&smc->conn.send_lock);
596 	struct smc_link *link = smc->conn.lnk;
627 	if (smc->conn.sndbuf_desc->is_vm) {
628 		if (smcr_link_reg_buf(link, smc->conn.sndbuf_desc))
633 	if (smcr_link_reg_buf(link, smc->conn.rmb_desc))
637 	smc->conn.rmb_desc->is_conf_rkey = true;
686 	if (smc->conn.lgr->is_smcd) {
687 		memcpy(smc->conn.lgr->negotiated_eid, clc->d1.eid,
691 		memcpy(smc->conn.lgr->negotiated_eid, clc->r1.eid,
696 	smc->conn.lgr->peer_os = fce->os_type;
697 	smc->conn.lgr->peer_smc_release = fce->release;
699 		memcpy(smc->conn.lgr->peer_hostname, fce->hostname,
708 	smc->conn.peer_rmbe_idx = clc->r0.rmbe_idx;
709 	smc->conn.local_tx_ctrl.token = ntohl(clc->r0.rmbe_alert_token);
710 	smc->conn.peer_rmbe_size = bufsize;
711 	atomic_set(&smc->conn.peer_rmbe_space, smc->conn.peer_rmbe_size);
712 	smc->conn.tx_off = bufsize * (smc->conn.peer_rmbe_idx - 1);
720 	smc->conn.peer_rmbe_idx = clc->d0.dmbe_idx;
721 	smc->conn.peer_token = ntohll(clc->d0.token);
723 	smc->conn.peer_rmbe_size = bufsize - sizeof(struct smcd_cdc_msg);
724 	atomic_set(&smc->conn.peer_rmbe_space, smc->conn.peer_rmbe_size);
725 	smc->conn.tx_off = bufsize * smc->conn.peer_rmbe_idx;
731 	if (smc->conn.lgr->is_smcd)
986 	struct smc_connection *conn = &smc->conn;
987 	struct smc_link_group *lgr = conn->lgr;
990 	if (smc_conn_lgr_valid(conn))
993 	smc_conn_free(conn);
1273 		link = smc->conn.lnk;
1278 			struct smc_link *l = &smc->conn.lgr->lnk[i];
1294 		smc_switch_link_and_count(&smc->conn, link);
1306 	if (smc_rmb_rtoken_handling(&smc->conn, link, aclc)) {
1321 		if (smc->conn.sndbuf_desc->is_vm) {
1322 			if (smcr_lgr_reg_sndbufs(link, smc->conn.sndbuf_desc)) {
1327 		if (smcr_lgr_reg_rmbs(link, smc->conn.rmb_desc)) {
1440 	if (smc_ism_support_dmb_nocopy(smc->conn.lgr->smcd)) {
1862 	struct smc_link *link = smc->conn.lnk;
1867 	if (smc->conn.sndbuf_desc->is_vm) {
1868 		if (smcr_link_reg_buf(link, smc->conn.sndbuf_desc))
1873 	if (smcr_link_reg_buf(link, smc->conn.rmb_desc))
1898 	smc->conn.rmb_desc->is_conf_rkey = true;
2264 	struct smc_connection *conn = &new_smc->conn;
2268 		if (conn->sndbuf_desc->is_vm) {
2269 			if (smcr_lgr_reg_sndbufs(conn->lnk,
2270 						 conn->sndbuf_desc))
2273 		if (smcr_lgr_reg_rmbs(conn->lnk, conn->rmb_desc))
2408 	struct smc_link *link = new_smc->conn.lnk;
2414 	if (smc_rmb_rtoken_handling(&new_smc->conn, link, cclc))
2553 	    smc_ism_support_dmb_nocopy(new_smc->conn.lgr->smcd)) {
2749 		} else if (!atomic_read(&smc_sk(nsk)->conn.bytes_to_rcv)) {
2895 			     atomic_read(&smc->conn.sndbuf_space)) ||
2902 			if (atomic_read(&smc->conn.bytes_to_rcv))
2908 			if (smc->conn.urg_state == SMC_URG_VALID)
3115 				smc_tx_pending(&smc->conn);
3116 				cancel_delayed_work(&smc->conn.tx_work);
3126 				smc_tx_pending(&smc->conn);
3127 				cancel_delayed_work(&smc->conn.tx_work);
3173 	struct smc_connection *conn;
3178 	conn = &smc->conn;
3199 			answ = atomic_read(&smc->conn.bytes_to_rcv);
3211 			answ = smc->conn.sndbuf_desc->len -
3212 					atomic_read(&smc->conn.sndbuf_space);
3224 			answ = smc_tx_prepared_sends(&smc->conn);
3235 			smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn);
3236 			smc_curs_copy(&urg, &conn->urg_curs, conn);
3237 			answ = smc_curs_diff(conn->rmb_desc->len,
3251  * to splice in conn->splice_pending, and press 'go'. Delays consumer cursor