staging: lustre: ptlrpc: Use kzalloc and kfree
authorJulia Lawall <Julia.Lawall@lip6.fr>
Fri, 1 May 2015 15:51:12 +0000 (17:51 +0200)
committerGreg Kroah-Hartman <gregkh@linuxfoundation.org>
Fri, 8 May 2015 07:23:50 +0000 (09:23 +0200)
Replace OBD_ALLOC, OBD_ALLOC_WAIT, OBD_ALLOC_PTR, and OBD_ALLOC_PTR_WAIT by
kalloc/kcalloc, and OBD_FREE and OBD_FREE_PTR by kfree.

A simplified version of the semantic patch that makes these changes is as
follows: (http://coccinelle.lip6.fr/)

// <smpl>
@@ expression ptr,size; @@
- OBD_ALLOC(ptr,size)
+ ptr = kzalloc(size, GFP_NOFS)

@@ expression ptr, size; @@
- OBD_FREE(ptr, size);
+ kfree(ptr);
// </smpl>

Signed-off-by: Julia Lawall <Julia.Lawall@lip6.fr>
Signed-off-by: Greg Kroah-Hartman <gregkh@linuxfoundation.org>
12 files changed:
drivers/staging/lustre/lustre/ptlrpc/client.c
drivers/staging/lustre/lustre/ptlrpc/connection.c
drivers/staging/lustre/lustre/ptlrpc/lproc_ptlrpc.c
drivers/staging/lustre/lustre/ptlrpc/nrs.c
drivers/staging/lustre/lustre/ptlrpc/nrs_fifo.c
drivers/staging/lustre/lustre/ptlrpc/pinger.c
drivers/staging/lustre/lustre/ptlrpc/ptlrpcd.c
drivers/staging/lustre/lustre/ptlrpc/sec.c
drivers/staging/lustre/lustre/ptlrpc/sec_bulk.c
drivers/staging/lustre/lustre/ptlrpc/sec_config.c
drivers/staging/lustre/lustre/ptlrpc/sec_plain.c
drivers/staging/lustre/lustre/ptlrpc/service.c

index 0357f1d4532f3763b5601ccbdad857a9ba6392af..45b7af77c37e8cc58c1f58cd6ba0131b8b93e248 100644 (file)
@@ -103,7 +103,8 @@ struct ptlrpc_bulk_desc *ptlrpc_new_bulk(unsigned npages, unsigned max_brw,
        struct ptlrpc_bulk_desc *desc;
        int i;
 
-       OBD_ALLOC(desc, offsetof(struct ptlrpc_bulk_desc, bd_iov[npages]));
+       desc = kzalloc(offsetof(struct ptlrpc_bulk_desc, bd_iov[npages]),
+                      GFP_NOFS);
        if (!desc)
                return NULL;
 
@@ -205,8 +206,7 @@ void __ptlrpc_free_bulk(struct ptlrpc_bulk_desc *desc, int unpin)
                        page_cache_release(desc->bd_iov[i].kiov_page);
        }
 
-       OBD_FREE(desc, offsetof(struct ptlrpc_bulk_desc,
-                               bd_iov[desc->bd_max_iov]));
+       kfree(desc);
 }
 EXPORT_SYMBOL(__ptlrpc_free_bulk);
 
@@ -439,7 +439,7 @@ void ptlrpc_free_rq_pool(struct ptlrpc_request_pool *pool)
                ptlrpc_request_cache_free(req);
        }
        spin_unlock(&pool->prp_lock);
-       OBD_FREE(pool, sizeof(*pool));
+       kfree(pool);
 }
 EXPORT_SYMBOL(ptlrpc_free_rq_pool);
 
@@ -498,7 +498,7 @@ ptlrpc_init_rq_pool(int num_rq, int msgsize,
 {
        struct ptlrpc_request_pool *pool;
 
-       OBD_ALLOC(pool, sizeof(struct ptlrpc_request_pool));
+       pool = kzalloc(sizeof(struct ptlrpc_request_pool), GFP_NOFS);
        if (!pool)
                return NULL;
 
@@ -514,7 +514,7 @@ ptlrpc_init_rq_pool(int num_rq, int msgsize,
 
        if (list_empty(&pool->prp_req_list)) {
                /* have not allocated a single request for the pool */
-               OBD_FREE(pool, sizeof(struct ptlrpc_request_pool));
+               kfree(pool);
                pool = NULL;
        }
        return pool;
@@ -856,7 +856,7 @@ struct ptlrpc_request_set *ptlrpc_prep_set(void)
 {
        struct ptlrpc_request_set *set;
 
-       OBD_ALLOC(set, sizeof(*set));
+       set = kzalloc(sizeof(*set), GFP_NOFS);
        if (!set)
                return NULL;
        atomic_set(&set->set_refcount, 1);
@@ -970,7 +970,7 @@ int ptlrpc_set_add_cb(struct ptlrpc_request_set *set,
 {
        struct ptlrpc_set_cbdata *cbdata;
 
-       OBD_ALLOC_PTR(cbdata);
+       cbdata = kzalloc(sizeof(*cbdata), GFP_NOFS);
        if (cbdata == NULL)
                return -ENOMEM;
 
@@ -2214,7 +2214,7 @@ int ptlrpc_set_wait(struct ptlrpc_request_set *set)
                        err = cbdata->psc_interpret(set, cbdata->psc_data, rc);
                        if (err && !rc)
                                rc = err;
-                       OBD_FREE_PTR(cbdata);
+                       kfree(cbdata);
                }
        }
 
index 7e27397ce384c258976d53bed4e84a1c39801234..ffe36e22245febe10cf080302da23a35c195bfd9 100644 (file)
@@ -54,7 +54,7 @@ ptlrpc_connection_get(lnet_process_id_t peer, lnet_nid_t self,
        if (conn)
                goto out;
 
-       OBD_ALLOC_PTR(conn);
+       conn = kzalloc(sizeof(*conn), GFP_NOFS);
        if (!conn)
                return NULL;
 
@@ -76,7 +76,7 @@ ptlrpc_connection_get(lnet_process_id_t peer, lnet_nid_t self,
        /* coverity[overrun-buffer-val] */
        conn2 = cfs_hash_findadd_unique(conn_hash, &peer, &conn->c_hash);
        if (conn != conn2) {
-               OBD_FREE_PTR(conn);
+               kfree(conn);
                conn = conn2;
        }
 out:
@@ -227,7 +227,7 @@ conn_exit(struct cfs_hash *hs, struct hlist_node *hnode)
        LASSERTF(atomic_read(&conn->c_refcount) == 0,
                 "Busy connection with %d refs\n",
                 atomic_read(&conn->c_refcount));
-       OBD_FREE_PTR(conn);
+       kfree(conn);
 }
 
 static cfs_hash_ops_t conn_hash_ops = {
index 9533ab976a33a21c23ec43e26f77420939b87fac..13917845126359cd99f422cb4aa874c34a3051d4 100644 (file)
@@ -507,7 +507,7 @@ static int ptlrpc_lprocfs_nrs_seq_show(struct seq_file *m, void *n)
        num_pols = svc->srv_parts[0]->scp_nrs_reg.nrs_num_pols;
        spin_unlock(&nrs->nrs_lock);
 
-       OBD_ALLOC(infos, num_pols * sizeof(*infos));
+       infos = kcalloc(num_pols, sizeof(*infos), GFP_NOFS);
        if (infos == NULL) {
                rc = -ENOMEM;
                goto out;
@@ -619,7 +619,7 @@ again:
 
 out:
        if (infos)
-               OBD_FREE(infos, num_pols * sizeof(*infos));
+               kfree(infos);
 
        mutex_unlock(&nrs_core.nrs_mutex);
 
@@ -655,7 +655,7 @@ static ssize_t ptlrpc_lprocfs_nrs_seq_write(struct file *file,
                goto out;
        }
 
-       OBD_ALLOC(cmd, LPROCFS_NRS_WR_MAX_CMD);
+       cmd = kzalloc(LPROCFS_NRS_WR_MAX_CMD, GFP_NOFS);
        if (cmd == NULL) {
                rc = -ENOMEM;
                goto out;
@@ -717,7 +717,7 @@ default_queue:
        mutex_unlock(&nrs_core.nrs_mutex);
 out:
        if (cmd_copy)
-               OBD_FREE(cmd_copy, LPROCFS_NRS_WR_MAX_CMD);
+               kfree(cmd_copy);
 
        return rc < 0 ? rc : count;
 }
@@ -825,7 +825,7 @@ ptlrpc_lprocfs_svc_req_history_start(struct seq_file *s, loff_t *pos)
                return NULL;
        }
 
-       OBD_ALLOC(srhi, sizeof(*srhi));
+       srhi = kzalloc(sizeof(*srhi), GFP_NOFS);
        if (srhi == NULL)
                return NULL;
 
@@ -851,7 +851,7 @@ ptlrpc_lprocfs_svc_req_history_start(struct seq_file *s, loff_t *pos)
                }
        }
 
-       OBD_FREE(srhi, sizeof(*srhi));
+       kfree(srhi);
        return NULL;
 }
 
@@ -861,7 +861,7 @@ ptlrpc_lprocfs_svc_req_history_stop(struct seq_file *s, void *iter)
        struct ptlrpc_srh_iterator *srhi = iter;
 
        if (srhi != NULL)
-               OBD_FREE(srhi, sizeof(*srhi));
+               kfree(srhi);
 }
 
 static void *
@@ -895,7 +895,7 @@ ptlrpc_lprocfs_svc_req_history_next(struct seq_file *s,
                }
        }
 
-       OBD_FREE(srhi, sizeof(*srhi));
+       kfree(srhi);
        return NULL;
 }
 
@@ -1191,7 +1191,7 @@ int lprocfs_wr_evict_client(struct file *file, const char __user *buffer,
        char          *kbuf;
        char          *tmpbuf;
 
-       OBD_ALLOC(kbuf, BUFLEN);
+       kbuf = kzalloc(BUFLEN, GFP_NOFS);
        if (kbuf == NULL)
                return -ENOMEM;
 
@@ -1225,7 +1225,7 @@ int lprocfs_wr_evict_client(struct file *file, const char __user *buffer,
        class_decref(obd, __func__, current);
 
 out:
-       OBD_FREE(kbuf, BUFLEN);
+       kfree(kbuf);
        return count;
 }
 EXPORT_SYMBOL(lprocfs_wr_evict_client);
@@ -1275,7 +1275,7 @@ int lprocfs_wr_import(struct file *file, const char __user *buffer,
        if (count > PAGE_CACHE_SIZE - 1 || count <= prefix_len)
                return -EINVAL;
 
-       OBD_ALLOC(kbuf, count + 1);
+       kbuf = kzalloc(count + 1, GFP_NOFS);
        if (kbuf == NULL)
                return -ENOMEM;
 
@@ -1319,7 +1319,7 @@ int lprocfs_wr_import(struct file *file, const char __user *buffer,
                ptlrpc_recover_import(imp, uuid, 1);
 
 out:
-       OBD_FREE(kbuf, count + 1);
+       kfree(kbuf);
        return count;
 }
 EXPORT_SYMBOL(lprocfs_wr_import);
index 81ad7473242eda90394aa7bc432fb6ab5574948c..68c754f67d2d1e8e189b717a05d23d6fbba7e0e6 100644 (file)
@@ -715,7 +715,7 @@ static int nrs_policy_unregister(struct ptlrpc_nrs *nrs, char *name)
        nrs_policy_fini(policy);
 
        LASSERT(policy->pol_private == NULL);
-       OBD_FREE_PTR(policy);
+       kfree(policy);
 
        return 0;
 }
@@ -761,7 +761,7 @@ static int nrs_policy_register(struct ptlrpc_nrs *nrs,
 
        rc = nrs_policy_init(policy);
        if (rc != 0) {
-               OBD_FREE_PTR(policy);
+               kfree(policy);
                return rc;
        }
 
@@ -776,7 +776,7 @@ static int nrs_policy_register(struct ptlrpc_nrs *nrs,
 
                spin_unlock(&nrs->nrs_lock);
                nrs_policy_fini(policy);
-               OBD_FREE_PTR(policy);
+               kfree(policy);
 
                return -EEXIST;
        }
@@ -1013,7 +1013,7 @@ again:
        }
 
        if (hp)
-               OBD_FREE_PTR(nrs);
+               kfree(nrs);
 }
 
 /**
@@ -1153,7 +1153,7 @@ int ptlrpc_nrs_policy_register(struct ptlrpc_nrs_pol_conf *conf)
                goto fail;
        }
 
-       OBD_ALLOC_PTR(desc);
+       desc = kzalloc(sizeof(*desc), GFP_NOFS);
        if (desc == NULL) {
                rc = -ENOMEM;
                goto fail;
@@ -1210,7 +1210,7 @@ again:
                                 */
                                LASSERT(rc2 == 0);
                                mutex_unlock(&ptlrpc_all_services_mutex);
-                               OBD_FREE_PTR(desc);
+                               kfree(desc);
                                goto fail;
                        }
 
@@ -1233,7 +1233,7 @@ again:
                                 */
                                LASSERT(rc2 == 0);
                                mutex_unlock(&ptlrpc_all_services_mutex);
-                               OBD_FREE_PTR(desc);
+                               kfree(desc);
                                goto fail;
                        }
                }
@@ -1301,7 +1301,7 @@ int ptlrpc_nrs_policy_unregister(struct ptlrpc_nrs_pol_conf *conf)
               conf->nc_name);
 
        list_del(&desc->pd_list);
-       OBD_FREE_PTR(desc);
+       kfree(desc);
 
 fail:
        mutex_unlock(&ptlrpc_all_services_mutex);
@@ -1747,7 +1747,7 @@ void ptlrpc_nrs_fini(void)
        list_for_each_entry_safe(desc, tmp, &nrs_core.nrs_policies,
                                     pd_list) {
                list_del_init(&desc->pd_list);
-               OBD_FREE_PTR(desc);
+               kfree(desc);
        }
 }
 
index eb40c01db612761ada10d4b1566af6e0757d4c74..2eefa25f464de75e00e57dbf352b6c8e1a6be2f1 100644 (file)
@@ -105,7 +105,7 @@ static void nrs_fifo_stop(struct ptlrpc_nrs_policy *policy)
        LASSERT(head != NULL);
        LASSERT(list_empty(&head->fh_list));
 
-       OBD_FREE_PTR(head);
+       kfree(head);
 }
 
 /**
index 9dbda9332dd828289c963cc49a64b8a07ac347c3..5abb91cc87ffbc3de33c24796ff06c9b652bf408 100644 (file)
@@ -427,7 +427,7 @@ struct timeout_item *ptlrpc_new_timeout(int time, enum timeout_event event,
 {
        struct timeout_item *ti;
 
-       OBD_ALLOC_PTR(ti);
+       ti = kzalloc(sizeof(*ti), GFP_NOFS);
        if (!ti)
                return NULL;
 
@@ -514,7 +514,7 @@ int ptlrpc_del_timeout_client(struct list_head *obd_list,
        LASSERTF(ti != NULL, "ti is NULL !\n");
        if (list_empty(&ti->ti_obd_list)) {
                list_del(&ti->ti_chain);
-               OBD_FREE_PTR(ti);
+               kfree(ti);
        }
        mutex_unlock(&pinger_mutex);
        return 0;
@@ -529,7 +529,7 @@ int ptlrpc_pinger_remove_timeouts(void)
        list_for_each_entry_safe(item, tmp, &timeout_list, ti_chain) {
                LASSERT(list_empty(&item->ti_obd_list));
                list_del(&item->ti_chain);
-               OBD_FREE_PTR(item);
+               kfree(item);
        }
        mutex_unlock(&pinger_mutex);
        return 0;
index 0c178ec0e48796756202b8acdd1188277b0dcf43..5ba3e6ed5289dd6d2bf090b9f6455105630b22b2 100644 (file)
@@ -528,8 +528,9 @@ static int ptlrpcd_bind(int index, int max)
        }
 
        if (rc == 0 && pc->pc_npartners > 0) {
-               OBD_ALLOC(pc->pc_partners,
-                         sizeof(struct ptlrpcd_ctl *) * pc->pc_npartners);
+               pc->pc_partners = kcalloc(pc->pc_npartners,
+                                         sizeof(struct ptlrpcd_ctl *),
+                                         GFP_NOFS);
                if (pc->pc_partners == NULL) {
                        pc->pc_npartners = 0;
                        rc = -ENOMEM;
@@ -699,8 +700,7 @@ out:
        if (pc->pc_npartners > 0) {
                LASSERT(pc->pc_partners != NULL);
 
-               OBD_FREE(pc->pc_partners,
-                        sizeof(struct ptlrpcd_ctl *) * pc->pc_npartners);
+               kfree(pc->pc_partners);
                pc->pc_partners = NULL;
        }
        pc->pc_npartners = 0;
@@ -717,7 +717,7 @@ static void ptlrpcd_fini(void)
                        ptlrpcd_free(&ptlrpcds->pd_threads[i]);
                ptlrpcd_stop(&ptlrpcds->pd_thread_rcv, 0);
                ptlrpcd_free(&ptlrpcds->pd_thread_rcv);
-               OBD_FREE(ptlrpcds, ptlrpcds->pd_size);
+               kfree(ptlrpcds);
                ptlrpcds = NULL;
        }
 }
@@ -738,7 +738,7 @@ static int ptlrpcd_init(void)
                nthreads &= ~1; /* make sure it is even */
 
        size = offsetof(struct ptlrpcd, pd_threads[nthreads]);
-       OBD_ALLOC(ptlrpcds, size);
+       ptlrpcds = kzalloc(size, GFP_NOFS);
        if (ptlrpcds == NULL) {
                rc = -ENOMEM;
                goto out;
@@ -781,7 +781,7 @@ out:
                        ptlrpcd_free(&ptlrpcds->pd_threads[j]);
                ptlrpcd_stop(&ptlrpcds->pd_thread_rcv, 0);
                ptlrpcd_free(&ptlrpcds->pd_thread_rcv);
-               OBD_FREE(ptlrpcds, size);
+               kfree(ptlrpcds);
                ptlrpcds = NULL;
        }
 
index 21e9dc9d5580b35c2029712b44d637a0f9dd223f..bcfd0b0b6f93c061cad3f2d3e3c271660843b1a1 100644 (file)
@@ -866,7 +866,7 @@ void sptlrpc_request_out_callback(struct ptlrpc_request *req)
        if (req->rq_pool || !req->rq_reqbuf)
                return;
 
-       OBD_FREE(req->rq_reqbuf, req->rq_reqbuf_len);
+       kfree(req->rq_reqbuf);
        req->rq_reqbuf = NULL;
        req->rq_reqbuf_len = 0;
 }
index c05a8554d737dcea467e945537299ce9a0ab4446..97edc9174da3797b9c0c00332c91a4cb55a8006e 100644 (file)
@@ -210,7 +210,7 @@ static void enc_pools_release_free_pages(long npages)
        /* free unused pools */
        while (p_idx_max1 < p_idx_max2) {
                LASSERT(page_pools.epp_pools[p_idx_max2]);
-               OBD_FREE(page_pools.epp_pools[p_idx_max2], PAGE_CACHE_SIZE);
+               kfree(page_pools.epp_pools[p_idx_max2]);
                page_pools.epp_pools[p_idx_max2] = NULL;
                p_idx_max2--;
        }
@@ -294,7 +294,7 @@ static unsigned long enc_pools_cleanup(struct page ***pools, int npools)
                                        cleaned++;
                                }
                        }
-                       OBD_FREE(pools[i], PAGE_CACHE_SIZE);
+                       kfree(pools[i]);
                        pools[i] = NULL;
                }
        }
@@ -409,12 +409,12 @@ static int enc_pools_add_pages(int npages)
        page_pools.epp_st_grows++;
 
        npools = npages_to_npools(npages);
-       OBD_ALLOC(pools, npools * sizeof(*pools));
+       pools = kcalloc(npools, sizeof(*pools), GFP_NOFS);
        if (pools == NULL)
                goto out;
 
        for (i = 0; i < npools; i++) {
-               OBD_ALLOC(pools[i], PAGE_CACHE_SIZE);
+               pools[i] = kzalloc(PAGE_CACHE_SIZE, GFP_NOFS);
                if (pools[i] == NULL)
                        goto out_pools;
 
@@ -435,7 +435,7 @@ static int enc_pools_add_pages(int npages)
 
 out_pools:
        enc_pools_cleanup(pools, npools);
-       OBD_FREE(pools, npools * sizeof(*pools));
+       kfree(pools);
 out:
        if (rc) {
                page_pools.epp_st_grow_fails++;
@@ -508,8 +508,8 @@ int sptlrpc_enc_pool_get_pages(struct ptlrpc_bulk_desc *desc)
        if (desc->bd_enc_iov != NULL)
                return 0;
 
-       OBD_ALLOC(desc->bd_enc_iov,
-                 desc->bd_iov_count * sizeof(*desc->bd_enc_iov));
+       desc->bd_enc_iov = kcalloc(desc->bd_iov_count,
+                                  sizeof(*desc->bd_enc_iov), GFP_NOFS);
        if (desc->bd_enc_iov == NULL)
                return -ENOMEM;
 
@@ -646,8 +646,7 @@ void sptlrpc_enc_pool_put_pages(struct ptlrpc_bulk_desc *desc)
 
        spin_unlock(&page_pools.epp_lock);
 
-       OBD_FREE(desc->bd_enc_iov,
-                desc->bd_iov_count * sizeof(*desc->bd_enc_iov));
+       kfree(desc->bd_enc_iov);
        desc->bd_enc_iov = NULL;
 }
 EXPORT_SYMBOL(sptlrpc_enc_pool_put_pages);
index 56ba9e4e5297eda5aabc1617c7528e2c29fb8eac..16dbf3fcfc8487481ee5fe3b2f5f905c5d2e7126 100644 (file)
@@ -242,8 +242,7 @@ void sptlrpc_rule_set_free(struct sptlrpc_rule_set *rset)
                (rset->srs_nrule == 0 && rset->srs_rules == NULL));
 
        if (rset->srs_nslot) {
-               OBD_FREE(rset->srs_rules,
-                        rset->srs_nslot * sizeof(*rset->srs_rules));
+               kfree(rset->srs_rules);
                sptlrpc_rule_set_init(rset);
        }
 }
@@ -265,7 +264,7 @@ int sptlrpc_rule_set_expand(struct sptlrpc_rule_set *rset)
        nslot = rset->srs_nslot + 8;
 
        /* better use realloc() if available */
-       OBD_ALLOC(rules, nslot * sizeof(*rset->srs_rules));
+       rules = kcalloc(nslot, sizeof(*rset->srs_rules), GFP_NOFS);
        if (rules == NULL)
                return -ENOMEM;
 
@@ -274,8 +273,7 @@ int sptlrpc_rule_set_expand(struct sptlrpc_rule_set *rset)
                memcpy(rules, rset->srs_rules,
                       rset->srs_nrule * sizeof(*rset->srs_rules));
 
-               OBD_FREE(rset->srs_rules,
-                        rset->srs_nslot * sizeof(*rset->srs_rules));
+               kfree(rset->srs_rules);
        }
 
        rset->srs_rules = rules;
@@ -509,7 +507,7 @@ static void sptlrpc_conf_free_rsets(struct sptlrpc_conf *conf)
                                     &conf->sc_tgts, sct_list) {
                sptlrpc_rule_set_free(&conf_tgt->sct_rset);
                list_del(&conf_tgt->sct_list);
-               OBD_FREE_PTR(conf_tgt);
+               kfree(conf_tgt);
        }
        LASSERT(list_empty(&conf->sc_tgts));
 
@@ -523,7 +521,7 @@ static void sptlrpc_conf_free(struct sptlrpc_conf *conf)
 
        sptlrpc_conf_free_rsets(conf);
        list_del(&conf->sc_list);
-       OBD_FREE_PTR(conf);
+       kfree(conf);
 }
 
 static
@@ -541,7 +539,7 @@ struct sptlrpc_conf_tgt *sptlrpc_conf_get_tgt(struct sptlrpc_conf *conf,
        if (!create)
                return NULL;
 
-       OBD_ALLOC_PTR(conf_tgt);
+       conf_tgt = kzalloc(sizeof(*conf_tgt), GFP_NOFS);
        if (conf_tgt) {
                strlcpy(conf_tgt->sct_name, name, sizeof(conf_tgt->sct_name));
                sptlrpc_rule_set_init(&conf_tgt->sct_rset);
@@ -565,7 +563,7 @@ struct sptlrpc_conf *sptlrpc_conf_get(const char *fsname,
        if (!create)
                return NULL;
 
-       OBD_ALLOC_PTR(conf);
+       conf = kzalloc(sizeof(*conf), GFP_NOFS);
        if (conf == NULL)
                return NULL;
 
index a79cd53010a4cfdf047a19882106e0f504fda676..604e51177bd3c35f2dd0a238410c4362fb332484 100644 (file)
@@ -376,7 +376,7 @@ struct ptlrpc_cli_ctx *plain_sec_install_ctx(struct plain_sec *plsec)
 {
        struct ptlrpc_cli_ctx  *ctx, *ctx_new;
 
-       OBD_ALLOC_PTR(ctx_new);
+       ctx_new = kzalloc(sizeof(*ctx_new), GFP_NOFS);
 
        write_lock(&plsec->pls_lock);
 
@@ -385,7 +385,7 @@ struct ptlrpc_cli_ctx *plain_sec_install_ctx(struct plain_sec *plsec)
                atomic_inc(&ctx->cc_refcount);
 
                if (ctx_new)
-                       OBD_FREE_PTR(ctx_new);
+                       kfree(ctx_new);
        } else if (ctx_new) {
                ctx = ctx_new;
 
@@ -424,7 +424,7 @@ void plain_destroy_sec(struct ptlrpc_sec *sec)
 
        class_import_put(sec->ps_import);
 
-       OBD_FREE_PTR(plsec);
+       kfree(plsec);
 }
 
 static
@@ -444,7 +444,7 @@ struct ptlrpc_sec *plain_create_sec(struct obd_import *imp,
 
        LASSERT(SPTLRPC_FLVR_POLICY(sf->sf_rpc) == SPTLRPC_POLICY_PLAIN);
 
-       OBD_ALLOC_PTR(plsec);
+       plsec = kzalloc(sizeof(*plsec), GFP_NOFS);
        if (plsec == NULL)
                return NULL;
 
@@ -508,7 +508,7 @@ void plain_release_ctx(struct ptlrpc_sec *sec,
        LASSERT(atomic_read(&ctx->cc_refcount) == 0);
        LASSERT(ctx->cc_sec == sec);
 
-       OBD_FREE_PTR(ctx);
+       kfree(ctx);
 
        atomic_dec(&sec->ps_nctx);
        sptlrpc_sec_put(sec);
index 8e61421515cb689e205681257fe634f9baeb72bc..d0758abfec9e67462bc08ddc08a46a8f4c96222d 100644 (file)
@@ -87,7 +87,7 @@ ptlrpc_alloc_rqbd(struct ptlrpc_service_part *svcpt)
        OBD_CPT_ALLOC_LARGE(rqbd->rqbd_buffer, svc->srv_cptable,
                            svcpt->scp_cpt, svc->srv_buf_size);
        if (rqbd->rqbd_buffer == NULL) {
-               OBD_FREE_PTR(rqbd);
+               kfree(rqbd);
                return NULL;
        }
 
@@ -113,7 +113,7 @@ ptlrpc_free_rqbd(struct ptlrpc_request_buffer_desc *rqbd)
        spin_unlock(&svcpt->scp_lock);
 
        OBD_FREE_LARGE(rqbd->rqbd_buffer, svcpt->scp_service->srv_buf_size);
-       OBD_FREE_PTR(rqbd);
+       kfree(rqbd);
 }
 
 int
@@ -661,13 +661,12 @@ ptlrpc_service_part_init(struct ptlrpc_service *svc,
 
  failed:
        if (array->paa_reqs_count != NULL) {
-               OBD_FREE(array->paa_reqs_count, sizeof(__u32) * size);
+               kfree(array->paa_reqs_count);
                array->paa_reqs_count = NULL;
        }
 
        if (array->paa_reqs_array != NULL) {
-               OBD_FREE(array->paa_reqs_array,
-                        sizeof(struct list_head) * array->paa_size);
+               kfree(array->paa_reqs_array);
                array->paa_reqs_array = NULL;
        }
 
@@ -724,17 +723,18 @@ ptlrpc_register_service(struct ptlrpc_service_conf *conf,
                                CERROR("%s: failed to parse CPT array %s: %d\n",
                                       conf->psc_name, cconf->cc_pattern, rc);
                                if (cpts != NULL)
-                                       OBD_FREE(cpts, sizeof(*cpts) * ncpts);
+                                       kfree(cpts);
                                return ERR_PTR(rc < 0 ? rc : -EINVAL);
                        }
                        ncpts = rc;
                }
        }
 
-       OBD_ALLOC(service, offsetof(struct ptlrpc_service, srv_parts[ncpts]));
+       service = kzalloc(offsetof(struct ptlrpc_service, srv_parts[ncpts]),
+                         GFP_NOFS);
        if (service == NULL) {
                if (cpts != NULL)
-                       OBD_FREE(cpts, sizeof(*cpts) * ncpts);
+                       kfree(cpts);
                return ERR_PTR(-ENOMEM);
        }
 
@@ -2291,7 +2291,7 @@ static int ptlrpc_main(void *arg)
                        goto out;
        }
 
-       OBD_ALLOC_PTR(env);
+       env = kzalloc(sizeof(*env), GFP_NOFS);
        if (env == NULL) {
                rc = -ENOMEM;
                goto out_srv_fini;
@@ -2414,7 +2414,7 @@ out_srv_fini:
 
        if (env != NULL) {
                lu_context_fini(&env->le_ctx);
-               OBD_FREE_PTR(env);
+               kfree(env);
        }
 out:
        CDEBUG(D_RPCTRACE, "service thread [ %p : %u ] %d exiting: rc %d\n",
@@ -2596,7 +2596,7 @@ static void ptlrpc_svcpt_stop_threads(struct ptlrpc_service_part *svcpt)
                thread = list_entry(zombie.next,
                                        struct ptlrpc_thread, t_link);
                list_del(&thread->t_link);
-               OBD_FREE_PTR(thread);
+               kfree(thread);
        }
 }
 
@@ -2678,7 +2678,7 @@ int ptlrpc_start_thread(struct ptlrpc_service_part *svcpt, int wait)
        spin_lock(&svcpt->scp_lock);
        if (!ptlrpc_threads_increasable(svcpt)) {
                spin_unlock(&svcpt->scp_lock);
-               OBD_FREE_PTR(thread);
+               kfree(thread);
                return -EMFILE;
        }
 
@@ -2687,7 +2687,7 @@ int ptlrpc_start_thread(struct ptlrpc_service_part *svcpt, int wait)
                 * might require unique and contiguous t_id */
                LASSERT(svcpt->scp_nthrs_starting == 1);
                spin_unlock(&svcpt->scp_lock);
-               OBD_FREE_PTR(thread);
+               kfree(thread);
                if (wait) {
                        CDEBUG(D_INFO, "Waiting for creating thread %s #%d\n",
                               svc->srv_thread_name, svcpt->scp_thr_nextid);
@@ -2733,7 +2733,7 @@ int ptlrpc_start_thread(struct ptlrpc_service_part *svcpt, int wait)
                } else {
                        list_del(&thread->t_link);
                        spin_unlock(&svcpt->scp_lock);
-                       OBD_FREE_PTR(thread);
+                       kfree(thread);
                }
                return rc;
        }
@@ -2817,8 +2817,7 @@ void ptlrpc_hr_fini(void)
 
        cfs_percpt_for_each(hrp, i, ptlrpc_hr.hr_partitions) {
                if (hrp->hrp_thrs != NULL) {
-                       OBD_FREE(hrp->hrp_thrs,
-                                hrp->hrp_nthrs * sizeof(hrp->hrp_thrs[0]));
+                       kfree(hrp->hrp_thrs);
                }
        }
 
@@ -2999,26 +2998,23 @@ ptlrpc_service_free(struct ptlrpc_service *svc)
                array = &svcpt->scp_at_array;
 
                if (array->paa_reqs_array != NULL) {
-                       OBD_FREE(array->paa_reqs_array,
-                                sizeof(struct list_head) * array->paa_size);
+                       kfree(array->paa_reqs_array);
                        array->paa_reqs_array = NULL;
                }
 
                if (array->paa_reqs_count != NULL) {
-                       OBD_FREE(array->paa_reqs_count,
-                                sizeof(__u32) * array->paa_size);
+                       kfree(array->paa_reqs_count);
                        array->paa_reqs_count = NULL;
                }
        }
 
        ptlrpc_service_for_each_part(svcpt, i, svc)
-               OBD_FREE_PTR(svcpt);
+               kfree(svcpt);
 
        if (svc->srv_cpts != NULL)
                cfs_expr_list_values_free(svc->srv_cpts, svc->srv_ncpts);
 
-       OBD_FREE(svc, offsetof(struct ptlrpc_service,
-                              srv_parts[svc->srv_ncpts]));
+       kfree(svc);
 }
 
 int ptlrpc_unregister_service(struct ptlrpc_service *service)