-/* device init/fini methods */
-static void mdt_stop_ptlrpc_service(struct mdt_device *m)
-{
- ENTRY;
- if (m->mdt_regular_service != NULL) {
- ptlrpc_unregister_service(m->mdt_regular_service);
- m->mdt_regular_service = NULL;
- }
- if (m->mdt_readpage_service != NULL) {
- ptlrpc_unregister_service(m->mdt_readpage_service);
- m->mdt_readpage_service = NULL;
- }
- if (m->mdt_xmds_service != NULL) {
- ptlrpc_unregister_service(m->mdt_xmds_service);
- m->mdt_xmds_service = NULL;
- }
- if (m->mdt_setattr_service != NULL) {
- ptlrpc_unregister_service(m->mdt_setattr_service);
- m->mdt_setattr_service = NULL;
- }
- if (m->mdt_mdsc_service != NULL) {
- ptlrpc_unregister_service(m->mdt_mdsc_service);
- m->mdt_mdsc_service = NULL;
- }
- if (m->mdt_mdss_service != NULL) {
- ptlrpc_unregister_service(m->mdt_mdss_service);
- m->mdt_mdss_service = NULL;
- }
- if (m->mdt_dtss_service != NULL) {
- ptlrpc_unregister_service(m->mdt_dtss_service);
- m->mdt_dtss_service = NULL;
- }
- if (m->mdt_fld_service != NULL) {
- ptlrpc_unregister_service(m->mdt_fld_service);
- m->mdt_fld_service = NULL;
- }
- EXIT;
-}
-
-static int mdt_start_ptlrpc_service(struct mdt_device *m)
-{
- static struct ptlrpc_service_conf conf;
- cfs_proc_dir_entry_t *procfs_entry;
- int rc = 0;
- ENTRY;
-
- m->mdt_ldlm_client = &m->mdt_md_dev.md_lu_dev.ld_obd->obd_ldlm_client;
- ptlrpc_init_client(LDLM_CB_REQUEST_PORTAL, LDLM_CB_REPLY_PORTAL,
- "mdt_ldlm_client", m->mdt_ldlm_client);
-
- procfs_entry = m->mdt_md_dev.md_lu_dev.ld_obd->obd_proc_entry;
-
- conf = (typeof(conf)) {
- .psc_name = LUSTRE_MDT_NAME,
- .psc_watchdog_factor = MDT_SERVICE_WATCHDOG_FACTOR,
- .psc_buf = {
- .bc_nbufs = MDS_NBUFS,
- .bc_buf_size = MDS_BUFSIZE,
- .bc_req_max_size = MDS_MAXREQSIZE,
- .bc_rep_max_size = MDS_MAXREPSIZE,
- .bc_req_portal = MDS_REQUEST_PORTAL,
- .bc_rep_portal = MDC_REPLY_PORTAL,
- },
- /*
- * We'd like to have a mechanism to set this on a per-device
- * basis, but alas...
- */
- .psc_thr = {
- .tc_thr_name = LUSTRE_MDT_NAME,
- .tc_thr_factor = MDT_THR_FACTOR,
- .tc_nthrs_init = MDT_NTHRS_INIT,
- .tc_nthrs_base = MDT_NTHRS_BASE,
- .tc_nthrs_max = MDT_NTHRS_MAX,
- .tc_nthrs_user = mds_num_threads,
- .tc_cpu_affinity = 1,
- .tc_ctx_tags = LCT_MD_THREAD,
- },
- .psc_cpt = {
- .cc_pattern = mds_num_cpts,
- },
- .psc_ops = {
- .so_req_handler = mdt_regular_handle,
- .so_req_printer = target_print_req,
- .so_hpreq_handler = ptlrpc_hpreq_handler,
- },
- };
- m->mdt_regular_service = ptlrpc_register_service(&conf, procfs_entry);
- if (IS_ERR(m->mdt_regular_service)) {
- rc = PTR_ERR(m->mdt_regular_service);
- CERROR("failed to start regular mdt service: %d\n", rc);
- m->mdt_regular_service = NULL;
-
- RETURN(rc);
- }
-
- /*
- * readpage service configuration. Parameters have to be adjusted,
- * ideally.
- */
- memset(&conf, 0, sizeof(conf));
- conf = (typeof(conf)) {
- .psc_name = LUSTRE_MDT_NAME "_readpage",
- .psc_watchdog_factor = MDT_SERVICE_WATCHDOG_FACTOR,
- .psc_buf = {
- .bc_nbufs = MDS_NBUFS,
- .bc_buf_size = MDS_BUFSIZE,
- .bc_req_max_size = MDS_MAXREQSIZE,
- .bc_rep_max_size = MDS_MAXREPSIZE,
- .bc_req_portal = MDS_READPAGE_PORTAL,
- .bc_rep_portal = MDC_REPLY_PORTAL,
- },
- .psc_thr = {
- .tc_thr_name = "mdt_rdpg",
- .tc_thr_factor = MDT_RDPG_THR_FACTOR,
- .tc_nthrs_init = MDT_RDPG_NTHRS_INIT,
- .tc_nthrs_base = MDT_RDPG_NTHRS_BASE,
- .tc_nthrs_max = MDT_RDPG_NTHRS_MAX,
- .tc_nthrs_user = mds_rdpg_num_threads,
- .tc_cpu_affinity = 1,
- .tc_ctx_tags = LCT_MD_THREAD,
- },
- .psc_cpt = {
- .cc_pattern = mds_rdpg_num_cpts,
- },
- .psc_ops = {
- .so_req_handler = mdt_readpage_handle,
- .so_req_printer = target_print_req,
- },
- };
- m->mdt_readpage_service = ptlrpc_register_service(&conf, procfs_entry);
- if (IS_ERR(m->mdt_readpage_service)) {
- rc = PTR_ERR(m->mdt_readpage_service);
- CERROR("failed to start readpage service: %d\n", rc);
- m->mdt_readpage_service = NULL;
-
- GOTO(err_mdt_svc, rc);
- }
-
- /*
- * setattr service configuration.
- *
- * XXX To keep the compatibility with old client(< 2.2), we need to
- * preserve this portal for a certain time, it should be removed
- * eventually. LU-617.
- */
- memset(&conf, 0, sizeof(conf));
- conf = (typeof(conf)) {
- .psc_name = LUSTRE_MDT_NAME "_setattr",
- .psc_watchdog_factor = MDT_SERVICE_WATCHDOG_FACTOR,
- .psc_buf = {
- .bc_nbufs = MDS_NBUFS,
- .bc_buf_size = MDS_BUFSIZE,
- .bc_req_max_size = MDS_MAXREQSIZE,
- .bc_rep_max_size = MDS_MAXREPSIZE,
- .bc_req_portal = MDS_SETATTR_PORTAL,
- .bc_rep_portal = MDC_REPLY_PORTAL,
- },
- .psc_thr = {
- .tc_thr_name = "mdt_attr",
- .tc_thr_factor = MDT_SETA_THR_FACTOR,
- .tc_nthrs_init = MDT_SETA_NTHRS_INIT,
- .tc_nthrs_base = MDT_SETA_NTHRS_BASE,
- .tc_nthrs_max = MDT_SETA_NTHRS_MAX,
- .tc_nthrs_user = mds_attr_num_threads,
- .tc_cpu_affinity = 1,
- .tc_ctx_tags = LCT_MD_THREAD,
- },
- .psc_cpt = {
- .cc_pattern = mds_attr_num_cpts,
- },
- .psc_ops = {
- .so_req_handler = mdt_regular_handle,
- .so_req_printer = target_print_req,
- },
- };
- m->mdt_setattr_service = ptlrpc_register_service(&conf, procfs_entry);
- if (IS_ERR(m->mdt_setattr_service)) {
- rc = PTR_ERR(m->mdt_setattr_service);
- CERROR("failed to start setattr service: %d\n", rc);
- m->mdt_setattr_service = NULL;
-
- GOTO(err_mdt_svc, rc);
- }
-
- /*
- * sequence controller service configuration
- */
- memset(&conf, 0, sizeof(conf));
- conf = (typeof(conf)) {
- .psc_name = LUSTRE_MDT_NAME "_mdsc",
- .psc_watchdog_factor = MDT_SERVICE_WATCHDOG_FACTOR,
- .psc_buf = {
- .bc_nbufs = MDS_NBUFS,
- .bc_buf_size = MDS_BUFSIZE,
- .bc_req_max_size = SEQ_MAXREQSIZE,
- .bc_rep_max_size = SEQ_MAXREPSIZE,
- .bc_req_portal = SEQ_CONTROLLER_PORTAL,
- .bc_rep_portal = MDC_REPLY_PORTAL,
- },
- .psc_thr = {
- .tc_thr_name = "mdt_mdsc",
- .tc_nthrs_init = MDT_OTHR_NTHRS_INIT,
- .tc_nthrs_max = MDT_OTHR_NTHRS_MAX,
- .tc_ctx_tags = LCT_MD_THREAD,
- },
- .psc_ops = {
- .so_req_handler = mdt_mdsc_handle,
- .so_req_printer = target_print_req,
- },
- };
- m->mdt_mdsc_service = ptlrpc_register_service(&conf, procfs_entry);
- if (IS_ERR(m->mdt_mdsc_service)) {
- rc = PTR_ERR(m->mdt_mdsc_service);
- CERROR("failed to start seq controller service: %d\n", rc);
- m->mdt_mdsc_service = NULL;
-
- GOTO(err_mdt_svc, rc);
- }
-
- /*
- * metadata sequence server service configuration
- */
- memset(&conf, 0, sizeof(conf));
- conf = (typeof(conf)) {
- .psc_name = LUSTRE_MDT_NAME "_mdss",
- .psc_watchdog_factor = MDT_SERVICE_WATCHDOG_FACTOR,
- .psc_buf = {
- .bc_nbufs = MDS_NBUFS,
- .bc_buf_size = MDS_BUFSIZE,
- .bc_req_max_size = SEQ_MAXREQSIZE,
- .bc_rep_max_size = SEQ_MAXREPSIZE,
- .bc_req_portal = SEQ_METADATA_PORTAL,
- .bc_rep_portal = MDC_REPLY_PORTAL,
- },
- .psc_thr = {
- .tc_thr_name = "mdt_mdss",
- .tc_nthrs_init = MDT_OTHR_NTHRS_INIT,
- .tc_nthrs_max = MDT_OTHR_NTHRS_MAX,
- .tc_ctx_tags = LCT_MD_THREAD | LCT_DT_THREAD
- },
- .psc_ops = {
- .so_req_handler = mdt_mdss_handle,
- .so_req_printer = target_print_req,
- },
- };
- m->mdt_mdss_service = ptlrpc_register_service(&conf, procfs_entry);
- if (IS_ERR(m->mdt_mdss_service)) {
- rc = PTR_ERR(m->mdt_mdss_service);
- CERROR("failed to start metadata seq server service: %d\n", rc);
- m->mdt_mdss_service = NULL;
-
- GOTO(err_mdt_svc, rc);
- }
-
- /*
- * Data sequence server service configuration. We want to have really
- * cluster-wide sequences space. This is why we start only one sequence
- * controller which manages space.
- */
- memset(&conf, 0, sizeof(conf));
- conf = (typeof(conf)) {
- .psc_name = LUSTRE_MDT_NAME "_dtss",
- .psc_watchdog_factor = MDT_SERVICE_WATCHDOG_FACTOR,
- .psc_buf = {
- .bc_nbufs = MDS_NBUFS,
- .bc_buf_size = MDS_BUFSIZE,
- .bc_req_max_size = SEQ_MAXREQSIZE,
- .bc_rep_max_size = SEQ_MAXREPSIZE,
- .bc_req_portal = SEQ_DATA_PORTAL,
- .bc_rep_portal = OSC_REPLY_PORTAL,
- },
- .psc_thr = {
- .tc_thr_name = "mdt_dtss",
- .tc_nthrs_init = MDT_OTHR_NTHRS_INIT,
- .tc_nthrs_max = MDT_OTHR_NTHRS_MAX,
- .tc_ctx_tags = LCT_MD_THREAD | LCT_DT_THREAD
- },
- .psc_ops = {
- .so_req_handler = mdt_dtss_handle,
- .so_req_printer = target_print_req,
- },
- };
- m->mdt_dtss_service = ptlrpc_register_service(&conf, procfs_entry);
- if (IS_ERR(m->mdt_dtss_service)) {
- rc = PTR_ERR(m->mdt_dtss_service);
- CERROR("failed to start data seq server service: %d\n", rc);
- m->mdt_dtss_service = NULL;
-
- GOTO(err_mdt_svc, rc);
- }
-
- /* FLD service start */
- memset(&conf, 0, sizeof(conf));
- conf = (typeof(conf)) {
- .psc_name = LUSTRE_MDT_NAME "_fld",
- .psc_watchdog_factor = MDT_SERVICE_WATCHDOG_FACTOR,
- .psc_buf = {
- .bc_nbufs = MDS_NBUFS,
- .bc_buf_size = MDS_BUFSIZE,
- .bc_req_max_size = FLD_MAXREQSIZE,
- .bc_rep_max_size = FLD_MAXREPSIZE,
- .bc_req_portal = FLD_REQUEST_PORTAL,
- .bc_rep_portal = MDC_REPLY_PORTAL,
- },
- .psc_thr = {
- .tc_thr_name = "mdt_fld",
- .tc_nthrs_init = MDT_OTHR_NTHRS_INIT,
- .tc_nthrs_max = MDT_OTHR_NTHRS_MAX,
- .tc_ctx_tags = LCT_DT_THREAD | LCT_MD_THREAD
- },
- .psc_ops = {
- .so_req_handler = mdt_fld_handle,
- .so_req_printer = target_print_req,
- },
- };
- m->mdt_fld_service = ptlrpc_register_service(&conf, procfs_entry);
- if (IS_ERR(m->mdt_fld_service)) {
- rc = PTR_ERR(m->mdt_fld_service);
- CERROR("failed to start fld service: %d\n", rc);
- m->mdt_fld_service = NULL;
-
- GOTO(err_mdt_svc, rc);
- }
-
- /*
- * mds-mds service configuration. Separate portal is used to allow
- * mds-mds requests be not blocked during recovery.
- */
- memset(&conf, 0, sizeof(conf));
- conf = (typeof(conf)) {
- .psc_name = LUSTRE_MDT_NAME "_mds",
- .psc_watchdog_factor = MDT_SERVICE_WATCHDOG_FACTOR,
- .psc_buf = {
- .bc_nbufs = MDS_NBUFS,
- .bc_buf_size = MDS_BUFSIZE,
- .bc_req_max_size = MDS_MAXREQSIZE,
- .bc_rep_max_size = MDS_MAXREPSIZE,
- .bc_req_portal = MDS_MDS_PORTAL,
- .bc_rep_portal = MDC_REPLY_PORTAL,
- },
- .psc_thr = {
- .tc_thr_name = "mdt_mds",
- .tc_nthrs_init = MDT_OTHR_NTHRS_INIT,
- .tc_nthrs_max = MDT_OTHR_NTHRS_MAX,
- .tc_ctx_tags = LCT_MD_THREAD,
- },
- .psc_ops = {
- .so_req_handler = mdt_xmds_handle,
- .so_req_printer = target_print_req,
- .so_hpreq_handler = ptlrpc_hpreq_handler,
- },
- };
- m->mdt_xmds_service = ptlrpc_register_service(&conf, procfs_entry);
- if (IS_ERR(m->mdt_xmds_service)) {
- rc = PTR_ERR(m->mdt_xmds_service);
- CERROR("failed to start xmds service: %d\n", rc);
- m->mdt_xmds_service = NULL;
-
- GOTO(err_mdt_svc, rc);
- }
-
- EXIT;
-err_mdt_svc:
- if (rc)
- mdt_stop_ptlrpc_service(m);
-
- return rc;
-}
-