| /drivers/staging/lustre/lnet/klnds/socklnd/ |
| D | socklnd.c | 106 ksock_peer_t *peer; in ksocknal_create_peer() local
112 LIBCFS_ALLOC(peer, sizeof(*peer)); in ksocknal_create_peer()
113 if (peer == NULL) in ksocknal_create_peer()
116 peer->ksnp_ni = ni; in ksocknal_create_peer()
117 peer->ksnp_id = id; in ksocknal_create_peer()
118 atomic_set(&peer->ksnp_refcount, 1); /* 1 ref for caller */ in ksocknal_create_peer()
119 peer->ksnp_closing = 0; in ksocknal_create_peer()
120 peer->ksnp_accepting = 0; in ksocknal_create_peer()
121 peer->ksnp_proto = NULL; in ksocknal_create_peer()
122 peer->ksnp_last_alive = 0; in ksocknal_create_peer()
[all …]
|
| D | socklnd_cb.c | 436 ksock_peer_t *peer = conn->ksnc_peer; in ksocknal_check_zc_req() local
458 spin_lock(&peer->ksnp_lock); in ksocknal_check_zc_req()
466 tx->tx_msg.ksm_zc_cookies[0] = peer->ksnp_zc_next_cookie++; in ksocknal_check_zc_req()
468 if (peer->ksnp_zc_next_cookie == 0) in ksocknal_check_zc_req()
469 peer->ksnp_zc_next_cookie = SOCKNAL_KEEPALIVE_PING + 1; in ksocknal_check_zc_req()
471 list_add_tail(&tx->tx_zc_list, &peer->ksnp_zc_req_list); in ksocknal_check_zc_req()
473 spin_unlock(&peer->ksnp_lock); in ksocknal_check_zc_req()
479 ksock_peer_t *peer = tx->tx_conn->ksnc_peer; in ksocknal_uncheck_zc_req() local
486 spin_lock(&peer->ksnp_lock); in ksocknal_uncheck_zc_req()
490 spin_unlock(&peer->ksnp_lock); in ksocknal_uncheck_zc_req()
[all …]
|
| D | socklnd.h | 598 ksocknal_peer_addref(ksock_peer_t *peer) in ksocknal_peer_addref() argument
600 LASSERT(atomic_read(&peer->ksnp_refcount) > 0); in ksocknal_peer_addref()
601 atomic_inc(&peer->ksnp_refcount); in ksocknal_peer_addref()
604 void ksocknal_destroy_peer(ksock_peer_t *peer);
607 ksocknal_peer_decref(ksock_peer_t *peer) in ksocknal_peer_decref() argument
609 LASSERT(atomic_read(&peer->ksnp_refcount) > 0); in ksocknal_peer_decref()
610 if (atomic_dec_and_test(&peer->ksnp_refcount)) in ksocknal_peer_decref()
611 ksocknal_destroy_peer(peer); in ksocknal_peer_decref()
627 void ksocknal_peer_failed(ksock_peer_t *peer);
633 int ksocknal_close_peer_conns_locked(ksock_peer_t *peer,
[all …]
|
| /drivers/net/ |
| D | veth.c | 36 struct net_device __rcu *peer; member
94 struct net_device *peer = rtnl_dereference(priv->peer); in veth_get_ethtool_stats() local
96 data[0] = peer ? peer->ifindex : 0; in veth_get_ethtool_stats()
115 rcv = rcu_dereference(priv->peer); in veth_xmit()
167 struct net_device *peer; in veth_get_stats64() local
175 peer = rcu_dereference(priv->peer); in veth_get_stats64()
176 if (peer) { in veth_get_stats64()
177 tot->rx_dropped = veth_stats_one(&one, peer); in veth_get_stats64()
194 struct net_device *peer = rtnl_dereference(priv->peer); in veth_open() local
196 if (!peer) in veth_open()
[all …]
|
| D | rionet.c | 234 struct rionet_peer *peer; in rionet_dbell_event() local
241 list_for_each_entry(peer, in rionet_dbell_event()
243 if (peer->rdev->destid == sid) { in rionet_dbell_event()
245 peer->rdev; in rionet_dbell_event()
308 struct rionet_peer *peer, *tmp; in rionet_open() local
348 list_for_each_entry_safe(peer, tmp, in rionet_open()
350 if (!(peer->res = rio_request_outb_dbell(peer->rdev, in rionet_open()
360 rio_send_doorbell(peer->rdev, RIONET_DOORBELL_JOIN); in rionet_open()
370 struct rionet_peer *peer, *tmp; in rionet_close() local
382 list_for_each_entry_safe(peer, tmp, in rionet_close()
[all …]
|
| /drivers/staging/fwserial/ |
| D | fwserial.c | 240 static int fwtty_send_data_async(struct fwtty_peer *peer, int tcode, in fwtty_send_data_async() argument
255 generation = peer->generation; in fwtty_send_data_async()
257 fw_send_request(peer->serial->card, &txn->fw_txn, tcode, in fwtty_send_data_async()
258 peer->node_id, generation, peer->speed, addr, payload, in fwtty_send_data_async()
263 static void fwtty_send_txn_async(struct fwtty_peer *peer, in fwtty_send_txn_async() argument
274 generation = peer->generation; in fwtty_send_txn_async()
276 fw_send_request(peer->serial->card, &txn->fw_txn, tcode, in fwtty_send_txn_async()
277 peer->node_id, generation, peer->speed, addr, payload, in fwtty_send_txn_async()
425 struct fwtty_peer *peer; in __fwtty_write_port_status() local
430 peer = rcu_dereference(port->peer); in __fwtty_write_port_status()
[all …]
|
| D | fwserial.h | 124 static inline void peer_set_state(struct fwtty_peer *peer, int new) in peer_set_state() argument
126 peer->state = new; in peer_set_state()
129 static inline struct fwtty_port *peer_revert_state(struct fwtty_peer *peer) in peer_revert_state() argument
131 struct fwtty_port *port = peer->port; in peer_revert_state()
133 peer->port = NULL; in peer_revert_state()
134 peer_set_state(peer, FWPS_NOT_ATTACHED); in peer_revert_state()
269 struct fwtty_peer __rcu *peer; member
|
| /drivers/net/wireless/ath/ath10k/ |
| D | txrx.c | 124 struct ath10k_peer *peer; in ath10k_peer_find() local
128 list_for_each_entry(peer, &ar->peers, list) { in ath10k_peer_find()
129 if (peer->vdev_id != vdev_id) in ath10k_peer_find()
131 if (memcmp(peer->addr, addr, ETH_ALEN)) in ath10k_peer_find()
134 return peer; in ath10k_peer_find()
142 struct ath10k_peer *peer; in ath10k_peer_find_by_id() local
146 list_for_each_entry(peer, &ar->peers, list) in ath10k_peer_find_by_id()
147 if (test_bit(peer_id, peer->peer_ids)) in ath10k_peer_find_by_id()
148 return peer; in ath10k_peer_find_by_id()
189 struct ath10k_peer *peer; in ath10k_peer_map_event() local
[all …]
|
| /drivers/usb/core/ |
| D | port.c | 83 struct usb_port *peer = port_dev->peer; in usb_port_runtime_resume() local
98 if (!port_dev->is_superspeed && peer) in usb_port_runtime_resume()
99 pm_runtime_get_sync(&peer->dev); in usb_port_runtime_resume()
141 struct usb_port *peer = port_dev->peer; in usb_port_runtime_suspend() local
172 if (!port_dev->is_superspeed && peer) in usb_port_runtime_suspend()
173 pm_runtime_put(&peer->dev); in usb_port_runtime_suspend()
202 if (left->peer == right && right->peer == left) in link_peers()
205 if (left->peer || right->peer) { in link_peers()
206 struct usb_port *lpeer = left->peer; in link_peers()
207 struct usb_port *rpeer = right->peer; in link_peers()
[all …]
|
| /drivers/staging/lustre/lnet/klnds/o2iblnd/ |
| D | o2iblnd_cb.c | 757 kib_peer_t *peer = conn->ibc_peer; in kiblnd_post_tx_locked() local
777 libcfs_nid2str(peer->ibp_nid)); in kiblnd_post_tx_locked()
783 libcfs_nid2str(peer->ibp_nid)); in kiblnd_post_tx_locked()
791 libcfs_nid2str(peer->ibp_nid)); in kiblnd_post_tx_locked()
807 kiblnd_tx_done(peer->ibp_ni, tx); in kiblnd_post_tx_locked()
810 libcfs_nid2str(peer->ibp_nid), in kiblnd_post_tx_locked()
815 kiblnd_pack_msg(peer->ibp_ni, msg, ver, conn->ibc_outstanding_credits, in kiblnd_post_tx_locked()
816 peer->ibp_nid, conn->ibc_incarnation); in kiblnd_post_tx_locked()
869 rc, libcfs_nid2str(peer->ibp_nid)); in kiblnd_post_tx_locked()
872 rc, libcfs_nid2str(peer->ibp_nid)); in kiblnd_post_tx_locked()
[all …]
|
| D | o2iblnd.c | 324 kib_peer_t *peer; in kiblnd_create_peer() local
332 LIBCFS_CPT_ALLOC(peer, lnet_cpt_table(), cpt, sizeof(*peer)); in kiblnd_create_peer()
333 if (peer == NULL) { in kiblnd_create_peer()
338 memset(peer, 0, sizeof(*peer)); /* zero flags etc */ in kiblnd_create_peer()
340 peer->ibp_ni = ni; in kiblnd_create_peer()
341 peer->ibp_nid = nid; in kiblnd_create_peer()
342 peer->ibp_error = 0; in kiblnd_create_peer()
343 peer->ibp_last_alive = 0; in kiblnd_create_peer()
344 atomic_set(&peer->ibp_refcount, 1); /* 1 ref for caller */ in kiblnd_create_peer()
346 INIT_LIST_HEAD(&peer->ibp_list); /* not in the peer table yet */ in kiblnd_create_peer()
[all …]
|
| D | o2iblnd.h | 646 #define kiblnd_peer_addref(peer) \ argument
649 (peer), libcfs_nid2str((peer)->ibp_nid), \
650 atomic_read(&(peer)->ibp_refcount)); \
651 atomic_inc(&(peer)->ibp_refcount); \
654 #define kiblnd_peer_decref(peer) \ argument
657 (peer), libcfs_nid2str((peer)->ibp_nid), \
658 atomic_read(&(peer)->ibp_refcount)); \
659 LASSERT_ATOMIC_POS(&(peer)->ibp_refcount); \
660 if (atomic_dec_and_test(&(peer)->ibp_refcount)) \
661 kiblnd_destroy_peer(peer); \
[all …]
|
| /drivers/net/wireless/mwifiex/ |
| D | tdls.c | 435 const u8 *peer, u8 action_code, in mwifiex_prep_tdls_encap_data() argument
448 memcpy(tf->da, peer, ETH_ALEN); in mwifiex_prep_tdls_encap_data()
538 ret = mwifiex_tdls_add_vht_oper(priv, peer, skb); in mwifiex_prep_tdls_encap_data()
543 ret = mwifiex_tdls_add_ht_oper(priv, peer, 1, skb); in mwifiex_prep_tdls_encap_data()
549 ret = mwifiex_tdls_add_ht_oper(priv, peer, 0, skb); in mwifiex_prep_tdls_encap_data()
580 const u8 *peer, const u8 *bssid) in mwifiex_tdls_add_link_ie() argument
591 memcpy(lnkid->resp_sta, peer, ETH_ALEN); in mwifiex_tdls_add_link_ie()
594 int mwifiex_send_tdls_data_frame(struct mwifiex_private *priv, const u8 *peer, in mwifiex_send_tdls_data_frame() argument
636 ret = mwifiex_prep_tdls_encap_data(priv, peer, action_code, in mwifiex_send_tdls_data_frame()
646 mwifiex_tdls_add_link_ie(skb, priv->curr_addr, peer, in mwifiex_send_tdls_data_frame()
[all …]
|
| /drivers/net/wireless/iwlwifi/mvm/ |
| D | tdls.c | 250 mvm->tdls_cs.peer.sent_timestamp = in iwl_mvm_tdls_update_cs_state()
301 const u8 *peer, bool peer_initiator, u32 timestamp) in iwl_mvm_tdls_check_action() argument
313 same_peer = ether_addr_equal(peer, sta->addr); in iwl_mvm_tdls_check_action()
340 else if (timestamp <= mvm->tdls_cs.peer.sent_timestamp) in iwl_mvm_tdls_check_action()
375 type, mvm->tdls_cs.state, peer, same_peer, in iwl_mvm_tdls_check_action()
385 const u8 *peer, bool peer_initiator, in iwl_mvm_tdls_config_channel_switch() argument
401 ret = iwl_mvm_tdls_check_action(mvm, type, peer, peer_initiator, in iwl_mvm_tdls_config_channel_switch()
417 sta = ieee80211_find_sta(vif, peer); in iwl_mvm_tdls_config_channel_switch()
428 mvm->tdls_cs.peer.chandef.chan) { in iwl_mvm_tdls_config_channel_switch()
430 chandef = &mvm->tdls_cs.peer.chandef; in iwl_mvm_tdls_config_channel_switch()
[all …]
|
| /drivers/firewire/ |
| D | net.c | 361 struct fwnet_peer *peer, u16 datagram_label, unsigned dg_size, in fwnet_pd_new() argument
385 list_add_tail(&new->pd_link, &peer->pd_list); in fwnet_pd_new()
397 static struct fwnet_partial_datagram *fwnet_pd_find(struct fwnet_peer *peer, in fwnet_pd_find() argument
402 list_for_each_entry(pd, &peer->pd_list, pd_link) in fwnet_pd_find()
422 static bool fwnet_pd_update(struct fwnet_peer *peer, in fwnet_pd_update() argument
435 list_move_tail(&pd->pd_link, &peer->pd_list); in fwnet_pd_update()
453 struct fwnet_peer *peer; in fwnet_peer_find_by_guid() local
455 list_for_each_entry(peer, &dev->peer_list, peer_link) in fwnet_peer_find_by_guid()
456 if (peer->guid == guid) in fwnet_peer_find_by_guid()
457 return peer; in fwnet_peer_find_by_guid()
[all …]
|
| /drivers/staging/lustre/lnet/lnet/ |
| D | router_proc.c | 317 struct lnet_peer *peer = NULL; in proc_lnet_routers() local
336 peer = lp; in proc_lnet_routers()
344 if (peer != NULL) { in proc_lnet_routers()
345 lnet_nid_t nid = peer->lp_nid; in proc_lnet_routers()
347 unsigned long deadline = peer->lp_ping_deadline; in proc_lnet_routers()
348 int nrefs = peer->lp_refcount; in proc_lnet_routers()
349 int nrtrrefs = peer->lp_rtr_refcount; in proc_lnet_routers()
350 int alive_cnt = peer->lp_alive_count; in proc_lnet_routers()
351 int alive = peer->lp_alive; in proc_lnet_routers()
352 int pingsent = !peer->lp_ping_notsent; in proc_lnet_routers()
[all …]
|
| /drivers/nfc/ |
| D | nfcsim.c | 133 struct nfcsim *peer = dev->peer_dev; in nfcsim_dep_link_up() local
139 mutex_lock(&peer->lock); in nfcsim_dep_link_up()
141 nfc_tm_activated(peer->nfc_dev, NFC_PROTO_NFC_DEP_MASK, in nfcsim_dep_link_up()
144 remote_gb = nfc_get_local_general_bytes(peer->nfc_dev, &remote_gb_len); in nfcsim_dep_link_up()
146 DEV_ERR(peer, "Can't get remote general bytes\n"); in nfcsim_dep_link_up()
148 mutex_unlock(&peer->lock); in nfcsim_dep_link_up()
152 mutex_unlock(&peer->lock); in nfcsim_dep_link_up()
292 struct nfcsim *peer = dev->peer_dev; in nfcsim_tx() local
308 mutex_lock(&peer->lock); in nfcsim_tx()
310 peer->clone_skb = skb_clone(skb, GFP_KERNEL); in nfcsim_tx()
[all …]
|
| /drivers/acpi/acpica/ |
| D | nsalloc.c | 181 next_node = next_node->peer; in acpi_ns_remove_node()
188 prev_node->peer = node->peer; in acpi_ns_remove_node()
194 parent_node->child = node->peer; in acpi_ns_remove_node()
254 node->peer = NULL; in acpi_ns_install_node()
263 while (child_node->peer) { in acpi_ns_install_node()
264 child_node = child_node->peer; in acpi_ns_install_node()
267 child_node->peer = node; in acpi_ns_install_node()
327 next_node = next_node->peer; in acpi_ns_delete_children()
|
| /drivers/staging/rdma/amso1100/ |
| D | c2_mq.c | 67 __raw_writew((__force u16) cpu_to_be16(q->priv), &q->peer->shared); in c2_mq_produce()
108 __raw_writew((__force u16) cpu_to_be16(q->priv), &q->peer->shared); in c2_mq_free()
142 u8 __iomem *pool_start, u16 __iomem *peer, u32 type) in c2_mq_req_init() argument
151 q->peer = (struct c2_mq_shared __iomem *) peer; in c2_mq_req_init()
160 u8 *pool_start, u16 __iomem *peer, u32 type) in c2_mq_rep_init() argument
169 q->peer = (struct c2_mq_shared __iomem *) peer; in c2_mq_rep_init()
|
| /drivers/net/wireless/brcm80211/brcmfmac/ |
| D | proto.h | 38 u8 peer[ETH_ALEN]);
40 u8 peer[ETH_ALEN]);
85 brcmf_proto_delete_peer(struct brcmf_pub *drvr, int ifidx, u8 peer[ETH_ALEN]) in brcmf_proto_delete_peer()
87 drvr->proto->delete_peer(drvr, ifidx, peer); in brcmf_proto_delete_peer()
90 brcmf_proto_add_tdls_peer(struct brcmf_pub *drvr, int ifidx, u8 peer[ETH_ALEN]) in brcmf_proto_add_tdls_peer()
92 drvr->proto->add_tdls_peer(drvr, ifidx, peer); in brcmf_proto_add_tdls_peer()
|
| /drivers/isdn/mISDN/ |
| D | dsp_core.c | 218 if (!dsp->ch.peer) { in dsp_rx_off_member()
226 if (dsp->ch.peer->ctrl(dsp->ch.peer, CONTROL_CHANNEL, &cq)) { in dsp_rx_off_member()
263 if (!dsp->ch.peer) { in dsp_fill_empty()
272 if (dsp->ch.peer->ctrl(dsp->ch.peer, CONTROL_CHANNEL, &cq)) { in dsp_fill_empty()
633 if (!ch->peer) { in get_features()
641 if (ch->peer->ctrl(ch->peer, CONTROL_CHANNEL, &cq) < 0) { in get_features()
655 if (ch->peer->ctrl(ch->peer, CONTROL_CHANNEL, &cq)) { in get_features()
919 if (ch->peer) in dsp_function()
920 return ch->recv(ch->peer, skb); in dsp_function()
939 if (ch->peer) in dsp_function()
[all …]
|
| D | stack.c | 396 dev->teimgr->peer = &newst->own; in create_stack()
401 dev->D.peer = &newst->own; in create_stack()
443 ch->peer = &dev->D.st->own; in connect_layer1()
484 ch->peer = rq.ch; in connect_Bstack()
486 rq.ch->peer = ch; in connect_Bstack()
499 ch->peer = rq2.ch; in connect_Bstack()
509 rq2.ch->peer = rq.ch; in connect_Bstack()
511 rq.ch->peer = rq2.ch; in connect_Bstack()
541 ch->peer = &dev->D.st->own; in create_l2entity()
558 rq.ch->peer = &dev->D.st->own; in create_l2entity()
[all …]
|
| /drivers/misc/vmw_vmci/ |
| D | vmci_queue_pair.c | 176 u32 peer; member
212 u32 peer; member
976 u32 peer, in qp_guest_endpoint_create() argument
997 entry->qp.peer = peer; in qp_guest_endpoint_create()
1062 alloc_msg->peer = entry->qp.peer; in qp_alloc_hypercall()
1193 u32 peer, in qp_alloc_guest_work() argument
1263 queue_pair_entry = qp_guest_endpoint_create(*handle, peer, flags, in qp_alloc_guest_work()
1298 (queue_pair_entry->qp.peer != VMCI_INVALID_ID && in qp_alloc_guest_work()
1299 queue_pair_entry->qp.peer != context_id)) { in qp_alloc_guest_work()
1378 u32 peer, in qp_broker_create() argument
[all …]
|
| /drivers/block/drbd/ |
| D | drbd_state.c | 123 enum drbd_role peer = R_UNKNOWN; in conn_highest_peer() local
130 peer = max_role(peer, device->state.peer); in conn_highest_peer()
134 return peer; in conn_highest_peer()
447 drbd_role_str(ns.peer), in print_st()
480 if (ns.peer != os.peer && flags & CS_DC_PEER) in print_state_change()
482 drbd_role_str(os.peer), in print_state_change()
483 drbd_role_str(ns.peer)); in print_state_change()
567 if (ns.peer == R_PRIMARY) in is_valid_state()
788 ns.peer = R_UNKNOWN; in sanitize_state()
1129 (device->state.pdsk < D_INCONSISTENT && device->state.peer == R_PRIMARY)) in __drbd_set_state()
[all …]
|
| /drivers/staging/lustre/lustre/ptlrpc/ |
| D | connection.c | 48 ptlrpc_connection_get(lnet_process_id_t peer, lnet_nid_t self, in ptlrpc_connection_get() argument
53 conn = cfs_hash_lookup(conn_hash, &peer); in ptlrpc_connection_get()
61 conn->c_peer = peer; in ptlrpc_connection_get()
77 conn2 = cfs_hash_findadd_unique(conn_hash, &peer, &conn->c_hash); in ptlrpc_connection_get()
|