Home
last modified time | relevance | path

Searched refs:client (Results 1 – 25 of 27) 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()
583 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.c438 ret = wait_event_interruptible_timeout(monc->client->auth_wq, in ceph_monc_wait_osdmap()
471 struct ceph_client *client = monc->client; in ceph_monc_handle_map() local
489 if (ceph_check_fsid(client, &monmap->fsid) < 0) { in ceph_monc_handle_map()
498 client->have_fsid = true; in ceph_monc_handle_map()
502 wake_up_all(&client->auth_wq); in ceph_monc_handle_map()
987 return ceph_wait_for_latest_osdmap(monc->client, 0); in ceph_monc_blocklist_add()
1057 struct ceph_options *opt = monc->client->options; in build_initial_monmap()
1084 monc->client = cl; in ceph_monc_init()
1128 &monc->client->msgr); in ceph_monc_init()
1220 monc->client->auth_err = ret; in handle_auth_reply()
[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 …]
/net/9p/
Dtrans_fd.c115 struct p9_client *client; member
192 spin_lock(&m->client->lock); in p9_conn_cancel()
195 spin_unlock(&m->client->lock); in p9_conn_cancel()
210 spin_unlock(&m->client->lock); in p9_conn_cancel()
217 p9_client_cb(m->client, req, REQ_STATUS_ERROR); in p9_conn_cancel()
222 p9_fd_poll(struct p9_client *client, struct poll_table_struct *pt, int *err) in p9_fd_poll() argument
227 if (client && client->status == Connected) in p9_fd_poll()
228 ts = client->trans; in p9_fd_poll()
250 static int p9_fd_read(struct p9_client *client, void *v, int len) in p9_fd_read() argument
256 if (client && client->status != Disconnected) in p9_fd_read()
[all …]
Dtrans_rdma.c293 struct p9_client *client = cq->cq_context; in recv_done() local
294 struct p9_trans_rdma *rdma = client->trans; in recv_done()
302 ib_dma_unmap_single(rdma->cm_id->device, c->busa, client->msize, in recv_done()
313 req = p9_tag_lookup(client, tag); in recv_done()
326 p9_client_cb(client, req, REQ_STATUS_RCVD); in recv_done()
337 client->status = Disconnected; in recv_done()
344 struct p9_client *client = cq->cq_context; in send_done() local
345 struct p9_trans_rdma *rdma = client->trans; in send_done()
384 post_recv(struct p9_client *client, struct p9_rdma_context *c) in post_recv() argument
386 struct p9_trans_rdma *rdma = client->trans; in post_recv()
[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()
225 req = p9_tag_lookup(priv->client, h.tag); in p9_xen_response()
[all …]
Dtrans_virtio.c66 struct p9_client *client; member
102 static void p9_virtio_close(struct p9_client *client) in p9_virtio_close() argument
104 struct virtio_chan *chan = client->trans; in p9_virtio_close()
144 p9_client_cb(chan->client, req, REQ_STATUS_RCVD); in req_done()
190 static int p9_virtio_cancel(struct p9_client *client, struct p9_req_t *req) in p9_virtio_cancel() argument
196 static int p9_virtio_cancelled(struct p9_client *client, struct p9_req_t *req) in p9_virtio_cancelled() argument
251 p9_virtio_request(struct p9_client *client, struct p9_req_t *req) in p9_virtio_request() argument
256 struct virtio_chan *chan = client->trans; in p9_virtio_request()
387 p9_virtio_zc_request(struct p9_client *client, struct p9_req_t *req, in p9_virtio_zc_request() argument
395 struct virtio_chan *chan = client->trans; in p9_virtio_zc_request()
[all …]
DMakefile9 client.o \
/net/batman-adv/
Dicmp_socket.c104 struct batadv_socket_client *client = file->private_data; in batadv_socket_release() local
107 spin_lock_bh(&client->lock); in batadv_socket_release()
110 list_for_each_entry_safe(packet, tmp, &client->queue_list, list) { in batadv_socket_release()
115 batadv_socket_client_hash[client->index] = NULL; in batadv_socket_release()
116 spin_unlock_bh(&client->lock); in batadv_socket_release()
118 kfree(client); in batadv_socket_release()
Dtranslation-table.c66 static void batadv_send_roam_adv(struct batadv_priv *bat_priv, u8 *client,
3699 static bool batadv_tt_check_roam_count(struct batadv_priv *bat_priv, u8 *client) in batadv_tt_check_roam_count() argument
3709 if (!batadv_compare_eth(tt_roam_node->addr, client)) in batadv_tt_check_roam_count()
3732 ether_addr_copy(tt_roam_node->addr, client); in batadv_tt_check_roam_count()
3755 static void batadv_send_roam_adv(struct batadv_priv *bat_priv, u8 *client, in batadv_send_roam_adv() argument
3769 if (!batadv_tt_check_roam_count(bat_priv, client)) in batadv_send_roam_adv()
3774 orig_node->orig, client, batadv_print_vid(vid)); in batadv_send_roam_adv()
3778 memcpy(tvlv_roam.client, client, sizeof(tvlv_roam.client)); in batadv_send_roam_adv()
4375 src, roaming_adv->client); in batadv_roam_tvlv_unicast_handler_v1()
4377 batadv_tt_global_add(bat_priv, orig_node, roaming_adv->client, in batadv_roam_tvlv_unicast_handler_v1()
/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()
728 le32_to_cpu(pkt->client.node), in qrtr_ns_worker()
729 le32_to_cpu(pkt->client.port)); in qrtr_ns_worker()
Daf_qrtr.c217 u64 remote_node = le32_to_cpu(pkt->client.node); in qrtr_tx_resume()
218 u32 remote_port = le32_to_cpu(pkt->client.port); in qrtr_tx_resume()
683 pkt->client.node = cpu_to_le32(ipc->us.sq_node); in qrtr_port_remove()
684 pkt->client.port = cpu_to_le32(ipc->us.sq_port); in qrtr_port_remove()
1000 pkt->client.node = cpu_to_le32(cb->dst_node); in qrtr_send_resume_tx()
1001 pkt->client.port = cpu_to_le32(cb->dst_port); in qrtr_send_resume_tx()
/net/wireless/
Dreg.c613 struct fwdb_wmm_ac client[IEEE80211_NUM_ACS]; member
879 wmm_rule->client[i].cw_min = in set_wmm_rule()
880 ecw2cw((wmm->client[i].ecw & 0xf0) >> 4); in set_wmm_rule()
881 wmm_rule->client[i].cw_max = ecw2cw(wmm->client[i].ecw & 0x0f); in set_wmm_rule()
882 wmm_rule->client[i].aifsn = wmm->client[i].aifsn; in set_wmm_rule()
883 wmm_rule->client[i].cot = in set_wmm_rule()
884 1000 * be16_to_cpu(wmm->client[i].cot); in set_wmm_rule()
1403 reg_wmm_rules_intersect(&wmm_rule1->client[ac], in reg_rules_intersect()
1404 &wmm_rule2->client[ac], in reg_rules_intersect()
1405 &wmm_rule->client[ac]); in reg_rules_intersect()
DKconfig153 scenarios, this relaxation is not allowed in cases where the BSS client
/net/rxrpc/
DKconfig18 This module at the moment only supports client operations and is
Dkey.c192 rxrpc_free_krb5_principal(&rxk5->client); in rxrpc_rxk5_free()
461 ret = rxrpc_krb5_decode_principal(&rxk5->client, &xdr, &toklen); in rxrpc_preparse_xdr_rxk5()
1081 princ = &token->k5->client; in rxrpc_read()
1185 princ = &token->k5->client; in rxrpc_read()
/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()
/net/caif/
Dcfctrl.c309 struct cflayer *client) in cfctrl_linkdown_req() argument
/net/netfilter/
DKconfig350 If you are using a tftp client behind -j SNAT or -j MASQUERADING
1197 connections to a server per client IP address (or address block).

12