| /net/ceph/crush/ |
| D | mapper.c | 270 int item, int x) in is_out() argument
272 if (item >= weight_max) in is_out()
274 if (weight[item] >= 0x10000) in is_out()
276 if (weight[item] == 0) in is_out()
278 if ((crush_hash32_2(CRUSH_HASH_RJENKINS1, x, item) & 0xffff) in is_out()
279 < weight[item]) in is_out()
324 int item = 0; in crush_choose_firstn() local
360 item = bucket_perm_choose(in, x, r); in crush_choose_firstn()
362 item = crush_bucket_choose(in, x, r); in crush_choose_firstn()
363 if (item >= map->max_devices) { in crush_choose_firstn()
[all …]
|
| /net/tipc/ |
| D | name_distr.c | 147 struct distr_item *item; in tipc_named_publish() local
161 item = (struct distr_item *)msg_data(buf_msg(buf)); in tipc_named_publish()
162 publ_to_item(item, publ); in tipc_named_publish()
172 struct distr_item *item; in tipc_named_withdraw() local
186 item = (struct distr_item *)msg_data(buf_msg(buf)); in tipc_named_withdraw()
187 publ_to_item(item, publ); in tipc_named_withdraw()
202 struct distr_item *item = NULL; in named_distribute() local
218 item = (struct distr_item *)msg_data(buf_msg(buf)); in named_distribute()
222 publ_to_item(item, publ); in named_distribute()
223 item++; in named_distribute()
[all …]
|
| D | bcast.c | 943 struct tipc_port_list *item = pl_ptr; in tipc_port_list_add() local
948 for (; ; cnt -= item_sz, item = item->next) { in tipc_port_list_add()
952 if (item->ports[i] == port) in tipc_port_list_add()
955 item->ports[i] = port; in tipc_port_list_add()
959 if (!item->next) { in tipc_port_list_add()
960 item->next = kmalloc(sizeof(*item), GFP_ATOMIC); in tipc_port_list_add()
961 if (!item->next) { in tipc_port_list_add()
965 item->next->next = NULL; in tipc_port_list_add()
976 struct tipc_port_list *item; in tipc_port_list_free() local
979 for (item = pl_ptr->next; item; item = next) { in tipc_port_list_free()
[all …]
|
| D | socket.c | 750 struct tipc_port_list *item; in tipc_sk_mcast_rcv() local
770 for (item = &dports; item; item = item->next) { in tipc_sk_mcast_rcv()
777 msg_set_destport(msg, item->ports[i]); in tipc_sk_mcast_rcv()
|
| /net/sunrpc/auth_gss/ |
| D | svcauth_gss.c | 82 static struct rsi *rsi_lookup(struct cache_detail *cd, struct rsi *item);
99 static inline int rsi_hash(struct rsi *item) in rsi_hash() argument
101 return hash_mem(item->in_handle.data, item->in_handle.len, RSI_HASHBITS) in rsi_hash()
102 ^ hash_mem(item->in_token.data, item->in_token.len, RSI_HASHBITS); in rsi_hash()
107 struct rsi *item = container_of(a, struct rsi, h); in rsi_match() local
109 return netobj_equal(&item->in_handle, &tmp->in_handle) && in rsi_match()
110 netobj_equal(&item->in_token, &tmp->in_token); in rsi_match()
130 struct rsi *item = container_of(citem, struct rsi, h); in rsi_init() local
136 new->in_handle.len = item->in_handle.len; in rsi_init()
137 item->in_handle.len = 0; in rsi_init()
[all …]
|
| /net/sunrpc/ |
| D | svcauth_unix.c | 98 struct cache_head *item = container_of(kref, struct cache_head, ref); in ip_map_put() local
99 struct ip_map *im = container_of(item, struct ip_map,h); in ip_map_put()
101 if (test_bit(CACHE_VALID, &item->flags) && in ip_map_put()
102 !test_bit(CACHE_NEGATIVE, &item->flags)) in ip_map_put()
121 struct ip_map *item = container_of(citem, struct ip_map, h); in ip_map_init() local
123 strcpy(new->m_class, item->m_class); in ip_map_init()
124 new->m_addr = item->m_addr; in ip_map_init()
129 struct ip_map *item = container_of(citem, struct ip_map, h); in update() local
131 kref_get(&item->m_client->h.ref); in update()
132 new->m_client = item->m_client; in update()
[all …]
|
| D | cache.c | 40 static bool cache_defer_req(struct cache_req *req, struct cache_head *item);
41 static void cache_revisit_request(struct cache_head *item);
518 #define DFR_HASH(item) ((((long)item)>>4 ^ (((long)item)>>13)) % DFR_HASHSIZE) argument
536 static void __hash_deferred_req(struct cache_deferred_req *dreq, struct cache_head *item) in __hash_deferred_req() argument
538 int hash = DFR_HASH(item); in __hash_deferred_req()
545 struct cache_head *item, in setup_deferral() argument
549 dreq->item = item; in setup_deferral()
553 __hash_deferred_req(dreq, item); in setup_deferral()
576 static void cache_wait_req(struct cache_req *req, struct cache_head *item) in cache_wait_req() argument
584 setup_deferral(dreq, item, 0); in cache_wait_req()
[all …]
|
| /net/netfilter/ |
| D | nf_conntrack_ecache.c | 124 struct nf_ct_event item; in nf_ct_deliver_cached_events() local
149 item.ct = ct; in nf_ct_deliver_cached_events()
150 item.portid = 0; in nf_ct_deliver_cached_events()
151 item.report = 0; in nf_ct_deliver_cached_events()
153 ret = notify->fcn(events | missed, &item); in nf_ct_deliver_cached_events()
|
| D | nf_conntrack_h323_main.c | 918 &setup->fastStart.item[i]); in process_setup()
951 &callproc->fastStart.item[i]); in process_callproceeding()
983 &connect->fastStart.item[i]); in process_connect()
1015 &alert->fastStart.item[i]); in process_alerting()
1056 &facility->fastStart.item[i]); in process_facility()
1088 &progress->fastStart.item[i]); in process_progress()
1147 &pdu->h245Control.item[i]); in process_q931()
1420 rrq->callSignalAddress.item, in process_rrq()
1429 rrq->rasAddress.item, in process_rrq()
1462 rcf->callSignalAddress.item, in process_rcf()
[all …]
|
| D | nf_conntrack_netlink.c | 612 ctnetlink_conntrack_event(unsigned int events, struct nf_ct_event *item) in ctnetlink_conntrack_event() argument
618 struct nf_conn *ct = item->ct; in ctnetlink_conntrack_event()
642 if (!item->report && !nfnetlink_has_listeners(net, group)) in ctnetlink_conntrack_event()
650 nlh = nlmsg_put(skb, item->portid, 0, type, sizeof(*nfmsg), flags); in ctnetlink_conntrack_event()
726 err = nfnetlink_send(skb, net, item->portid, group, item->report, in ctnetlink_conntrack_event()
2415 ctnetlink_expect_event(unsigned int events, struct nf_exp_event *item) in ctnetlink_expect_event() argument
2417 struct nf_conntrack_expect *exp = item->exp; in ctnetlink_expect_event()
2435 if (!item->report && !nfnetlink_has_listeners(net, group)) in ctnetlink_expect_event()
2443 nlh = nlmsg_put(skb, item->portid, 0, type, sizeof(*nfmsg), flags); in ctnetlink_expect_event()
2458 nfnetlink_send(skb, net, item->portid, group, item->report, GFP_ATOMIC); in ctnetlink_expect_event()
|
| /net/wireless/ |
| D | core.c | 273 struct cfg80211_iface_destroy *item; in cfg80211_destroy_ifaces() local
278 while ((item = list_first_entry_or_null(&rdev->destroy_list, in cfg80211_destroy_ifaces()
282 u32 nlportid = item->nlportid; in cfg80211_destroy_ifaces()
284 list_del(&item->list); in cfg80211_destroy_ifaces()
285 kfree(item); in cfg80211_destroy_ifaces()
|