Searched refs:mlength (Results 1 – 7 of 7) sorted by relevance
| /drivers/staging/lustre/lustre/ptlrpc/ |
| D | events.c | 96 LASSERT(ev->offset + ev->mlength <= req->rq_repbuf_len); in reply_in_callback()
117 if (ev->mlength < ev->rlength) { in reply_in_callback()
132 ev->mlength, ev->offset, in reply_in_callback()
142 req->rq_nob_received = ev->mlength; in reply_in_callback()
152 req->rq_nob_received = ev->mlength; in reply_in_callback()
158 ev->mlength, ev->offset, req->rq_replen); in reply_in_callback()
203 desc->bd_nob_transferred += ev->mlength; in client_bulk_callback()
293 LASSERT((char *)ev->md.start + ev->offset + ev->mlength <= in request_in_callback()
329 req->rq_reqdata_len = ev->mlength; in request_in_callback()
341 req, req->rq_xid, ev->mlength); in request_in_callback()
|
| /drivers/staging/lustre/lnet/lnet/ |
| D | lib-ptl.c | 145 unsigned int mlength; in lnet_try_match_md() local
177 mlength = md->md_max_size; in lnet_try_match_md()
178 LASSERT(md->md_offset + mlength <= md->md_length); in lnet_try_match_md()
180 mlength = md->md_length - offset; in lnet_try_match_md()
183 if (info->mi_rlength <= mlength) { /* fits in allowed space */ in lnet_try_match_md()
184 mlength = info->mi_rlength; in lnet_try_match_md()
189 info->mi_rlength, md->md_length - offset, mlength); in lnet_try_match_md()
197 info->mi_portal, libcfs_id2str(info->mi_id), mlength, in lnet_try_match_md()
200 lnet_msg_attach_md(msg, md, offset, mlength); in lnet_try_match_md()
201 md->md_offset = offset + mlength; in lnet_try_match_md()
|
| D | lib-msg.c | 86 ev->mlength = msg->msg_wanted; in lnet_build_msg_event()
108 ev->mlength = hdr->msg.ack.mlength; in lnet_build_msg_event()
119 ev->mlength = in lnet_build_msg_event()
127 ev->mlength = in lnet_build_msg_event()
384 msg->msg_hdr.msg.ack.mlength = cpu_to_le32(msg->msg_ev.mlength); in lnet_complete_msg_locked()
|
| D | lib-move.c | 1502 int mlength; in lnet_parse_reply() local
1530 mlength = min_t(uint, rlength, md->md_length); in lnet_parse_reply()
1532 if (mlength < rlength && in lnet_parse_reply()
1537 mlength); in lnet_parse_reply()
1544 mlength, rlength, hdr->msg.reply.dst_wmd.wh_object_cookie); in lnet_parse_reply()
1546 lnet_msg_attach_md(msg, md, 0, mlength); in lnet_parse_reply()
1548 if (mlength != 0) in lnet_parse_reply()
1555 lnet_ni_recv(ni, private, msg, 0, 0, mlength, rlength); in lnet_parse_reply()
1572 hdr->msg.ack.mlength = le32_to_cpu(hdr->msg.ack.mlength); in lnet_parse_ack()
1697 hdr->msg.ack.mlength); in lnet_print_hdr()
[all …]
|
| D | api-ni.c | 227 CLASSERT((int)offsetof(lnet_hdr_t, msg.ack.mlength) == 56); in lnet_assert_wire_constants()
228 CLASSERT((int)sizeof(((lnet_hdr_t *)0)->msg.ack.mlength) == 4); in lnet_assert_wire_constants()
1791 rc = event.mlength; in lnet_ping()
|
| /drivers/staging/lustre/include/linux/lnet/ |
| D | types.h | 143 __u32 mlength; member
585 unsigned int mlength; member
|
| /drivers/staging/lustre/lnet/selftest/ |
| D | rpc.c | 1507 if (ev->status != 0 || ev->mlength != sizeof(*msg) || in srpc_lnet_ev_handler()
1514 ev->status, ev->mlength, in srpc_lnet_ev_handler()
1558 srpc_data.rpc_counters.bulk_get += ev->mlength; in srpc_lnet_ev_handler()
1560 srpc_data.rpc_counters.bulk_put += ev->mlength; in srpc_lnet_ev_handler()
|