Home
last modified time | relevance | path

Searched refs:pool (Results 1 – 13 of 13) sorted by relevance

/net/ceph/
Dmsgpool.c12 struct ceph_msgpool *pool = arg; in msgpool_alloc() local
15 msg = ceph_msg_new(pool->type, pool->front_len, gfp_mask, true); in msgpool_alloc()
17 dout("msgpool_alloc %s failed\n", pool->name); in msgpool_alloc()
19 dout("msgpool_alloc %s %p\n", pool->name, msg); in msgpool_alloc()
20 msg->pool = pool; in msgpool_alloc()
27 struct ceph_msgpool *pool = arg; in msgpool_free() local
30 dout("msgpool_release %s %p\n", pool->name, msg); in msgpool_free()
31 msg->pool = NULL; in msgpool_free()
35 int ceph_msgpool_init(struct ceph_msgpool *pool, int type, in ceph_msgpool_init() argument
39 pool->type = type; in ceph_msgpool_init()
[all …]
Dosdmap.c350 if (l.pool < r.pool) in pgid_cmp()
352 if (l.pool > r.pool) in pgid_cmp()
403 pgid.pool, pgid.seed, pg); in __lookup_pg_mapping()
415 dout("__remove_pg_mapping %lld.%x %p\n", pgid.pool, pgid.seed, in __remove_pg_mapping()
421 dout("__remove_pg_mapping %lld.%x dne\n", pgid.pool, pgid.seed); in __remove_pg_mapping()
567 u64 pool; in __decode_pool_names() local
572 ceph_decode_64_safe(p, end, pool, bad); in __decode_pool_names()
574 dout(" pool %llu len %d\n", pool, len); in __decode_pool_names()
576 pi = __lookup_pg_pool(&map->pg_pools, pool); in __decode_pool_names()
771 dout(" added pg_temp %lld.%x len %d\n", pgid.pool, pgid.seed, in osdmap_decode()
[all …]
Ddebugfs.c67 struct ceph_pg_pool_info *pool = in osdmap_show() local
70 (unsigned long long)pool->id, pool->pg_num, in osdmap_show()
71 pool->pg_num_mask); in osdmap_show()
133 req->r_pgid.pool, req->r_pgid.seed); in osdc_show()
Dmon_client.c641 u32 pool, u64 snapid, in do_poolop() argument
674 h->pool = cpu_to_le32(pool); in do_poolop()
688 u32 pool, u64 *snapid) in ceph_monc_create_snapid() argument
691 pool, 0, (char *)snapid, sizeof(*snapid)); in ceph_monc_create_snapid()
697 u32 pool, u64 snapid) in ceph_monc_delete_snapid() argument
700 pool, snapid, NULL, 0); in ceph_monc_delete_snapid()
Dosd_client.c1271 req->r_tid, pgid.pool, pgid.seed, o, in __map_request()
1324 (unsigned long long)req->r_pgid.pool, req->r_pgid.seed); in __send_request()
1329 put_unaligned_le64(req->r_pgid.pool, req->r_request_pool); in __send_request()
1331 ceph_encode_64(&p, req->r_pgid.pool); in __send_request()
Dmessenger.c3295 if (m->pool) in ceph_msg_last_put()
3296 ceph_msgpool_put(m->pool, m); in ceph_msg_last_put()
/net/rds/
Dib_rdma.c49 struct rds_ib_mr_pool *pool; member
86 static int rds_ib_flush_mr_pool(struct rds_ib_mr_pool *pool, int free_all, struct rds_ib_mr **);
217 struct rds_ib_mr_pool *pool; in rds_ib_create_mr_pool() local
219 pool = kzalloc(sizeof(*pool), GFP_KERNEL); in rds_ib_create_mr_pool()
220 if (!pool) in rds_ib_create_mr_pool()
223 init_llist_head(&pool->free_list); in rds_ib_create_mr_pool()
224 init_llist_head(&pool->drop_list); in rds_ib_create_mr_pool()
225 init_llist_head(&pool->clean_list); in rds_ib_create_mr_pool()
226 mutex_init(&pool->flush_lock); in rds_ib_create_mr_pool()
227 init_waitqueue_head(&pool->flush_wait); in rds_ib_create_mr_pool()
[all …]
Diw_rdma.c46 struct rds_iw_mr_pool *pool; member
78 static int rds_iw_flush_mr_pool(struct rds_iw_mr_pool *pool, int free_all);
80 static int rds_iw_init_fastreg(struct rds_iw_mr_pool *pool, struct rds_iw_mr *ibmr);
81 static int rds_iw_map_fastreg(struct rds_iw_mr_pool *pool,
84 static void rds_iw_free_fastreg(struct rds_iw_mr_pool *pool, struct rds_iw_mr *ibmr);
85 static unsigned int rds_iw_unmap_fastreg_list(struct rds_iw_mr_pool *pool,
89 static void rds_iw_destroy_fastreg(struct rds_iw_mr_pool *pool, struct rds_iw_mr *ibmr);
340 struct rds_iw_mr_pool *pool; local
342 pool = kzalloc(sizeof(*pool), GFP_KERNEL);
343 if (!pool) {
[all …]
/net/sunrpc/
Dsvc_xprt.c316 static void svc_thread_enqueue(struct svc_pool *pool, struct svc_rqst *rqstp) in svc_thread_enqueue() argument
318 list_add(&rqstp->rq_list, &pool->sp_threads); in svc_thread_enqueue()
324 static void svc_thread_dequeue(struct svc_pool *pool, struct svc_rqst *rqstp) in svc_thread_dequeue() argument
345 struct svc_pool *pool; in svc_xprt_enqueue() local
353 pool = svc_pool_for_cpu(xprt->xpt_server, cpu); in svc_xprt_enqueue()
356 spin_lock_bh(&pool->sp_lock); in svc_xprt_enqueue()
358 if (!list_empty(&pool->sp_threads) && in svc_xprt_enqueue()
359 !list_empty(&pool->sp_sockets)) in svc_xprt_enqueue()
364 pool->sp_stats.packets++; in svc_xprt_enqueue()
377 if (!list_empty(&pool->sp_threads)) { in svc_xprt_enqueue()
[all …]
Dsvc.c471 struct svc_pool *pool = &serv->sv_pools[i]; in __svc_create() local
476 pool->sp_id = i; in __svc_create()
477 INIT_LIST_HEAD(&pool->sp_threads); in __svc_create()
478 INIT_LIST_HEAD(&pool->sp_sockets); in __svc_create()
479 INIT_LIST_HEAD(&pool->sp_all_threads); in __svc_create()
480 spin_lock_init(&pool->sp_lock); in __svc_create()
607 svc_prepare_thread(struct svc_serv *serv, struct svc_pool *pool, int node) in svc_prepare_thread() argument
618 spin_lock_bh(&pool->sp_lock); in svc_prepare_thread()
619 pool->sp_nrthreads++; in svc_prepare_thread()
620 list_add(&rqstp->rq_all, &pool->sp_all_threads); in svc_prepare_thread()
[all …]
/net/9p/
Dutil.c45 struct idr pool; member
62 idr_init(&p->pool); in p9_idpool_create()
75 idr_destroy(&p->pool); in p9_idpool_destroy()
97 i = idr_alloc(&p->pool, p, 0, 0, GFP_NOWAIT); in p9_idpool_get()
125 idr_remove(&p->pool, id); in p9_idpool_put()
138 return idr_find(&p->pool, id) != NULL; in p9_idpool_check()
/net/ipv4/
Dtcp.c3141 static void __tcp_free_md5sig_pool(struct tcp_md5sig_pool __percpu *pool) in __tcp_free_md5sig_pool() argument
3146 struct tcp_md5sig_pool *p = per_cpu_ptr(pool, cpu); in __tcp_free_md5sig_pool()
3151 free_percpu(pool); in __tcp_free_md5sig_pool()
3156 struct tcp_md5sig_pool __percpu *pool = NULL; in tcp_free_md5sig_pool() local
3160 pool = tcp_md5sig_pool; in tcp_free_md5sig_pool()
3164 if (pool) in tcp_free_md5sig_pool()
3165 __tcp_free_md5sig_pool(pool); in tcp_free_md5sig_pool()
3173 struct tcp_md5sig_pool __percpu *pool; in __tcp_alloc_md5sig_pool() local
3175 pool = alloc_percpu(struct tcp_md5sig_pool); in __tcp_alloc_md5sig_pool()
3176 if (!pool) in __tcp_alloc_md5sig_pool()
[all …]
/net/bridge/netfilter/
Debt_among.c36 p = &wh->pool[i]; in ebt_mac_wormhash_contains()
43 p = &wh->pool[i]; in ebt_mac_wormhash_contains()