contrib/libpcap/pcap-rdmasniff.c

69 	struct pcap_rdmasniff *priv = handle->priv;
71 	stat->ps_recv = priv->packets_recv;
81 	struct pcap_rdmasniff *priv = handle->priv;
83 	ibv_dereg_mr(priv->mr);
84 	ibv_destroy_flow(priv->flow);
85 	ibv_destroy_qp(priv->qp);
86 	ibv_destroy_cq(priv->cq);
87 	ibv_dealloc_pd(priv->pd);
88 	ibv_destroy_comp_channel(priv->channel);
89 	ibv_close_device(priv->context);
90 	free(priv->oneshot_buffer);
98 	struct pcap_rdmasniff *priv = handle->priv;
104 	sg_entry.lkey = priv->mr->lkey;
111 	ibv_post_recv(priv->qp, &wr, &bad_wr);
117 	struct pcap_rdmasniff *priv = handle->priv;
125 	if (!priv->cq_event) {
126 		while (ibv_get_cq_event(priv->channel, &ev_cq, &ev_ctx) < 0) {
135 		ibv_ack_cq_events(priv->cq, 1);
136 		ibv_req_notify_cq(priv->cq, 0);
137 		priv->cq_event = 1;
156 		if (ibv_poll_cq(priv->cq, 1, &wc) != 1) {
157 			priv->cq_event = 0;
177 			++priv->packets_recv;
197 	struct pcap_rdmasniff *priv = handle->priv;
200 	memcpy(priv->oneshot_buffer, bytes, h->caplen);
201 	*sp->pkt = priv->oneshot_buffer;
207 	struct pcap_rdmasniff *priv = handle->priv;
214 	priv->context = ibv_open_device(priv->rdma_device);
215 	if (!priv->context) {
221 	priv->pd = ibv_alloc_pd(priv->context);
222 	if (!priv->pd) {
228 	priv->channel = ibv_create_comp_channel(priv->context);
229 	if (!priv->channel) {
235 	priv->cq = ibv_create_cq(priv->context, RDMASNIFF_NUM_RECEIVES,
236 				 NULL, priv->channel, 0);
237 	if (!priv->cq) {
243 	ibv_req_notify_cq(priv->cq, 0);
246 	qp_init_attr.send_cq = qp_init_attr.recv_cq = priv->cq;
250 	priv->qp = ibv_create_qp(priv->pd, &qp_init_attr);
251 	if (!priv->qp) {
259 	qp_attr.port_num = priv->port_num;
260 	if (ibv_modify_qp(priv->qp, &qp_attr, IBV_QP_STATE | IBV_QP_PORT)) {
268 	if (ibv_modify_qp(priv->qp, &qp_attr, IBV_QP_STATE)) {
277 	flow_attr.port = priv->port_num;
278 	priv->flow = ibv_create_flow(priv->qp, &flow_attr);
279 	if (!priv->flow) {
293 	priv->oneshot_buffer = malloc(RDMASNIFF_RECEIVE_SIZE);
294 	if (!priv->oneshot_buffer) {
300 	priv->mr = ibv_reg_mr(priv->pd, handle->buffer, handle->bufsize, IBV_ACCESS_LOCAL_WRITE);
301 	if (!priv->mr) {
312 	if (!ibv_query_port(priv->context, priv->port_num, &port_attr) &&
332 	handle->selectable_fd = priv->channel->fd;
337 	if (priv->mr) {
338 		ibv_dereg_mr(priv->mr);
341 	if (priv->flow) {
342 		ibv_destroy_flow(priv->flow);
345 	if (priv->qp) {
346 		ibv_destroy_qp(priv->qp);
349 	if (priv->cq) {
350 		ibv_destroy_cq(priv->cq);
353 	if (priv->channel) {
354 		ibv_destroy_comp_channel(priv->channel);
357 	if (priv->pd) {
358 		ibv_dealloc_pd(priv->pd);
361 	if (priv->context) {
362 		ibv_close_device(priv->context);
365 	if (priv->oneshot_buffer) {
366 		free(priv->oneshot_buffer);
375 	struct pcap_rdmasniff *priv;
417 				priv = p->priv;
418 				priv->rdma_device = dev_list[i];
419 				priv->port_num = port_num;