| 742 | |
| 743 | public: |
| 744 | TIBClientServer(TPtrArg<TIBPort> port) |
| 745 | : Port(port) |
| 746 | , MemPool(GetIBMemPool()) |
| 747 | , CQ(new TComplectionQueue(port->GetCtx(), MAX_CQ_EVENTS)) |
| 748 | , BP(port->GetCtx(), MAX_SRQ_WORK_REQUESTS) |
| 749 | , WelcomeQP(new TUDQueuePair(port, CQ, BP.GetSRQ(), WELCOME_QP_SEND_SIZE)) |
| 750 | , WelcomeQPN(WelcomeQP->GetQPN()) |
| 751 | , MsgCounter(1) |
| 752 | { |
| 753 | CopyResults = new TIBMemPool::TCopyResultStorage; |
| 754 | CreateGuid(&ConnectInfo.SocketId); |
| 755 | ibv_gid addr; |
| 756 | port->GetGID(&addr); |
| 757 | ConnectInfo.Interface = addr.global.interface_id; |
| 758 | ConnectInfo.Subnet = addr.global.subnet_prefix; |
| 759 | //printf("connect addr subnet %lx, iface %lx\n", addr.global.subnet_prefix, addr.global.interface_id); |
| 760 | ConnectInfo.LID = port->GetLID(); |
| 761 | ConnectInfo.QPN = WelcomeQPN; |
| 762 | |
| 763 | WelcomeQP->Init(WELCOME_QKEY); |
| 764 | |
| 765 | NHPTimer::GetTime(&LastCheckTime); |
| 766 | } |
| 767 | }; |
| 768 | |
| 769 | IIBClientServer* CreateIBClientServer() { |
nothing calls this directly
no test coverage detected