/net/ceph/ |
D | msgpool.c | 12 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 …]
|
D | osdmap.c | 350 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 …]
|
D | debugfs.c | 67 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()
|
D | mon_client.c | 641 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()
|
D | osd_client.c | 1271 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()
|
D | messenger.c | 3295 if (m->pool) in ceph_msg_last_put() 3296 ceph_msgpool_put(m->pool, m); in ceph_msg_last_put()
|
/net/rds/ |
D | ib_rdma.c | 49 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 …]
|
D | iw_rdma.c | 46 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/ |
D | svc_xprt.c | 316 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 …]
|
D | svc.c | 471 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/ |
D | util.c | 45 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/ |
D | tcp.c | 3141 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/ |
D | ebt_among.c | 36 p = &wh->pool[i]; in ebt_mac_wormhash_contains() 43 p = &wh->pool[i]; in ebt_mac_wormhash_contains()
|