| /net/ceph/crush/ |
| A D | crush.c | 32 switch (b->alg) { in crush_get_bucket_item_weight() 50 kfree(b); in crush_destroy_bucket_uniform() 58 kfree(b); in crush_destroy_bucket_list() 65 kfree(b); in crush_destroy_bucket_tree() 70 kfree(b->straws); in crush_destroy_bucket_straw() 73 kfree(b); in crush_destroy_bucket_straw() 80 kfree(b); in crush_destroy_bucket_straw2() 112 __s32 b; in crush_destroy() local 113 for (b = 0; b < map->max_buckets; b++) { in crush_destroy() 123 __u32 b; in crush_destroy() local [all …]
|
| A D | hash.c | 15 b = b-c; b = b-a; b = b^(a<<8); \ 16 c = c-a; c = c-b; c = c^(b>>13); \ 18 b = b-c; b = b-a; b = b^(a<<16); \ 19 c = c-a; c = c-b; c = c^(b>>5); \ 21 b = b-c; b = b-a; b = b^(a<<10); \ 22 c = c-a; c = c-b; c = c^(b>>15); \ 30 __u32 b = a; in crush_hash32_rjenkins1() local 33 crush_hashmix(b, x, hash); in crush_hash32_rjenkins1() 43 crush_hashmix(a, b, hash); in crush_hash32_rjenkins1_2() 45 crush_hashmix(b, y, hash); in crush_hash32_rjenkins1_2() [all …]
|
| /net/ceph/ |
| A D | ceph_hash.c | 13 b = b - c; b = b - a; b = b ^ (a << 8); \ 14 c = c - a; c = c - b; c = c ^ (b >> 13); \ 16 b = b - c; b = b - a; b = b ^ (a << 16); \ 17 c = c - a; c = c - b; c = c ^ (b >> 5); \ 19 b = b - c; b = b - a; b = b ^ (a << 10); \ 20 c = c - a; c = c - b; c = c ^ (b >> 15); \ 32 b = a; in ceph_str_hash_rjenkins() 62 b = b + ((__u32)k[7] << 24); in ceph_str_hash_rjenkins() 65 b = b + ((__u32)k[6] << 16); in ceph_str_hash_rjenkins() 68 b = b + ((__u32)k[5] << 8); in ceph_str_hash_rjenkins() [all …]
|
| A D | buffer.c | 14 struct ceph_buffer *b; in ceph_buffer_new() local 16 b = kmalloc(sizeof(*b), gfp); in ceph_buffer_new() 17 if (!b) in ceph_buffer_new() 21 if (!b->vec.iov_base) { in ceph_buffer_new() 22 kfree(b); in ceph_buffer_new() 26 kref_init(&b->kref); in ceph_buffer_new() 27 b->alloc_len = len; in ceph_buffer_new() 28 b->vec.iov_len = len; in ceph_buffer_new() 30 return b; in ceph_buffer_new() 40 kfree(b); in ceph_buffer_release() [all …]
|
| A D | armor.c | 43 unsigned char a, b, c; in ceph_armor() local 48 b = *src++; in ceph_armor() 49 *dst++ = encode_bits(((a & 3) << 4) | (b >> 4)); in ceph_armor() 52 *dst++ = encode_bits(((b & 15) << 2) | in ceph_armor() 56 *dst++ = encode_bits((b & 15) << 2); in ceph_armor() 80 int a, b, c, d; in ceph_unarmor() local 89 b = decode_bits(src[1]); in ceph_unarmor() 92 if (a < 0 || b < 0 || c < 0 || d < 0) in ceph_unarmor() 95 *dst++ = (a << 2) | (b >> 4); in ceph_unarmor() 98 *dst++ = ((b & 15) << 4) | (c >> 2); in ceph_unarmor()
|
| A D | osdmap.c | 51 int b = 0; in calc_bits_of() local 54 b++; in calc_bits_of() 56 return b; in calc_bits_of() 87 b->item_weights = kcalloc(b->h.size, sizeof(u32), GFP_NOFS); in crush_decode_list_bucket() 90 b->sum_weights = kcalloc(b->h.size, sizeof(u32), GFP_NOFS); in crush_decode_list_bucket() 125 b->item_weights = kcalloc(b->h.size, sizeof(u32), GFP_NOFS); in crush_decode_straw_bucket() 128 b->straws = kcalloc(b->h.size, sizeof(u32), GFP_NOFS); in crush_decode_straw_bucket() 407 __s32 b; in crush_finalize() local 413 for (b = 0; b < c->max_buckets; b++) { in crush_finalize() 523 b->items = kcalloc(b->size, sizeof(__s32), GFP_NOFS); in crush_decode() [all …]
|
| /net/tipc/ |
| A D | bearer.c | 189 if (b && (!strcmp(b->name, name))) in tipc_bearer_find() 325 b = kzalloc(sizeof(*b), GFP_ATOMIC); in tipc_enable_bearer() 415 b->media->disable_media(b); in bearer_disable() 468 b->media->raw2addr(b, &b->addr, (const char *)dev->dev_addr); in tipc_enable_l2_media() 575 b->media->send_msg(net, skb, b, dest); in tipc_bearer_xmit_skb() 606 b->media->send_msg(net, skb, b, dst); in tipc_bearer_xmit() 628 if (unlikely(!b || !test_bit(0, &b->up))) in tipc_bearer_bc_xmit() 640 b->media->send_msg(net, skb, b, dst); in tipc_bearer_bc_xmit() 664 if (likely(b && test_bit(0, &b->up) && in tipc_l2_rcv_msg() 668 tipc_rcv(dev_net(b->pt.dev), skb, b); in tipc_l2_rcv_msg() [all …]
|
| A D | discover.c | 85 u32 dest_domain = b->domain; in tipc_disc_init_msg() 97 b->media->addr2msg(msg_media_addr(hdr), &b->addr); in tipc_disc_init_msg() 134 media_addr_str, b->name); in disc_dupl_alert() 194 struct tipc_bearer *b) in tipc_disc_rcv() argument 225 err = b->media->msg2addr(b, &maddr, msg_media_addr(hdr)); in tipc_disc_rcv() 236 if (tipc_disc_addr_trial_msg(b->disc, &maddr, b, dst, in tipc_disc_rcv() 373 d->bearer_id = b->identity; in tipc_disc_create() 374 d->domain = b->domain; in tipc_disc_create() 380 b->disc = d; in tipc_disc_create() 410 d->bearer_id = b->identity; in tipc_disc_reset() [all …]
|
| A D | udp_media.c | 235 struct tipc_bearer *b, in tipc_udp_send_msg() argument 375 struct tipc_bearer *b; in tipc_udp_recv() local 387 b = rcu_dereference(ub->bearer); in tipc_udp_recv() 388 if (!b) in tipc_udp_recv() 391 if (b && test_bit(0, &b->up)) { in tipc_udp_recv() 464 struct tipc_bearer *b; in tipc_udp_nl_dump_remoteip() local 492 if (!b || b->bcast_addr.media_id != TIPC_MEDIA_TYPE_UDP) { in tipc_udp_nl_dump_remoteip() 496 bid = b->identity; in tipc_udp_nl_dump_remoteip() 503 if (!b || b->bcast_addr.media_id != TIPC_MEDIA_TYPE_UDP) { in tipc_udp_nl_dump_remoteip() 745 b->mtu = b->media->mtu; in tipc_udp_enable() [all …]
|
| A D | bearer.h | 106 struct tipc_bearer *b, 108 int (*enable_media)(struct net *net, struct tipc_bearer *b, 110 void (*disable_media)(struct tipc_bearer *b); 115 int (*msg2addr)(struct tipc_bearer *b, 118 int (*raw2addr)(struct tipc_bearer *b, 188 void tipc_rcv(struct net *net, struct sk_buff *skb, struct tipc_bearer *b); 218 int tipc_enable_l2_media(struct net *net, struct tipc_bearer *b, 220 bool tipc_bearer_hold(struct tipc_bearer *b); 221 void tipc_bearer_put(struct tipc_bearer *b); 222 void tipc_disable_l2_media(struct tipc_bearer *b); [all …]
|
| A D | ib_media.c | 68 static int tipc_ib_raw2addr(struct tipc_bearer *b, in tipc_ib_raw2addr() argument 75 addr->broadcast = !memcmp(msg, b->bcast_addr.value, in tipc_ib_raw2addr() 81 static int tipc_ib_msg2addr(struct tipc_bearer *b, in tipc_ib_msg2addr() argument 85 return tipc_ib_raw2addr(b, addr, msg); in tipc_ib_msg2addr()
|
| /net/rxrpc/ |
| A D | call_accept.c | 68 head = b->peer_backlog_head; in rxrpc_service_prealloc_one() 81 head = b->conn_backlog_head; in rxrpc_service_prealloc_one() 166 if (!b) { in rxrpc_service_prealloc() 168 if (!b) in rxrpc_service_prealloc() 170 rx->backlog = b; in rxrpc_service_prealloc() 185 if (!b) in rxrpc_discard_prealloc() 195 head = b->peer_backlog_head; in rxrpc_discard_prealloc() 196 tail = b->peer_backlog_tail; in rxrpc_discard_prealloc() 204 head = b->conn_backlog_head; in rxrpc_discard_prealloc() 238 kfree(b); in rxrpc_discard_prealloc() [all …]
|
| /net/sched/ |
| A D | sch_cake.c | 147 u16 t:3, b:10; member 1572 idx = qq.b; in cake_drop() 1883 b = div64_u64(b, window_interval); in cake_enqueue() 2012 !(b->sparse_flow_count + b->bulk_flow_count)) { in cake_dequeue() 2014 b->tin_deficit += b->tin_quantum; in cake_dequeue() 2015 if (b->sparse_flow_count + b->bulk_flow_count) in cake_dequeue() 2019 b++; in cake_dequeue() 2046 if ((b->sparse_flow_count + b->bulk_flow_count) > 0) { in cake_dequeue() 2191 b->avge_delay = cake_ewma(b->avge_delay, delay, 8); in cake_dequeue() 2192 b->peak_delay = cake_ewma(b->peak_delay, delay, in cake_dequeue() [all …]
|
| A D | cls_route.c | 165 if (b) { in route4_classify() 233 if (b) { in route4_get() 290 if (b) { in route4_destroy() 307 kfree_rcu(b, rcu); in route4_destroy() 328 b = f->bkt; in route4_delete() 440 if (!b) { in route4_set_parms() 442 if (b == NULL) in route4_set_parms() 465 f->bkt = b; in route4_set_parms() 549 if (b) { in route4_change() 550 fp = &b->ht[h]; in route4_change() [all …]
|
| A D | sch_sfb.c | 133 b[hash].qlen++; in increment_one_qlen() 162 b[hash].qlen--; in decrement_one_qlen() 182 b->p_mark = prob_minus(b->p_mark, q->decrement); in decrement_prob() 187 b->p_mark = prob_plus(b->p_mark, q->increment); in increment_prob() 205 if (qlen < b->qlen) in sfb_compute_qlen() 206 qlen = b->qlen; in sfb_compute_qlen() 209 prob = b->p_mark; in sfb_compute_qlen() 210 b++; in sfb_compute_qlen() 336 if (b->qlen == 0) in sfb_enqueue() 341 minqlen = b->qlen; in sfb_enqueue() [all …]
|
| /net/netfilter/ |
| A D | nft_set_pipapo_avx2.c | 245 return b; in nft_pipapo_avx2_lookup_4b_2() 322 return b; in nft_pipapo_avx2_lookup_4b_4() 417 return b; in nft_pipapo_avx2_lookup_4b_8() 508 return b; in nft_pipapo_avx2_lookup_4b_12() 644 return b; in nft_pipapo_avx2_lookup_4b_32() 702 return b; in nft_pipapo_avx2_lookup_8b_1() 767 return b; in nft_pipapo_avx2_lookup_8b_2() 842 return b; in nft_pipapo_avx2_lookup_8b_4() 928 return b; in nft_pipapo_avx2_lookup_8b_6() 1022 return b; in nft_pipapo_avx2_lookup_8b_16() [all …]
|
| A D | nft_set_pipapo.c | 442 int b; in pipapo_get() local 465 if (b < 0) { in pipapo_get() 779 int g, b, i; in pipapo_lt_4b_to_8b() local 784 for (b = 0; b < NFT_PIPAPO_BUCKETS(8); b++) { in pipapo_lt_4b_to_8b() 833 for (b = 0; b < NFT_PIPAPO_BUCKETS(4); b++) { in pipapo_lt_8b_to_4b() 847 for (b = 0; b < NFT_PIPAPO_BUCKETS(4); b++) { in pipapo_lt_8b_to_4b() 1618 int b; local 1623 for (b = 0; b < NFT_PIPAPO_BUCKETS(f->bb); b++) { 1936 for (b = 0; b < NFT_PIPAPO_BUCKETS(f->bb); b++) { 1942 x0 = b; [all …]
|
| /net/bridge/ |
| A D | br_ioctl.c | 164 struct __bridge_info b; in br_dev_siocdevprivate() local 166 memset(&b, 0, sizeof(struct __bridge_info)); in br_dev_siocdevprivate() 169 memcpy(&b.bridge_id, &br->bridge_id, 8); in br_dev_siocdevprivate() 170 b.root_path_cost = br->root_path_cost; in br_dev_siocdevprivate() 171 b.max_age = jiffies_to_clock_t(br->max_age); in br_dev_siocdevprivate() 173 b.forward_delay = br->forward_delay; in br_dev_siocdevprivate() 174 b.bridge_max_age = br->bridge_max_age; in br_dev_siocdevprivate() 175 b.bridge_hello_time = br->bridge_hello_time; in br_dev_siocdevprivate() 177 b.topology_change = br->topology_change; in br_dev_siocdevprivate() 179 b.root_port = br->root_port; in br_dev_siocdevprivate() [all …]
|
| A D | br.c | 219 const struct switchdev_brport *b; in br_switchdev_blocking_event() local 230 b = &brport_info->brport; in br_switchdev_blocking_event() 232 err = br_switchdev_port_offload(p, b->dev, b->ctx, in br_switchdev_blocking_event() 233 b->atomic_nb, b->blocking_nb, in br_switchdev_blocking_event() 234 b->tx_fwd_offload, extack); in br_switchdev_blocking_event() 239 b = &brport_info->brport; in br_switchdev_blocking_event() 241 br_switchdev_port_unoffload(p, b->ctx, b->atomic_nb, in br_switchdev_blocking_event() 242 b->blocking_nb); in br_switchdev_blocking_event() 246 b = &brport_info->brport; in br_switchdev_blocking_event() 248 err = br_switchdev_port_replay(p, b->dev, b->ctx, b->atomic_nb, in br_switchdev_blocking_event() [all …]
|
| /net/core/ |
| A D | gen_stats.c | 120 u64_stats_set(&b->bytes, 0); in gnet_stats_basic_sync_init() 121 u64_stats_set(&b->packets, 0); in gnet_stats_basic_sync_init() 122 u64_stats_init(&b->syncp); in gnet_stats_basic_sync_init() 165 start = u64_stats_fetch_begin(&b->syncp); in gnet_stats_add_basic() 166 bytes = u64_stats_read(&b->bytes); in gnet_stats_add_basic() 167 packets = u64_stats_read(&b->packets); in gnet_stats_add_basic() 204 start = u64_stats_fetch_begin(&b->syncp); in gnet_stats_read_basic() 205 *ret_bytes = u64_stats_read(&b->bytes); in gnet_stats_read_basic() 213 struct gnet_stats_basic_sync *b, in ___gnet_stats_copy_basic() argument 262 struct gnet_stats_basic_sync *b, in gnet_stats_copy_basic() argument [all …]
|
| A D | gen_estimator.c | 63 struct gnet_stats_basic_sync *b) in est_fetch_counters() argument 65 gnet_stats_basic_sync_init(b); in est_fetch_counters() 69 gnet_stats_add_basic(b, e->cpu_bstats, e->bstats, e->running); in est_fetch_counters() 79 struct gnet_stats_basic_sync b; in est_timer() local 83 est_fetch_counters(est, &b); in est_timer() 84 b_bytes = u64_stats_read(&b.bytes); in est_timer() 85 b_packets = u64_stats_read(&b.packets); in est_timer() 139 struct gnet_stats_basic_sync b; in gen_new_estimator() local 170 est_fetch_counters(est, &b); in gen_new_estimator() 173 est->last_bytes = u64_stats_read(&b.bytes); in gen_new_estimator() [all …]
|
| /net/ipv4/ |
| A D | ipconfig.c | 827 struct bootp_pkt *b; in ic_bootp_send_if() local 874 b->xid = d->xid; in ic_bootp_send_if() 991 struct bootp_pkt *b; in ic_bootp_recv() local 1013 h = &b->iph; in ic_bootp_recv() 1030 if (b->udph.source != htons(67) || b->udph.dest != htons(68)) in ic_bootp_recv() 1040 sizeof(b->exten)); in ic_bootp_recv() 1049 h = &b->iph; in ic_bootp_recv() 1069 d->dev->name, b->op, b->xid); in ic_bootp_recv() 1076 u8 *end = (u8 *) b + ntohs(b->iph.tot_len); in ic_bootp_recv() 1084 ext = &b->exten[4]; in ic_bootp_recv() [all …]
|
| /net/netfilter/ipvs/ |
| A D | ip_vs_dh.c | 101 struct ip_vs_dh_bucket *b; in ip_vs_dh_reassign() local 106 b = &s->buckets[0]; in ip_vs_dh_reassign() 110 dest = rcu_dereference_protected(b->dest, 1); in ip_vs_dh_reassign() 114 RCU_INIT_POINTER(b->dest, NULL); in ip_vs_dh_reassign() 121 RCU_INIT_POINTER(b->dest, dest); in ip_vs_dh_reassign() 125 b++; in ip_vs_dh_reassign() 137 struct ip_vs_dh_bucket *b; in ip_vs_dh_flush() local 140 b = &s->buckets[0]; in ip_vs_dh_flush() 142 dest = rcu_dereference_protected(b->dest, 1); in ip_vs_dh_flush() 145 RCU_INIT_POINTER(b->dest, NULL); in ip_vs_dh_flush() [all …]
|
| A D | ip_vs_sh.c | 166 struct ip_vs_sh_bucket *b; in ip_vs_sh_reassign() local 172 b = &s->buckets[0]; in ip_vs_sh_reassign() 177 dest = rcu_dereference_protected(b->dest, 1); in ip_vs_sh_reassign() 181 RCU_INIT_POINTER(b->dest, NULL); in ip_vs_sh_reassign() 188 RCU_INIT_POINTER(b->dest, dest); in ip_vs_sh_reassign() 201 b++; in ip_vs_sh_reassign() 213 struct ip_vs_sh_bucket *b; in ip_vs_sh_flush() local 216 b = &s->buckets[0]; in ip_vs_sh_flush() 218 dest = rcu_dereference_protected(b->dest, 1); in ip_vs_sh_flush() 221 RCU_INIT_POINTER(b->dest, NULL); in ip_vs_sh_flush() [all …]
|
| /net/sunrpc/ |
| A D | stats.c | 218 static void _add_rpc_iostats(struct rpc_iostats *a, struct rpc_iostats *b) in _add_rpc_iostats() argument 220 a->om_ops += b->om_ops; in _add_rpc_iostats() 221 a->om_ntrans += b->om_ntrans; in _add_rpc_iostats() 222 a->om_timeouts += b->om_timeouts; in _add_rpc_iostats() 223 a->om_bytes_sent += b->om_bytes_sent; in _add_rpc_iostats() 224 a->om_bytes_recv += b->om_bytes_recv; in _add_rpc_iostats() 225 a->om_queue = ktime_add(a->om_queue, b->om_queue); in _add_rpc_iostats() 226 a->om_rtt = ktime_add(a->om_rtt, b->om_rtt); in _add_rpc_iostats() 227 a->om_execute = ktime_add(a->om_execute, b->om_execute); in _add_rpc_iostats() 228 a->om_error_status += b->om_error_status; in _add_rpc_iostats()
|