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