Home
last modified time | relevance | path

Searched refs:recv_buf (Results 1 – 11 of 11) sorted by relevance

/freebsd-10-stable/sys/ofed/drivers/infiniband/core/
Dmad_rmpp.c137 hdr_len = ib_get_mad_data_offset(recv_wc->recv_buf.mad->mad_hdr.mgmt_class); in ack_recv()
144 format_ack(msg, (struct ib_rmpp_mad *) recv_wc->recv_buf.mad, rmpp_recv); in ack_recv()
159 recv_wc->recv_buf.grh, agent->port_num); in alloc_response_msg()
163 hdr_len = ib_get_mad_data_offset(recv_wc->recv_buf.mad->mad_hdr.mgmt_class); in alloc_response_msg()
189 memcpy(rmpp_mad, recv_wc->recv_buf.mad, msg->hdr_len); in ack_ds_ack()
222 memcpy(rmpp_mad, recv_wc->recv_buf.mad, msg->hdr_len); in nack_recv()
290 mad_recv_wc->recv_buf.grh, in create_rmpp_recv()
304 rmpp_recv->cur_seg_buf = &mad_recv_wc->recv_buf; in create_rmpp_recv()
310 mad_hdr = &mad_recv_wc->recv_buf.mad->mad_hdr; in create_rmpp_recv()
328 struct ib_mad_hdr *mad_hdr = &mad_recv_wc->recv_buf.mad->mad_hdr; in find_rmpp_recv()
[all …]
Duser_mad.c243 mad_recv_wc->wc, mad_recv_wc->recv_buf.grh, in recv_handler()
266 struct ib_mad_recv_buf *recv_buf; in copy_recv_mad() local
270 recv_buf = &packet->recv_wc->recv_buf; in copy_recv_mad()
271 if ((packet->length <= sizeof (*recv_buf->mad) && in copy_recv_mad()
273 (packet->length > sizeof (*recv_buf->mad) && in copy_recv_mad()
274 count < hdr_size(file) + sizeof (*recv_buf->mad))) in copy_recv_mad()
281 seg_payload = min_t(int, packet->length, sizeof (*recv_buf->mad)); in copy_recv_mad()
282 if (copy_to_user(buf, recv_buf->mad, seg_payload)) in copy_recv_mad()
297 offset = ib_get_mad_data_offset(recv_buf->mad->mad_hdr.mgmt_class); in copy_recv_mad()
302 recv_buf = container_of(recv_buf->list.next, in copy_recv_mad()
[all …]
Dcm.c303 mad_recv_wc->recv_buf.grh, port->port_num); in cm_alloc_response_msg()
1225 rcv_msg = (struct cm_rej_msg *) mad_recv_wc->recv_buf.mad; in cm_issue_rej()
1308 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad; in cm_format_req_event()
1464 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad; in cm_match_req()
1547 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad; in cm_req_handler()
1556 work->mad_recv_wc->recv_buf.grh, in cm_req_handler()
1776 rep_msg = (struct cm_rep_msg *)work->mad_recv_wc->recv_buf.mad; in cm_format_rep_event()
1799 rep_msg = (struct cm_rep_msg *) work->mad_recv_wc->recv_buf.mad; in cm_dup_rep_handler()
1841 rep_msg = (struct cm_rep_msg *)work->mad_recv_wc->recv_buf.mad; in cm_rep_handler()
1960 rtu_msg = (struct cm_rtu_msg *)work->mad_recv_wc->recv_buf.mad; in cm_rtu_handler()
[all …]
Dlocal_sa.c141 struct ib_mad_recv_buf *recv_buf; member
304 struct ib_sa_mad *mad = (struct ib_sa_mad *) mad_recv_wc->recv_buf.mad; in ib_sa_iter_create()
318 iter->recv_buf = &mad_recv_wc->recv_buf; in ib_sa_iter_create()
336 mad = (struct ib_sa_mad *) iter->recv_buf->mad; in ib_sa_iter_next()
361 iter->recv_buf = list_entry(iter->recv_buf->list.next, in ib_sa_iter_next()
Dmad.c1178 recv_buf); in ib_free_recv_mad()
1705 rwc->recv_buf.mad->mad_hdr.mgmt_class; in rcv_has_same_class()
1720 rcv_resp = ib_response_mad(rwc->recv_buf.mad); in rcv_has_same_gid()
1747 return !memcmp(sgid.raw, rwc->recv_buf.grh->dgid.raw, in rcv_has_same_gid()
1755 return !memcmp(attr.grh.dgid.raw, rwc->recv_buf.grh->sgid.raw, in rcv_has_same_gid()
1771 mad = (struct ib_mad *)wc->recv_buf.mad; in ib_find_send_mad()
1780 (is_direct(wc->recv_buf.mad->mad_hdr.mgmt_class) || in ib_find_send_mad()
1798 (is_direct(wc->recv_buf.mad->mad_hdr.mgmt_class) || in ib_find_send_mad()
1822 list_add(&mad_recv_wc->recv_buf.list, &mad_recv_wc->rmpp_list); in ib_mad_complete_recv()
1833 if (ib_response_mad(mad_recv_wc->recv_buf.mad)) { in ib_mad_complete_recv()
[all …]
Dsa_query.c1232 memcpy(mad, mad_recv_wc->recv_buf.mad, sizeof *mad); in ib_sa_notice_resp()
1299 mad_recv_wc->recv_buf.mad->mad_hdr.status ? in recv_handler()
1301 (struct ib_sa_mad *) mad_recv_wc->recv_buf.mad); in recv_handler()
1324 mad = (struct ib_sa_mad *) mad_recv_wc->recv_buf.mad; in notice_handler()
/freebsd-10-stable/sys/ofed/drivers/infiniband/util/
Dmadeye.c417 if (!smp && mad_recv_wc->recv_buf.mad->mad_hdr.mgmt_class != mgmt_class) in recv_smi_handler()
419 if (attr_id && be16_to_cpu(mad_recv_wc->recv_buf.mad->mad_hdr.attr_id) != attr_id) in recv_smi_handler()
423 print_smp((struct ib_smp *)&mad_recv_wc->recv_buf.mad->mad_hdr); in recv_smi_handler()
465 struct ib_mad_hdr *hdr = &mad_recv_wc->recv_buf.mad->mad_hdr; in recv_gsi_handler()
474 if (attr_id && be16_to_cpu(mad_recv_wc->recv_buf.mad->mad_hdr.attr_id) != attr_id) in recv_gsi_handler()
493 &mad_recv_wc->recv_buf.mad; in recv_gsi_handler()
500 &mad_recv_wc->recv_buf.mad; in recv_gsi_handler()
508 mad_data = mad_recv_wc->recv_buf.mad->data; in recv_gsi_handler()
/freebsd-10-stable/tests/sys/kern/
Dunix_seqpacket_test.c173 char recv_buf[pktsize]; in test_sendrecv_symmetric_buffers() local
200 rsize = recv(sv[1], recv_buf, pktsize, MSG_WAITALL); in test_sendrecv_symmetric_buffers()
641 char recv_buf[bufsize]; in ATF_TC_BODY() local
658 rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL); in ATF_TC_BODY()
679 char recv_buf[bufsize]; in ATF_TC_BODY() local
698 rsize = recvfrom(sv[1], recv_buf, bufsize, MSG_WAITALL, in ATF_TC_BODY()
728 char recv_buf[bufsize]; in ATF_TC_BODY() local
744 rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL); in ATF_TC_BODY()
792 char recv_buf[bufsize]; in ATF_TC_BODY() local
800 rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL); in ATF_TC_BODY()
[all …]
/freebsd-10-stable/contrib/ofed/librdmacm/examples/
Drping.c123 struct rping_rdma_info recv_buf;/* malloc'd buffer */ member
239 if (wc->byte_len != sizeof(cb->recv_buf)) { in server_recv()
244 cb->remote_rkey = ntohl(cb->recv_buf.rkey); in server_recv()
245 cb->remote_addr = ntohll(cb->recv_buf.buf); in server_recv()
246 cb->remote_len = ntohl(cb->recv_buf.size); in server_recv()
260 if (wc->byte_len != sizeof(cb->recv_buf)) { in client_recv()
369 cb->recv_sgl.addr = (uint64_t) (unsigned long) &cb->recv_buf; in rping_setup_wr()
370 cb->recv_sgl.length = sizeof cb->recv_buf; in rping_setup_wr()
397 cb->recv_mr = ibv_reg_mr(cb->pd, &cb->recv_buf, sizeof cb->recv_buf, in rping_setup_buffers()
/freebsd-10-stable/sys/contrib/rdma/krping/
Dkrping.c187 struct krping_rdma_info recv_buf;/* malloc'd buffer */ member
317 if (wc->byte_len != sizeof(cb->recv_buf)) { in server_recv()
323 cb->remote_rkey = ntohl(cb->recv_buf.rkey); in server_recv()
324 cb->remote_addr = ntohll(cb->recv_buf.buf); in server_recv()
325 cb->remote_len = ntohl(cb->recv_buf.size); in server_recv()
340 if (wc->byte_len != sizeof(cb->recv_buf)) { in client_recv()
410 cb->stats.recv_bytes += sizeof(cb->recv_buf); in krping_cq_event_handler()
479 cb->recv_sgl.length = sizeof cb->recv_buf; in krping_setup_wr()
548 &cb->recv_buf, in krping_setup_buffers()
549 sizeof(cb->recv_buf), DMA_BIDIRECTIONAL); in krping_setup_buffers()
[all …]
/freebsd-10-stable/sys/ofed/include/rdma/
Dib_mad.h405 struct ib_mad_recv_buf recv_buf; member