Searched refs:wr_id (Results 1 – 7 of 7) sorted by relevance
95 rdmasniff_post_recv(pcap_t *handle, uint64_t wr_id) in rdmasniff_post_recv() argument102 sg_entry.addr = (uintptr_t) handle->buffer + RDMASNIFF_RECEIVE_SIZE * wr_id; in rdmasniff_post_recv()105 wr.wr_id = wr_id; in rdmasniff_post_recv()147 (unsigned long long) wc.wr_id, in rdmasniff_read()156 pktd = (u_char *) handle->buffer + wc.wr_id * RDMASNIFF_RECEIVE_SIZE; in rdmasniff_read()165 rdmasniff_post_recv(handle, wc.wr_id); in rdmasniff_read()
218 __aligned_u64 wr_id; /* wr id */ member226 __aligned_u64 wr_id; /* wr id */ member279 __aligned_u64 wr_id; member
71 __aligned_u64 wr_id; member150 __aligned_u64 wr_id; member
459 __aligned_u64 wr_id; member792 __aligned_u64 wr_id; member836 __aligned_u64 wr_id; member
453 << static_cast<int>(wc_[i].wr_id) << " " << wc_[i].vendor_err; in Process_CQ()455 RdmaChannel* rc = reinterpret_cast<RdmaChannel*>(wc_[i].wr_id); in Process_CQ()505 RdmaWriteID* wr_id = reinterpret_cast<RdmaWriteID*>(wc_[i].wr_id); in Process_CQ() local506 RDMA_LOG(2) << "Write complete of type " << wr_id->write_type; in Process_CQ()507 switch (wr_id->write_type) { in Process_CQ()512 reinterpret_cast<RdmaMessageBuffer*>(wr_id->write_context); in Process_CQ()519 reinterpret_cast<RdmaTensorResponse*>(wr_id->write_context); in Process_CQ()523 delete wr_id; in Process_CQ()534 wr.wr_id = kPingRecvWrid; in PingPostRecv()542 wr.wr_id = (uint64_t)this; in PingPostSend()[all …]
163 if ((int)rdma_adapter_->wc_[i].wr_id == RdmaChannel::kPingRecvWrid) { in ConnectivityCheck()171 reinterpret_cast<RdmaChannel*>(rdma_adapter_->wc_[i].wr_id); in ConnectivityCheck()
336 TensorKey key = wc[i].wr_id; in Run()