Lines Matching defs:conn
173 smc_conn_free(&smc->conn);
254 INIT_DELAYED_WORK(&smc->conn.tx_work, smc_tx_work);
257 spin_lock_init(&smc->conn.send_lock);
395 struct smc_link *link = smc->conn.lnk;
425 if (smcr_link_reg_rmb(link, smc->conn.rmb_desc))
429 smc->conn.rmb_desc->is_conf_rkey = true;
461 smc->conn.peer_rmbe_idx = clc->r0.rmbe_idx;
462 smc->conn.local_tx_ctrl.token = ntohl(clc->r0.rmbe_alert_token);
463 smc->conn.peer_rmbe_size = bufsize;
464 atomic_set(&smc->conn.peer_rmbe_space, smc->conn.peer_rmbe_size);
465 smc->conn.tx_off = bufsize * (smc->conn.peer_rmbe_idx - 1);
483 smc->conn.peer_rmbe_idx = clc->d0.dmbe_idx;
484 smc->conn.peer_token = clc->d0.token;
486 smc->conn.peer_rmbe_size = bufsize - sizeof(struct smcd_cdc_msg);
487 atomic_set(&smc->conn.peer_rmbe_space, smc->conn.peer_rmbe_size);
488 smc->conn.tx_off = bufsize * smc->conn.peer_rmbe_idx;
497 memcpy(smc->conn.lgr->negotiated_eid, clc_v2->eid,
499 smc->conn.lgr->peer_os = fce->os_type;
500 smc->conn.lgr->peer_smc_release = fce->release;
502 memcpy(smc->conn.lgr->peer_hostname, fce->hostname,
510 if (smc->conn.lgr->is_smcd)
589 smc_lgr_cleanup_early(&smc->conn);
591 smc_conn_free(&smc->conn);
770 link = smc->conn.lnk;
775 struct smc_link *l = &smc->conn.lgr->lnk[i];
790 smc->conn.lnk = link;
802 if (smc_rmb_rtoken_handling(&smc->conn, link, aclc)) {
816 if (smcr_lgr_reg_rmbs(link, smc->conn.rmb_desc)) {
821 smc_rmb_sync_sg_for_device(&smc->conn);
1269 struct smc_link *link = smc->conn.lnk;
1273 if (smcr_link_reg_rmb(link, smc->conn.rmb_desc))
1298 smc->conn.rmb_desc->is_conf_rkey = true;
1356 smc_lgr_cleanup_early(&new_smc->conn);
1358 smc_conn_free(&new_smc->conn);
1463 smc_lgr_cleanup_early(&new_smc->conn);
1465 smc_conn_free(&new_smc->conn);
1599 struct smc_connection *conn = &new_smc->conn;
1602 if (smcr_lgr_reg_rmbs(conn->lnk, conn->rmb_desc))
1605 smc_rmb_sync_sg_for_device(&new_smc->conn);
1676 struct smc_link *link = new_smc->conn.lnk;
1682 if (smc_rmb_rtoken_handling(&new_smc->conn, link, cclc))
1965 } else if (!atomic_read(&smc_sk(nsk)->conn.bytes_to_rcv)) {
2107 atomic_read(&smc->conn.sndbuf_space)) ||
2114 if (atomic_read(&smc->conn.bytes_to_rcv))
2120 if (smc->conn.urg_state == SMC_URG_VALID)
2238 mod_delayed_work(smc->conn.lgr->tx_wq,
2239 &smc->conn.tx_work, 0);
2247 mod_delayed_work(smc->conn.lgr->tx_wq,
2248 &smc->conn.tx_work, 0);
2280 struct smc_connection *conn;
2285 conn = &smc->conn;
2306 answ = atomic_read(&smc->conn.bytes_to_rcv);
2318 answ = smc->conn.sndbuf_desc->len -
2319 atomic_read(&smc->conn.sndbuf_space);
2331 answ = smc_tx_prepared_sends(&smc->conn);
2342 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn);
2343 smc_curs_copy(&urg, &conn->urg_curs, conn);
2344 answ = smc_curs_diff(conn->rmb_desc->len,
2382 * to splice in conn->splice_pending, and press 'go'. Delays consumer cursor