Home
last modified time | relevance | path

Searched refs:client (Results 1 – 25 of 33) sorted by relevance

12

/net/atm/
Dmpoa_caches.c36 struct mpoa_client *client) in in_cache_get() argument
40 read_lock_bh(&client->ingress_lock); in in_cache_get()
41 entry = client->in_cache; in in_cache_get()
45 read_unlock_bh(&client->ingress_lock); in in_cache_get()
50 read_unlock_bh(&client->ingress_lock); in in_cache_get()
56 struct mpoa_client *client, in in_cache_get_with_mask() argument
61 read_lock_bh(&client->ingress_lock); in in_cache_get_with_mask()
62 entry = client->in_cache; in in_cache_get_with_mask()
66 read_unlock_bh(&client->ingress_lock); in in_cache_get_with_mask()
71 read_unlock_bh(&client->ingress_lock); in in_cache_get_with_mask()
[all …]
Dmpoa_caches.h36 struct mpoa_client *client);
37 in_cache_entry *(*get)(__be32 dst_ip, struct mpoa_client *client);
39 struct mpoa_client *client,
42 struct mpoa_client *client);
45 struct mpoa_client *client );
47 struct mpoa_client *client);
48 void (*clear_count)(struct mpoa_client *client);
49 void (*check_resolving)(struct mpoa_client *client);
50 void (*refresh)(struct mpoa_client *client);
68 eg_cache_entry *(*add_entry)(struct k_message *msg, struct mpoa_client *client);
[all …]
Dmpc.c1117 struct mpoa_client *client, in check_qos_and_open_shortcut() argument
1122 eg_cache_entry *eg_entry = client->eg_ops->get_by_src_ip(dst_ip, client); in check_qos_and_open_shortcut()
1135 client->dev->name, &dst_ip); in check_qos_and_open_shortcut()
1136 client->eg_ops->put(eg_entry); in check_qos_and_open_shortcut()
1141 client->eg_ops->put(eg_entry); in check_qos_and_open_shortcut()
1149 client->dev->name); in check_qos_and_open_shortcut()
1152 msg_to_mpoad(msg, client); in check_qos_and_open_shortcut()
1372 struct mpoa_client *client) in set_mps_mac_addr_rcvd() argument
1375 if (client->number_of_mps_macs) in set_mps_mac_addr_rcvd()
1376 kfree(client->mps_macs); in set_mps_mac_addr_rcvd()
[all …]
DKconfig46 network. Besides operating as a normal ATM end station client, Linux
47 LANE client can also act as an proxy client bridging packets between
/net/ceph/
Dceph_common.c105 int ceph_check_fsid(struct ceph_client *client, struct ceph_fsid *fsid) in ceph_check_fsid() argument
107 if (client->have_fsid) { in ceph_check_fsid()
108 if (ceph_fsid_compare(&client->fsid, fsid)) { in ceph_check_fsid()
110 &client->fsid, fsid); in ceph_check_fsid()
114 memcpy(&client->fsid, fsid, sizeof(*fsid)); in ceph_check_fsid()
132 struct ceph_client *client) in ceph_compare_options() argument
135 struct ceph_options *opt2 = client->options; in ceph_compare_options()
144 if (!net_eq(current->nsproxy->net_ns, read_pnet(&client->msgr.net))) in ceph_compare_options()
185 if (ceph_monmap_contains(client->monc.monmap, in ceph_compare_options()
626 int ceph_print_client_options(struct seq_file *m, struct ceph_client *client, in ceph_print_client_options() argument
[all …]
Ddebugfs.c37 struct ceph_client *client = s->private; in monmap_show() local
39 if (client->monc.monmap == NULL) in monmap_show()
42 seq_printf(s, "epoch %d\n", client->monc.monmap->epoch); in monmap_show()
43 for (i = 0; i < client->monc.monmap->num_mon; i++) { in monmap_show()
45 &client->monc.monmap->mon_inst[i]; in monmap_show()
57 struct ceph_client *client = s->private; in osdmap_show() local
58 struct ceph_osd_client *osdc = &client->osdc; in osdmap_show()
90 &client->options->crush_locs)); in osdmap_show()
140 struct ceph_client *client = s->private; in monc_show() local
142 struct ceph_mon_client *monc = &client->monc; in monc_show()
[all …]
Dmon_client.c266 if (ceph_msgr2(monc->client)) { in __open_session()
509 ret = wait_event_interruptible_timeout(monc->client->auth_wq, in ceph_monc_wait_osdmap()
542 struct ceph_client *client = monc->client; in ceph_monc_handle_map() local
552 monmap = ceph_monmap_decode(&p, end, ceph_msgr2(client)); in ceph_monc_handle_map()
560 if (ceph_check_fsid(client, &monmap->fsid) < 0) { in ceph_monc_handle_map()
569 client->have_fsid = true; in ceph_monc_handle_map()
573 wake_up_all(&client->auth_wq); in ceph_monc_handle_map()
1058 return ceph_wait_for_latest_osdmap(monc->client, 0); in ceph_monc_blocklist_add()
1128 __le32 my_type = ceph_msgr2(monc->client) ? in build_initial_monmap()
1130 struct ceph_options *opt = monc->client->options; in build_initial_monmap()
[all …]
Dosd_client.c1097 req->r_flags = flags | osdc->client->options->read_from_replica; in ceph_osdc_new_request()
1220 ceph_con_init(&osd->o_con, osd, &osd_con_ops, &osdc->client->msgr); in create_osd()
1260 osd->lru_ttl = jiffies + osdc->client->options->osd_idle_ttl; in DEFINE_RB_FUNCS()
1497 struct ceph_options *opt = osdc->client->options; in pick_closest_replica()
2309 if (ceph_monc_want_map(&osdc->client->monc, CEPH_SUB_OSDMAP, in maybe_request_map()
2311 ceph_monc_renew_subs(&osdc->client->monc); in maybe_request_map()
2364 if (ceph_test_opt(osdc->client, ABORT_ON_FULL)) { in __submit_request()
2605 if (ceph_test_opt(osdc->client, ABORT_ON_FULL) && in ceph_osdc_abort_on_full()
2646 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in map_check_cb()
2687 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", in send_map_check()
[all …]
Dmessenger_v2.c1364 struct ceph_client *client = from_msgr(con->msgr); in prepare_client_ident() local
1365 u64 global_id = ceph_client_gid(client); in prepare_client_ident()
1388 global_id, con->v2.global_seq, client->supported_features, in prepare_client_ident()
1389 client->required_features, con->v2.client_cookie); in prepare_client_ident()
1404 ceph_encode_64(&p, client->supported_features); in prepare_client_ident()
1405 ceph_encode_64(&p, client->required_features); in prepare_client_ident()
2171 struct ceph_client *client = from_msgr(con->msgr); in process_server_ident() local
2212 if (client->required_features & ~features) { in process_server_ident()
2214 features, client->required_features & ~features); in process_server_ident()
2228 WARN_ON(required_features & ~client->supported_features); in process_server_ident()
[all …]
/net/9p/
Dtrans_fd.c118 struct p9_client *client; member
221 p9_client_cb(m->client, req, REQ_STATUS_ERROR); in p9_conn_cancel()
226 p9_fd_poll(struct p9_client *client, struct poll_table_struct *pt, int *err) in p9_fd_poll() argument
231 if (client && client->status == Connected) in p9_fd_poll()
232 ts = client->trans; in p9_fd_poll()
254 static int p9_fd_read(struct p9_client *client, void *v, int len) in p9_fd_read() argument
260 if (client && client->status != Disconnected) in p9_fd_read()
261 ts = client->trans; in p9_fd_read()
272 client->status = Disconnected; in p9_fd_read()
305 err = p9_fd_read(m->client, m->rc.sdata + m->rc.offset, in p9_read_work()
[all …]
Dtrans_rdma.c295 struct p9_client *client = cq->cq_context; in recv_done() local
296 struct p9_trans_rdma *rdma = client->trans; in recv_done()
304 ib_dma_unmap_single(rdma->cm_id->device, c->busa, client->msize, in recv_done()
315 req = p9_tag_lookup(client, tag); in recv_done()
328 p9_client_cb(client, req, REQ_STATUS_RCVD); in recv_done()
339 client->status = Disconnected; in recv_done()
346 struct p9_client *client = cq->cq_context; in send_done() local
347 struct p9_trans_rdma *rdma = client->trans; in send_done()
355 p9_req_put(client, c->req); in send_done()
386 post_recv(struct p9_client *client, struct p9_rdma_context *c) in post_recv() argument
[all …]
Dtrans_xen.c78 struct p9_client *client; member
88 static int p9_xen_cancel(struct p9_client *client, struct p9_req_t *req) in p9_xen_cancel() argument
93 static int p9_xen_create(struct p9_client *client, const char *addr, char *args) in p9_xen_create() argument
103 priv->client = client; in p9_xen_create()
112 static void p9_xen_close(struct p9_client *client) in p9_xen_close() argument
118 if (priv->client == client) { in p9_xen_close()
119 priv->client = NULL; in p9_xen_close()
139 static int p9_xen_request(struct p9_client *client, struct p9_req_t *p9_req) in p9_xen_request() argument
150 if (priv->client == client) in p9_xen_request()
189 p9_req_put(client, p9_req); in p9_xen_request()
[all …]
Dtrans_virtio.c70 struct p9_client *client; member
106 static void p9_virtio_close(struct p9_client *client) in p9_virtio_close() argument
108 struct virtio_chan *chan = client->trans; in p9_virtio_close()
148 p9_client_cb(chan->client, req, REQ_STATUS_RCVD); in req_done()
194 static int p9_virtio_cancel(struct p9_client *client, struct p9_req_t *req) in p9_virtio_cancel() argument
200 static int p9_virtio_cancelled(struct p9_client *client, struct p9_req_t *req) in p9_virtio_cancelled() argument
202 p9_req_put(client, req); in p9_virtio_cancelled()
256 p9_virtio_request(struct p9_client *client, struct p9_req_t *req) in p9_virtio_request() argument
261 struct virtio_chan *chan = client->trans; in p9_virtio_request()
392 p9_virtio_zc_request(struct p9_client *client, struct p9_req_t *req, in p9_virtio_zc_request() argument
[all …]
DMakefile9 client.o \
/net/wireless/
Dsme.c484 if (!wdev->links[link].client.current_bss) in cfg80211_wdev_release_bsses()
486 cfg80211_unhold_bss(wdev->links[link].client.current_bss); in cfg80211_wdev_release_bsses()
488 &wdev->links[link].client.current_bss->pub); in cfg80211_wdev_release_bsses()
489 wdev->links[link].client.current_bss = NULL; in cfg80211_wdev_release_bsses()
601 wdev->conn->params.ssid = wdev->u.client.ssid; in cfg80211_sme_connect()
602 wdev->conn->params.ssid_len = wdev->u.client.ssid_len; in cfg80211_sme_connect()
818 wdev->u.client.ssid, in __cfg80211_connect_result()
819 wdev->u.client.ssid_len, in __cfg80211_connect_result()
835 wdev->u.client.ssid_len = 0; in __cfg80211_connect_result()
860 wdev->links[link].client.current_bss = in __cfg80211_connect_result()
[all …]
Dwext-sme.c131 if (wdev->links[0].client.current_bss) in cfg80211_mgd_wext_giwfreq()
132 chan = wdev->links[0].client.current_bss->pub.channel; in cfg80211_mgd_wext_giwfreq()
220 if (wdev->links[0].client.current_bss) { in cfg80211_mgd_wext_giwessid()
225 &wdev->links[0].client.current_bss->pub, in cfg80211_mgd_wext_giwessid()
314 if (wdev->links[0].client.current_bss) in cfg80211_mgd_wext_giwap()
316 wdev->links[0].client.current_bss->pub.bssid, in cfg80211_mgd_wext_giwap()
Dmlme.c117 if (!wdev->connected || !ether_addr_equal(wdev->u.client.connected_addr, bssid)) in cfg80211_process_deauth()
138 !ether_addr_equal(wdev->u.client.connected_addr, bssid))) in cfg80211_process_disassoc()
279 ether_addr_equal(req->bss->bssid, wdev->u.client.connected_addr)) in cfg80211_mlme_auth()
340 !ether_addr_equal(wdev->u.client.connected_addr, req->prev_bssid))) in cfg80211_mlme_assoc()
385 !ether_addr_equal(wdev->u.client.connected_addr, bssid))) in cfg80211_mlme_deauth()
390 ether_addr_equal(wdev->u.client.connected_addr, bssid))) in cfg80211_mlme_deauth()
416 if (memcmp(wdev->u.client.connected_addr, ap_addr, ETH_ALEN)) in cfg80211_mlme_disassoc()
442 memcpy(bssid, wdev->u.client.connected_addr, ETH_ALEN); in cfg80211_mlme_down()
727 if (!ether_addr_equal(wdev->u.client.connected_addr, in cfg80211_mlme_mgmt_tx()
734 if (!ether_addr_equal(wdev->u.client.connected_addr, in cfg80211_mlme_mgmt_tx()
Dreg.c633 struct fwdb_wmm_ac client[IEEE80211_NUM_ACS]; member
899 wmm_rule->client[i].cw_min = in set_wmm_rule()
900 ecw2cw((wmm->client[i].ecw & 0xf0) >> 4); in set_wmm_rule()
901 wmm_rule->client[i].cw_max = ecw2cw(wmm->client[i].ecw & 0x0f); in set_wmm_rule()
902 wmm_rule->client[i].aifsn = wmm->client[i].aifsn; in set_wmm_rule()
903 wmm_rule->client[i].cot = in set_wmm_rule()
904 1000 * be16_to_cpu(wmm->client[i].cot); in set_wmm_rule()
1445 reg_wmm_rules_intersect(&wmm_rule1->client[ac], in reg_rules_intersect()
1446 &wmm_rule2->client[ac], in reg_rules_intersect()
1447 &wmm_rule->client[ac]); in reg_rules_intersect()
[all …]
Dwext-compat.c1326 if (!wdev->valid_links && wdev->links[0].client.current_bss) in cfg80211_wext_giwrate()
1327 memcpy(addr, wdev->links[0].client.current_bss->pub.bssid, in cfg80211_wext_giwrate()
1372 if (wdev->valid_links || !wdev->links[0].client.current_bss) { in cfg80211_wireless_stats()
1376 memcpy(bssid, wdev->links[0].client.current_bss->pub.bssid, ETH_ALEN); in cfg80211_wireless_stats()
/net/qrtr/
Dns.c387 pkt.client.node = cpu_to_le32(from->sq_node); in ctrl_cmd_bye()
476 pkt.client.node = cpu_to_le32(node_id); in ctrl_cmd_del_client()
477 pkt.client.port = cpu_to_le32(port); in ctrl_cmd_del_client()
720 le32_to_cpu(pkt->client.node), in qrtr_ns_worker()
721 le32_to_cpu(pkt->client.port)); in qrtr_ns_worker()
Daf_qrtr.c222 u64 remote_node = le32_to_cpu(pkt->client.node); in qrtr_tx_resume()
223 u32 remote_port = le32_to_cpu(pkt->client.port); in qrtr_tx_resume()
699 pkt->client.node = cpu_to_le32(ipc->us.sq_node); in qrtr_port_remove()
700 pkt->client.port = cpu_to_le32(ipc->us.sq_port); in qrtr_port_remove()
1016 pkt->client.node = cpu_to_le32(cb->dst_node); in qrtr_send_resume_tx()
1017 pkt->client.port = cpu_to_le32(cb->dst_port); in qrtr_send_resume_tx()
/net/batman-adv/
Dtranslation-table.c65 static void batadv_send_roam_adv(struct batadv_priv *bat_priv, u8 *client,
3460 static bool batadv_tt_check_roam_count(struct batadv_priv *bat_priv, u8 *client) in batadv_tt_check_roam_count() argument
3470 if (!batadv_compare_eth(tt_roam_node->addr, client)) in batadv_tt_check_roam_count()
3493 ether_addr_copy(tt_roam_node->addr, client); in batadv_tt_check_roam_count()
3516 static void batadv_send_roam_adv(struct batadv_priv *bat_priv, u8 *client, in batadv_send_roam_adv() argument
3530 if (!batadv_tt_check_roam_count(bat_priv, client)) in batadv_send_roam_adv()
3535 orig_node->orig, client, batadv_print_vid(vid)); in batadv_send_roam_adv()
3539 memcpy(tvlv_roam.client, client, sizeof(tvlv_roam.client)); in batadv_send_roam_adv()
4135 src, roaming_adv->client); in batadv_roam_tvlv_unicast_handler_v1()
4137 batadv_tt_global_add(bat_priv, orig_node, roaming_adv->client, in batadv_roam_tvlv_unicast_handler_v1()
/net/rxrpc/
DKconfig19 This module at the moment only supports client operations and is
/net/sunrpc/
DKconfig73 This option allows the NFS client and server to use RDMA
/net/sunrpc/auth_gss/
Dauth_gss.c74 struct rpc_clnt *client; member
1030 gss_auth->client = clnt; in gss_create_new()
1166 if (gss_auth->client != clnt) in gss_auth_find_or_add_hashed()
1277 task = rpc_call_null(gss_auth->client, &new->gc_base, in gss_send_destroy_context()

12