| /net/sunrpc/xprtrdma/ |
| D | svc_rdma_sendto.c | 369 u32 *remaining, unsigned int segno) in svc_rdma_encode_write_segment() argument
380 length = min_t(u32, *remaining, segment->rs_length); in svc_rdma_encode_write_segment()
381 *remaining -= length; in svc_rdma_encode_write_segment()
406 u32 remaining = chunk->ch_payload_length; in svc_rdma_encode_write_chunk() local
422 ret = svc_rdma_encode_write_segment(sctxt, chunk, &remaining, segno); in svc_rdma_encode_write_chunk()
570 unsigned int len, remaining; in svc_rdma_xb_dma_map() local
581 remaining = xdr->page_len; in svc_rdma_xb_dma_map()
582 while (remaining) { in svc_rdma_xb_dma_map()
583 len = min_t(u32, PAGE_SIZE - pageoff, remaining); in svc_rdma_xb_dma_map()
589 remaining -= len; in svc_rdma_xb_dma_map()
[all …]
|
| D | svc_rdma_rw.c | 409 unsigned int remaining, in svc_rdma_pagelist_to_sg() argument
421 info->wi_next_off += remaining; in svc_rdma_pagelist_to_sg()
425 sge_bytes = min_t(unsigned int, remaining, in svc_rdma_pagelist_to_sg()
429 remaining -= sge_bytes; in svc_rdma_pagelist_to_sg()
434 } while (remaining); in svc_rdma_pagelist_to_sg()
447 unsigned int remaining) in svc_rdma_build_writes() argument
463 write_len = min(remaining, seg->rs_length - info->wi_seg_off); in svc_rdma_build_writes()
487 remaining -= write_len; in svc_rdma_build_writes()
488 } while (remaining); in svc_rdma_build_writes()
493 trace_svcrdma_small_wrch_err(rdma, remaining, info->wi_seg_no, in svc_rdma_build_writes()
[all …]
|
| D | rpc_rdma.c | 135 unsigned int count, remaining, offset; in rpcrdma_args_inline() local
141 remaining = xdr->page_len; in rpcrdma_args_inline()
144 while (remaining) { in rpcrdma_args_inline()
145 remaining -= min_t(unsigned int, in rpcrdma_args_inline()
146 PAGE_SIZE - offset, remaining); in rpcrdma_args_inline()
600 unsigned int page_base, len, remaining; in rpcrdma_prepare_pagelist() local
606 remaining = xdr->page_len; in rpcrdma_prepare_pagelist()
607 while (remaining) { in rpcrdma_prepare_pagelist()
609 len = min_t(unsigned int, PAGE_SIZE - page_base, remaining); in rpcrdma_prepare_pagelist()
620 remaining -= len; in rpcrdma_prepare_pagelist()
[all …]
|
| /net/mptcp/ |
| D | options.c | 438 unsigned int remaining, in mptcp_established_options_mp() argument
552 unsigned int remaining, in mptcp_established_options_dss() argument
576 remaining -= map_size; in mptcp_established_options_dss()
646 unsigned int remaining, in mptcp_established_options_add_addr() argument
662 !mptcp_pm_add_addr_signal(msk, skb, opt_size, remaining, &opts->addr, in mptcp_established_options_add_addr()
667 remaining += opt_size; in mptcp_established_options_add_addr()
669 if (remaining < len) in mptcp_established_options_add_addr()
699 unsigned int remaining, in mptcp_established_options_rm_addr() argument
708 !(mptcp_pm_rm_addr_signal(msk, remaining, &rm_list))) in mptcp_established_options_rm_addr()
714 if (remaining < len) in mptcp_established_options_rm_addr()
[all …]
|
| D | pm.c | 264 unsigned int opt_size, unsigned int remaining, in mptcp_pm_add_addr_signal() argument
283 remaining += opt_size; in mptcp_pm_add_addr_signal()
291 if (remaining < mptcp_add_addr_len(family, *echo, *port)) in mptcp_pm_add_addr_signal()
309 bool mptcp_pm_rm_addr_signal(struct mptcp_sock *msk, unsigned int remaining, in mptcp_pm_rm_addr_signal() argument
327 if (remaining < len) in mptcp_pm_rm_addr_signal()
|
| /net/sctp/ |
| D | chunk.c | 150 size_t len, first_len, max_data, remaining; in sctp_datamsg_from_user() local
236 for (remaining = msg_len; remaining; remaining -= len) { in sctp_datamsg_from_user()
239 if (remaining == msg_len) { in sctp_datamsg_from_user()
248 if (len >= remaining) { in sctp_datamsg_from_user()
250 len = remaining; in sctp_datamsg_from_user()
|
| /net/ipv4/ |
| D | tcp_output.c | 473 unsigned int *remaining) in bpf_skops_hdr_opt_len() argument
480 !*remaining) in bpf_skops_hdr_opt_len()
514 sock_ops.remaining_opt_len = *remaining; in bpf_skops_hdr_opt_len()
521 if (err || sock_ops.remaining_opt_len == *remaining) in bpf_skops_hdr_opt_len()
524 opts->bpf_opt_len = *remaining - sock_ops.remaining_opt_len; in bpf_skops_hdr_opt_len()
528 *remaining -= opts->bpf_opt_len; in bpf_skops_hdr_opt_len()
580 unsigned int *remaining) in bpf_skops_hdr_opt_len() argument
707 unsigned int *remaining) in smc_set_option() argument
712 if (*remaining >= TCPOLEN_EXP_SMC_BASE_ALIGNED) { in smc_set_option()
714 *remaining -= TCPOLEN_EXP_SMC_BASE_ALIGNED; in smc_set_option()
[all …]
|
| D | tcp_timer.c | 30 s32 remaining; in tcp_clamp_rto_to_user_timeout() local
36 remaining = icsk->icsk_user_timeout - elapsed; in tcp_clamp_rto_to_user_timeout()
37 if (remaining <= 0) in tcp_clamp_rto_to_user_timeout()
40 return min_t(u32, icsk->icsk_rto, msecs_to_jiffies(remaining)); in tcp_clamp_rto_to_user_timeout()
46 u32 remaining; in tcp_clamp_probe0_to_user_timeout() local
55 remaining = msecs_to_jiffies(icsk->icsk_user_timeout) - elapsed; in tcp_clamp_probe0_to_user_timeout()
56 remaining = max_t(u32, remaining, TCP_TIMEOUT_MIN); in tcp_clamp_probe0_to_user_timeout()
58 return min_t(u32, remaining, when); in tcp_clamp_probe0_to_user_timeout()
|
| D | tcp_recovery.c | 74 s32 remaining; in tcp_rack_detect_loss() local
89 remaining = tcp_rack_skb_timeout(tp, skb, reo_wnd); in tcp_rack_detect_loss()
90 if (remaining <= 0) { in tcp_rack_detect_loss()
95 *reo_timeout = max_t(u32, *reo_timeout, remaining); in tcp_rack_detect_loss()
|
| D | metrics.c | 16 int remaining; in ip_metrics_convert() local
21 nla_for_each_attr(nla, fc_mx, fc_mx_len, remaining) { in ip_metrics_convert()
|
| D | inet_hashtables.c | 744 u32 remaining, offset; in __inet_hash_connect() local
760 remaining = high - low; in __inet_hash_connect()
761 if (likely(remaining > 1)) in __inet_hash_connect()
762 remaining &= ~1U; in __inet_hash_connect()
769 offset %= remaining; in __inet_hash_connect()
777 for (i = 0; i < remaining; i += 2, port += 2) { in __inet_hash_connect()
779 port -= remaining; in __inet_hash_connect()
818 if ((offset & 1) && remaining > 1) in __inet_hash_connect()
|
| D | fib_semantics.c | 655 static int fib_count_nexthops(struct rtnexthop *rtnh, int remaining, in fib_count_nexthops() argument
660 while (rtnh_ok(rtnh, remaining)) { in fib_count_nexthops()
662 rtnh = rtnh_next(rtnh, &remaining); in fib_count_nexthops()
666 if (remaining > 0) { in fib_count_nexthops()
690 int remaining, struct fib_config *cfg, in fib_get_nhs() argument
703 if (!rtnh_ok(rtnh, remaining)) { in fib_get_nhs()
766 rtnh = rtnh_next(rtnh, &remaining); in fib_get_nhs()
841 int remaining, struct fib_config *cfg, in fib_get_nhs() argument
880 int remaining; in fib_nh_match() local
933 remaining = cfg->fc_mp_len; in fib_nh_match()
[all …]
|
| D | inet_connection_sock.c | 203 u32 remaining, offset; in inet_csk_find_open_port() local
222 remaining = high - low; in inet_csk_find_open_port()
223 if (likely(remaining > 1)) in inet_csk_find_open_port()
224 remaining &= ~1U; in inet_csk_find_open_port()
226 offset = prandom_u32() % remaining; in inet_csk_find_open_port()
234 for (i = 0; i < remaining; i += 2, port += 2) { in inet_csk_find_open_port()
236 port -= remaining; in inet_csk_find_open_port()
|
| /net/tls/ |
| D | tls_device_fallback.c | 240 int remaining; in fill_sg_in() local
270 remaining = *sync_size; in fill_sg_in()
271 for (i = 0; remaining > 0; i++) { in fill_sg_in()
278 remaining -= skb_frag_size(frag); in fill_sg_in()
280 if (remaining < 0) in fill_sg_in()
281 sg_in[i].length += remaining; in fill_sg_in()
|
| /net/mac80211/ |
| D | offchannel.c | 201 long remaining; in ieee80211_end_finished_rocs() local
206 remaining = roc->start_time + in ieee80211_end_finished_rocs()
214 if (roc->abort || roc->hw_begun || remaining <= 0) in ieee80211_end_finished_rocs()
217 remaining_dur_min = min(remaining_dur_min, remaining); in ieee80211_end_finished_rocs()
493 unsigned long remaining; in ieee80211_coalesce_hw_started_roc() local
504 remaining = cur_roc->start_time + in ieee80211_coalesce_hw_started_roc()
509 if (new_roc->duration > jiffies_to_msecs(remaining)) in ieee80211_coalesce_hw_started_roc()
|
| /net/sunrpc/ |
| D | svcsock.c | 184 static int svc_one_sock_name(struct svc_sock *svsk, char *buf, int remaining) in svc_one_sock_name() argument
193 len = snprintf(buf, remaining, "ipv4 %s %pI4 %d\n", in svc_one_sock_name()
200 len = snprintf(buf, remaining, "ipv6 %s %pI6 %d\n", in svc_one_sock_name()
207 len = snprintf(buf, remaining, "*unknown-%d*\n", in svc_one_sock_name()
211 if (len >= remaining) { in svc_one_sock_name()
1107 unsigned int offset, len, remaining; in svc_tcp_sendmsg() local
1112 remaining = xdr->page_len; in svc_tcp_sendmsg()
1113 while (remaining > 0) { in svc_tcp_sendmsg()
1114 len = min(remaining, bvec->bv_len - offset); in svc_tcp_sendmsg()
1123 remaining -= len; in svc_tcp_sendmsg()
|
| D | svc.c | 1734 size_t len, remaining; in svc_fill_symlink_pathname() local
1742 remaining = total; in svc_fill_symlink_pathname()
1748 remaining -= len; in svc_fill_symlink_pathname()
1751 if (remaining) { in svc_fill_symlink_pathname()
1752 len = min_t(size_t, remaining, PAGE_SIZE); in svc_fill_symlink_pathname()
|
| D | xdr.c | 1649 unsigned int remaining, offset, len; in xdr_stream_subsegment() local
1658 remaining = subbuf->page_len; in xdr_stream_subsegment()
1660 while (remaining) { in xdr_stream_subsegment()
1661 len = min_t(unsigned int, remaining, PAGE_SIZE) - offset; in xdr_stream_subsegment()
1668 remaining -= len; in xdr_stream_subsegment()
|
| D | svc_xprt.c | 1337 char *pos, int remaining) in svc_one_xprt_name() argument
1341 len = snprintf(pos, remaining, "%s %u\n", in svc_one_xprt_name()
1344 if (len >= remaining) in svc_one_xprt_name()
|
| /net/core/ |
| D | lwtunnel.c | 184 int lwtunnel_valid_encap_type_attr(struct nlattr *attr, int remaining, in lwtunnel_valid_encap_type_attr() argument
193 while (rtnh_ok(rtnh, remaining)) { in lwtunnel_valid_encap_type_attr()
211 rtnh = rtnh_next(rtnh, &remaining); in lwtunnel_valid_encap_type_attr()
|
| /net/dccp/ |
| D | output.c | 222 long remaining; in dccp_wait_for_ccid() local
228 remaining = schedule_timeout(delay); in dccp_wait_for_ccid()
236 return remaining; in dccp_wait_for_ccid()
|
| /net/mpls/ |
| D | af_mpls.c | 839 int remaining = len; in mpls_count_nexthops() local
845 while (rtnh_ok(rtnh, remaining)) { in mpls_count_nexthops()
877 rtnh = rtnh_next(rtnh, &remaining); in mpls_count_nexthops()
881 return remaining > 0 ? 0 : nhs; in mpls_count_nexthops()
890 int remaining = cfg->rc_mp_len; in mpls_nh_build_multi() local
901 if (!rtnh_ok(rtnh, remaining)) in mpls_nh_build_multi()
927 rtnh = rtnh_next(rtnh, &remaining); in mpls_nh_build_multi()
|
| /net/ceph/ |
| D | messenger_v2.c | 3340 int remaining; /* data + [data padding] + epilogue */ in revoke_at_prepare_read_data() local
3349 remaining = padded_len(data_len(con->in_msg)) + in revoke_at_prepare_read_data()
3352 remaining = data_len(con->in_msg) + CEPH_EPILOGUE_PLAIN_LEN; in revoke_at_prepare_read_data()
3355 remaining); in revoke_at_prepare_read_data()
3357 set_in_skip(con, resid + remaining); in revoke_at_prepare_read_data()
3364 int remaining; /* [data padding] + epilogue */ in revoke_at_prepare_read_data_cont() local
3378 remaining = padding_len(data_len(con->in_msg)) + in revoke_at_prepare_read_data_cont()
3381 remaining = CEPH_EPILOGUE_PLAIN_LEN; in revoke_at_prepare_read_data_cont()
3384 con->v2.in_cursor.total_resid, remaining); in revoke_at_prepare_read_data_cont()
3386 set_in_skip(con, con->v2.in_cursor.total_resid + remaining); in revoke_at_prepare_read_data_cont()
|
| /net/xfrm/ |
| D | xfrm_compat.c | 294 int len, remaining; in xfrm_xlate64() local
303 nla_for_each_attr(nla, attrs, len, remaining) { in xfrm_xlate64()
|
| /net/wireless/ |
| D | util.c | 758 int offset = 0, remaining; in ieee80211_amsdu_to_8023s() local
775 remaining = skb->len - offset; in ieee80211_amsdu_to_8023s()
776 if (subframe_len > remaining) in ieee80211_amsdu_to_8023s()
783 last = remaining <= subframe_len + padding; in ieee80211_amsdu_to_8023s()
|