| /net/ceph/ |
| D | ceph_common.c | 97 int ceph_check_fsid(struct ceph_client *client, struct ceph_fsid *fsid) in ceph_check_fsid() argument
99 if (client->have_fsid) { in ceph_check_fsid()
100 if (ceph_fsid_compare(&client->fsid, fsid)) { in ceph_check_fsid()
102 &client->fsid, fsid); in ceph_check_fsid()
106 memcpy(&client->fsid, fsid, sizeof(*fsid)); in ceph_check_fsid()
124 struct ceph_client *client) in ceph_compare_options() argument
127 struct ceph_options *opt2 = client->options; in ceph_compare_options()
136 if (!net_eq(current->nsproxy->net_ns, read_pnet(&client->msgr.net))) in ceph_compare_options()
173 if (ceph_monmap_contains(client->monc.monmap, in ceph_compare_options()
543 int ceph_print_client_options(struct seq_file *m, struct ceph_client *client) in ceph_print_client_options() argument
[all …]
|
| D | debugfs.c | 37 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()
138 struct ceph_client *client = s->private; in monc_show() local
140 struct ceph_mon_client *monc = &client->monc; in monc_show()
339 struct ceph_client *client = s->private; in osdc_show() local
[all …]
|
| D | mon_client.c | 425 ret = wait_event_interruptible_timeout(monc->client->auth_wq, in ceph_monc_wait_osdmap()
458 struct ceph_client *client = monc->client; in ceph_monc_handle_map() local
475 if (ceph_check_fsid(monc->client, &monmap->fsid) < 0) { in ceph_monc_handle_map()
480 client->monc.monmap = monmap; in ceph_monc_handle_map()
484 client->have_fsid = true; in ceph_monc_handle_map()
488 wake_up_all(&client->auth_wq); in ceph_monc_handle_map()
932 ret = ceph_wait_for_latest_osdmap(monc->client, 0); in ceph_monc_blacklist_add()
1006 struct ceph_options *opt = monc->client->options; in build_initial_monmap()
1034 monc->client = cl; in ceph_monc_init()
1078 &monc->client->msgr); in ceph_monc_init()
[all …]
|
| D | osd_client.c | 1057 ceph_con_init(&osd->o_con, osd, &osd_con_ops, &osdc->client->msgr); in create_osd()
1097 osd->lru_ttl = jiffies + osdc->client->options->osd_idle_ttl; in DEFINE_RB_FUNCS()
2091 if (ceph_monc_want_map(&osdc->client->monc, CEPH_SUB_OSDMAP, in maybe_request_map()
2093 ceph_monc_renew_subs(&osdc->client->monc); in maybe_request_map()
2406 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in map_check_cb()
2447 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", in send_map_check()
2990 struct ceph_osd_client *osdc = &greq->monc->client->osdc; in linger_map_check_cb()
3033 ret = ceph_monc_get_version_async(&osdc->client->monc, "osdmap", in send_linger_map_check()
3066 struct ceph_options *opts = osdc->client->options; in handle_timeout()
3148 osdc->client->options->osd_keepalive_timeout); in handle_timeout()
[all …]
|
| /net/atm/ |
| D | mpoa_caches.c | 36 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 …]
|
| D | mpoa_caches.h | 35 struct mpoa_client *client);
36 in_cache_entry *(*get)(__be32 dst_ip, struct mpoa_client *client);
38 struct mpoa_client *client,
41 struct mpoa_client *client);
44 struct mpoa_client *client );
46 struct mpoa_client *client);
47 void (*clear_count)(struct mpoa_client *client);
48 void (*check_resolving)(struct mpoa_client *client);
49 void (*refresh)(struct mpoa_client *client);
67 eg_cache_entry *(*add_entry)(struct k_message *msg, struct mpoa_client *client);
[all …]
|
| D | mpc.c | 1117 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()
1371 struct mpoa_client *client) in set_mps_mac_addr_rcvd() argument
1374 if (client->number_of_mps_macs) in set_mps_mac_addr_rcvd()
1375 kfree(client->mps_macs); in set_mps_mac_addr_rcvd()
[all …]
|
| D | Kconfig | 45 network. Besides operating as a normal ATM end station client, Linux
46 LANE client can also act as an proxy client bridging packets between
|
| /net/9p/ |
| D | trans_fd.c | 130 struct p9_client *client; member
206 spin_lock(&m->client->lock); in p9_conn_cancel()
209 spin_unlock(&m->client->lock); in p9_conn_cancel()
227 p9_client_cb(m->client, req, REQ_STATUS_ERROR); in p9_conn_cancel()
229 spin_unlock(&m->client->lock); in p9_conn_cancel()
233 p9_fd_poll(struct p9_client *client, struct poll_table_struct *pt) in p9_fd_poll() argument
238 if (client && client->status == Connected) in p9_fd_poll()
239 ts = client->trans; in p9_fd_poll()
272 static int p9_fd_read(struct p9_client *client, void *v, int len) in p9_fd_read() argument
278 if (client && client->status != Disconnected) in p9_fd_read()
[all …]
|
| D | trans_rdma.c | 309 struct p9_client *client = cq->cq_context; in recv_done() local
310 struct p9_trans_rdma *rdma = client->trans; in recv_done()
318 ib_dma_unmap_single(rdma->cm_id->device, c->busa, client->msize, in recv_done()
328 req = p9_tag_lookup(client, tag); in recv_done()
340 p9_client_cb(client, req, REQ_STATUS_RCVD); in recv_done()
351 client->status = Disconnected; in recv_done()
358 struct p9_client *client = cq->cq_context; in send_done() local
359 struct p9_trans_rdma *rdma = client->trans; in send_done()
397 post_recv(struct p9_client *client, struct p9_rdma_context *c) in post_recv() argument
399 struct p9_trans_rdma *rdma = client->trans; in post_recv()
[all …]
|
| D | trans_xen.c | 79 struct p9_client *client; member
89 static int p9_xen_cancel(struct p9_client *client, struct p9_req_t *req) in p9_xen_cancel() argument
94 static int p9_xen_create(struct p9_client *client, const char *addr, char *args) in p9_xen_create() argument
104 priv->client = client; in p9_xen_create()
113 static void p9_xen_close(struct p9_client *client) in p9_xen_close() argument
119 if (priv->client == client) { in p9_xen_close()
120 priv->client = NULL; in p9_xen_close()
140 static int p9_xen_request(struct p9_client *client, struct p9_req_t *p9_req) in p9_xen_request() argument
151 if (priv->client == client) in p9_xen_request()
155 if (!priv || priv->client != client) in p9_xen_request()
[all …]
|
| D | trans_virtio.c | 82 struct p9_client *client; member
120 static void p9_virtio_close(struct p9_client *client) in p9_virtio_close() argument
122 struct virtio_chan *chan = client->trans; in p9_virtio_close()
164 p9_client_cb(chan->client, req, REQ_STATUS_RCVD); in req_done()
205 static int p9_virtio_cancel(struct p9_client *client, struct p9_req_t *req) in p9_virtio_cancel() argument
259 p9_virtio_request(struct p9_client *client, struct p9_req_t *req) in p9_virtio_request() argument
264 struct virtio_chan *chan = client->trans; in p9_virtio_request()
394 p9_virtio_zc_request(struct p9_client *client, struct p9_req_t *req, in p9_virtio_zc_request() argument
402 struct virtio_chan *chan = client->trans; in p9_virtio_zc_request()
649 p9_virtio_create(struct p9_client *client, const char *devname, char *args) in p9_virtio_create() argument
[all …]
|
| D | Makefile | 9 client.o \
|
| /net/batman-adv/ |
| D | icmp_socket.c | 107 struct batadv_socket_client *client = file->private_data; in batadv_socket_release() local
110 spin_lock_bh(&client->lock); in batadv_socket_release()
113 list_for_each_entry_safe(packet, tmp, &client->queue_list, list) { in batadv_socket_release()
118 batadv_socket_client_hash[client->index] = NULL; in batadv_socket_release()
119 spin_unlock_bh(&client->lock); in batadv_socket_release()
121 kfree(client); in batadv_socket_release()
|
| D | translation-table.c | 76 static void batadv_send_roam_adv(struct batadv_priv *bat_priv, u8 *client,
3691 static bool batadv_tt_check_roam_count(struct batadv_priv *bat_priv, u8 *client) in batadv_tt_check_roam_count() argument
3701 if (!batadv_compare_eth(tt_roam_node->addr, client)) in batadv_tt_check_roam_count()
3724 ether_addr_copy(tt_roam_node->addr, client); in batadv_tt_check_roam_count()
3747 static void batadv_send_roam_adv(struct batadv_priv *bat_priv, u8 *client, in batadv_send_roam_adv() argument
3761 if (!batadv_tt_check_roam_count(bat_priv, client)) in batadv_send_roam_adv()
3766 orig_node->orig, client, batadv_print_vid(vid)); in batadv_send_roam_adv()
3770 memcpy(tvlv_roam.client, client, sizeof(tvlv_roam.client)); in batadv_send_roam_adv()
4344 src, roaming_adv->client); in batadv_roam_tvlv_unicast_handler_v1()
4346 batadv_tt_global_add(bat_priv, orig_node, roaming_adv->client, in batadv_roam_tvlv_unicast_handler_v1()
|
| D | packet.h | 607 u8 client[ETH_ALEN]; member
|
| /net/rxrpc/ |
| D | Kconfig | 17 This module at the moment only supports client operations and is
|
| D | key.c | 194 rxrpc_free_krb5_principal(&rxk5->client); in rxrpc_rxk5_free()
463 ret = rxrpc_krb5_decode_principal(&rxk5->client, &xdr, &toklen); in rxrpc_preparse_xdr_rxk5()
1084 princ = &token->k5->client; in rxrpc_read()
1184 princ = &token->k5->client; in rxrpc_read()
|
| /net/sunrpc/ |
| D | Kconfig | 57 This option allows the NFS client and server to use RDMA
|
| /net/ipx/ |
| D | Kconfig | 11 Novell client ncpfs (available from
|
| /net/sunrpc/auth_gss/ |
| D | auth_gss.c | 95 struct rpc_clnt *client; member
1009 gss_auth->client = clnt; in gss_create_new()
1147 if (gss_auth->client != clnt) in gss_auth_find_or_add_hashed()
1234 task = rpc_call_null(gss_auth->client, cred, RPC_TASK_ASYNC|RPC_TASK_SOFT); in gss_destroying_context()
|
| /net/wireless/ |
| D | Kconfig | 113 scenarios, this relaxation is not allowed in cases where the BSS client
|
| /net/caif/ |
| D | cfctrl.c | 305 struct cflayer *client) in cfctrl_linkdown_req() argument
|
| /net/netfilter/ |
| D | Kconfig | 334 If you are using a tftp client behind -j SNAT or -j MASQUERADING
1125 connections to a server per client IP address (or address block).
|