| 637 | } |
| 638 | |
| 639 | void RdmaChannel::SetRemoteAddress(const RdmaAddress& ra, bool override) { |
| 640 | mutex_lock lock{mu_}; |
| 641 | if ((override) || (!remote_set_)) { |
| 642 | remote_.lid = ra.lid; |
| 643 | remote_.qpn = ra.qpn; |
| 644 | remote_.psn = ra.psn; |
| 645 | remote_.snp = ra.snp; |
| 646 | remote_.iid = ra.iid; |
| 647 | remote_set_ = true; |
| 648 | } else { |
| 649 | CHECK(remote_.lid == ra.lid); |
| 650 | CHECK(remote_.qpn == ra.qpn); |
| 651 | CHECK(remote_.psn == ra.psn); |
| 652 | CHECK(remote_.snp == ra.snp); |
| 653 | CHECK(remote_.iid == ra.iid); |
| 654 | } |
| 655 | } |
| 656 | |
| 657 | // Adding tokens to the completion queue |
| 658 | // Tokens are needed to process future messages. |
no outgoing calls
no test coverage detected