| /titanic_41/usr/src/cmd/lvm/rpc.mdcommd/ |
| H A D | mdmn_commd_server.c | 322 timeout_initiator(set_t setno, md_mn_msgclass_t class) in timeout_initiator() argument 332 "timeout_initiator set = %d, class = %d\n", setno, class); in timeout_initiator() 334 transp = mdmn_get_initiator_table_transp(setno, class); in timeout_initiator() 335 mdmn_get_initiator_table_id(setno, class, &mid); in timeout_initiator() 350 mdmn_unregister_initiator_table(setno, class); in timeout_initiator() 377 set_t setno; in check_timeouts() local 384 for (setno = 1; setno < MD_MAXSETS; setno++) { in check_timeouts() 385 if (md_mn_set_inited[setno] != MDMN_SET_READY) { in check_timeouts() 390 mx = mdmn_get_initiator_table_mx(setno, class); in check_timeouts() 395 mdmn_get_initiator_table_time(setno, class); in check_timeouts() [all …]
|
| H A D | mdmn_subr.c | 36 extern int mdmn_init_set(set_t setno, int todo); 63 mdmn_is_class_busy(set_t setno, md_mn_msgclass_t class) in mdmn_is_class_busy() argument 65 if (mdmn_busy[setno][class] & MDMN_BUSY) { in mdmn_is_class_busy() 86 mdmn_mark_class_busy(set_t setno, md_mn_msgclass_t class) in mdmn_mark_class_busy() argument 88 if (mdmn_busy[setno][class] & MDMN_BUSY) { in mdmn_mark_class_busy() 91 mdmn_busy[setno][class] |= MDMN_BUSY; in mdmn_mark_class_busy() 93 setno, class); in mdmn_mark_class_busy() 111 mdmn_mark_class_unbusy(set_t setno, md_mn_msgclass_t class) in mdmn_mark_class_unbusy() argument 113 commd_debug(MD_MMV_MISC, "unbusy: set=%d, class=%d\n", setno, class); in mdmn_mark_class_unbusy() 114 mdmn_busy[setno][class] &= ~MDMN_BUSY; in mdmn_mark_class_unbusy() [all …]
|
| H A D | mdmn_subr.h | 168 extern bool_t mdmn_is_class_busy(set_t setno, md_mn_msgclass_t class); 169 extern bool_t mdmn_mark_class_busy(set_t setno, md_mn_msgclass_t class); 170 extern void mdmn_mark_class_unbusy(set_t setno, md_mn_msgclass_t class); 172 extern bool_t mdmn_is_class_locked(set_t setno, md_mn_msgclass_t class); 173 extern void mdmn_mark_class_locked(set_t setno, md_mn_msgclass_t class); 174 extern void mdmn_mark_class_unlocked(set_t setno, md_mn_msgclass_t class); 176 extern bool_t mdmn_is_class_suspended(set_t setno, md_mn_msgclass_t class); 177 extern int mdmn_mark_class_suspended(set_t setno, md_mn_msgclass_t class, 179 extern void mdmn_mark_class_resumed(set_t setno, md_mn_msgclass_t class, 188 extern void mdmn_set_master_table_res(set_t setno, md_mn_msgclass_t class, [all …]
|
| /titanic_41/usr/src/uts/common/io/lvm/md/ |
| H A D | md_names.c | 164 cleanup_unused_rec(set_t setno, int devid_nm) in cleanup_unused_rec() argument 173 recid = mddb_makerecid(setno, 0); in cleanup_unused_rec() 178 recid = mddb_makerecid(setno, 0); in cleanup_unused_rec() 183 recid = mddb_makerecid(setno, 0); in cleanup_unused_rec() 190 create_hdr(set_t setno, int shared) in create_hdr() argument 200 nmid = md_set[setno].s_did_nmid = in create_hdr() 202 MDDB_DID_NM_HDR, 1, MD_CRO_32BIT, setno); in create_hdr() 209 nmid = md_set[setno].s_nmid = in create_hdr() 211 MDDB_NM_HDR, 1, MD_CRO_32BIT, setno); in create_hdr() 222 md_set[setno].s_did_nm = hhdr; in create_hdr() [all …]
|
| H A D | md_subr.c | 110 extern mddb_set_t *mddb_setenter(set_t setno, int flag, int *errorcodep); 247 md_set_setstatus(set_t setno, int bits) in md_set_setstatus() argument 249 ASSERT(setno != MD_SET_BAD && setno < MD_MAXSETS); in md_set_setstatus() 252 md_set[setno].s_status |= bits; in md_set_setstatus() 257 md_clr_setstatus(set_t setno, int bits) in md_clr_setstatus() argument 259 ASSERT(setno != MD_SET_BAD && setno < MD_MAXSETS); in md_clr_setstatus() 262 md_set[setno].s_status &= ~bits; in md_clr_setstatus() 267 md_get_setstatus(set_t setno) in md_get_setstatus() argument 271 ASSERT(setno != MD_SET_BAD && setno < MD_MAXSETS); in md_get_setstatus() 274 result = md_set[setno].s_status; in md_get_setstatus() [all …]
|
| H A D | md.c | 869 snarf_user_data(set_t setno) in snarf_user_data() argument 874 recid = mddb_makerecid(setno, 0); in snarf_user_data() 978 md_create_minor_node(set_t setno, minor_t mnum) in md_create_minor_node() argument 983 if (setno >= MD_MAXSETS || MD_MIN2UNIT(mnum) >= MD_MAXUNITS) in md_create_minor_node() 987 (unsigned)setno, (unsigned)MD_MIN2UNIT(mnum)); in md_create_minor_node() 990 MD_MKMIN(setno, mnum), DDI_PSEUDO, 0)) in md_create_minor_node() 994 (unsigned)setno, (unsigned)MD_MIN2UNIT(mnum)); in md_create_minor_node() 997 MD_MKMIN(setno, mnum), DDI_PSEUDO, 0)) in md_create_minor_node() 1016 md_verify_orphaned_record(set_t setno, mdkey_t key) in md_verify_orphaned_record() argument 1023 s = (mddb_set_t *)md_set[setno].s_db; in md_verify_orphaned_record() [all …]
|
| H A D | md_mddb.c | 100 #define SETMUTEX(setno) (&md_set[setno].s_dbmx) argument 2324 set_t setno, in getuserdata() argument 2346 if (!(md_get_setstatus(setno) & in getuserdata() 2704 set_t setno; in fixoptrecords() local 2713 setno = s->s_setno; in fixoptrecords() 2714 if ((setno != MD_LOCAL_SET) && (s->s_lbp->lb_flags & MDDB_MNSET) && in fixoptrecords() 2715 (md_set[setno].s_am_i_master == 0)) { in fixoptrecords() 3155 set_t setno = s->s_setno; in upd_med() local 3170 if ((setno != MD_LOCAL_SET) && (s->s_lbp->lb_flags & MDDB_MNSET) && in upd_med() 3171 (md_set[setno].s_am_i_master == 0)) { in upd_med() [all …]
|
| H A D | md_ioctl.c | 73 extern hot_spare_pool_t *find_hot_spare_pool(set_t setno, int hsp_id); 80 extern unit_t md_get_nextunit(set_t setno); 83 extern mddb_set_t *mddb_setenter(set_t setno, int flag, int *errorcodep); 168 set_t setno = MD_MIN2SET(mnum); in verify_minor() local 173 if (setno >= md_nsets || (MD_MIN2UNIT(mnum) >= md_nunits)) { in verify_minor() 178 if ((md_get_setstatus(setno) & MD_SET_SNARFED) == 0) in verify_minor() 189 set_t setno = cp->c_setno; in get_lb_inittime_ioctl() local 193 if (setno >= md_nsets) in get_lb_inittime_ioctl() 196 if ((s = mddb_setenter(setno, MDDB_MUSTEXIST, &err)) == NULL) in get_lb_inittime_ioctl() 234 if ((md_get_setstatus(nm->setno) & MD_SET_SNARFED) == 0) in setnm_ioctl() [all …]
|
| /titanic_41/usr/src/uts/common/io/lvm/hotspares/ |
| H A D | hotspares.c | 75 lookup_hot_spare(set_t setno, mddb_recid_t hs_id, int must_exist) in lookup_hot_spare() argument 79 for (hs = (hot_spare_t *)md_set[setno].s_hs; hs; hs = hs->hs_next) { in lookup_hot_spare() 95 set_t setno; in seths_create_hsp() local 98 setno = HSP_SET(shs->shs_hot_spare_pool); in seths_create_hsp() 101 hsp = find_hot_spare_pool(setno, shs->shs_hot_spare_pool); in seths_create_hsp() 105 typ1 = (mddb_type_t)md_getshared_key(setno, in seths_create_hsp() 116 setno); in seths_create_hsp() 121 setno); in seths_create_hsp() 135 hsp->hsp_next = (hot_spare_pool_t *)md_set[setno].s_hsp; in seths_create_hsp() 140 md_set[setno].s_hsp = (void *) hsp; in seths_create_hsp() [all …]
|
| /titanic_41/usr/src/lib/lvm/libmeta/common/ |
| H A D | meta_mn_changelog.c | 83 dump_array(char *fn_name, set_t setno) in dump_array() argument 91 tlr = &mdmn_changelog[setno][i]; in dump_array() 166 set_t setno; in mdmn_allocate_changelog() local 171 setno = sd->sd_setno; in mdmn_allocate_changelog() 184 mdmn_changelog[setno] = Zalloc(MDMN_LOGHDR_SIZE * mdmn_logrecs); in mdmn_allocate_changelog() 188 METAD_SETUP_LR(MD_DB_CREATE, setno, 0); in mdmn_allocate_changelog() 198 Free(mdmn_changelog[setno]); in mdmn_allocate_changelog() 202 tlr = &mdmn_changelog[setno][i]; in mdmn_allocate_changelog() 210 Free(mdmn_changelog[setno]); in mdmn_allocate_changelog() 234 set_t setno; in mdmn_reset_changelog() local [all …]
|
| H A D | meta_namespace.c | 48 set_t setno, in meta_getnmentbykey() argument 61 nm.setno = setno; in meta_getnmentbykey() 91 set_t setno, in meta_gethspnmentbyid() argument 104 nm.setno = setno; in meta_gethspnmentbyid() 128 set_t setno, in meta_gethspnmentbyname() argument 144 nm.setno = setno; in meta_gethspnmentbyname() 177 set_t setno, in meta_getdidminorbykey() argument 187 nm.setno = setno; in meta_getdidminorbykey() 207 set_t setno, in meta_getdidbykey() argument 216 nm.setno = setno; in meta_getdidbykey() [all …]
|
| H A D | meta_devadm.c | 238 set_t setno, in update_locator_namespace() argument 250 nm.setno = setno; in update_locator_namespace() 274 set_t setno, in meta_update_namespace() argument 287 nm.setno = setno; in meta_update_namespace() 398 has_devid(set_t setno, side_t sideno, mdkey_t key, md_error_t *ep) in has_devid() argument 400 return (meta_getdidbykey(setno, sideno, key, ep)); in has_devid() 424 set_t setno = sp->setno; in fix_replicanames() local 553 if (update_locator_namespace(setno, sideno, in fix_replicanames() 590 set_t setno, in pathname_reload() argument 646 nm.setno = setno; in pathname_reload() [all …]
|
| H A D | meta_mirror_resync.c | 67 assert(sp->setno == MD_MIN2SET(meta_getminor(mirnp->dev))); in meta_mirror_resync() 79 MD_SETDRIVERNAME(&ri, MD_MIRROR, sp->setno); in meta_mirror_resync() 307 MD_SETDRIVERNAME(&ri, MD_MIRROR, sp->setno); in meta_mirror_resync_all() 343 set_t setno = *((set_t *)arg); in meta_mn_mirror_resync_all() local 352 assert(setno != NULL); in meta_mn_mirror_resync_all() 354 if ((sp = metasetnosetname(setno, &mde)) == NULL) { in meta_mn_mirror_resync_all() 395 sr_cache_flush_setno(setno); in meta_mn_mirror_resync_all() 396 if ((sp = metasetnosetname(setno, &mde)) == NULL) { in meta_mn_mirror_resync_all() 483 MD_SETDRIVERNAME(&ri, MD_MIRROR, sp->setno); in meta_mn_mirror_resync_all() 567 set_t setno, max_sets; in meta_mirror_resync_process_all() local [all …]
|
| H A D | meta_set_med.c | 108 sp->setno, nm, NULL, sp->setname)); in validate_med_nodes() 117 MDE_DS_NOTNODENAME, sp->setno, nm, in validate_med_nodes() 125 MDE_DS_ALIASNOMATCH, sp->setno, nm, in validate_med_nodes() 208 sp->setno, in meta_set_addmeds() 223 sp->setno, cp, NULL, sp->setname)); in meta_set_addmeds() 226 sp->setno, cp, NULL, sp->setname)); in meta_set_addmeds() 303 (void) mddserror(ep, MDE_DS_ISMED, sp->setno, in meta_set_addmeds() 327 rb_medr.med_rec_sn = sp->setno; in meta_set_addmeds() 385 sp->setno, j); in meta_set_addmeds() 396 mp.med_setno = sp->setno; in meta_set_addmeds() [all …]
|
| H A D | meta_se_notify.c | 38 obj2devname(uint32_t tag, set_t setno, md_dev64_t dev) in obj2devname() argument 50 if ((setno != MD_SET_BAD) && in obj2devname() 51 ((sp = metasetnosetname(setno, &status)) != NULL)) { in obj2devname() 104 if ((setname = get_devname(setno, dev)) != NULL) { in obj2devname() 200 do_mdnotify(char *se_subclass, uint32_t tag, set_t setno, md_dev64_t devid) in do_mdnotify() argument 222 NOTIFY_MD(md_tag, setno, devid, ev_type); in do_mdnotify() 323 set_t setno, in meta_svm_sysevent() argument 333 do_mdnotify(se_subclass, tag, setno, devid); in meta_svm_sysevent() 358 (uint32_t)setno); in meta_svm_sysevent() 371 devname = obj2devname(tag, setno, devid); in meta_svm_sysevent()
|
| H A D | meta_metad.c | 424 v21_args->cl_sk = cl_get_setkey(sp->setno, sp->setname); in clnt_add_drv_sidenms() 458 v1_args.cl_sk = cl_get_setkey(sp->setno, sp->setname); in clnt_add_drv_sidenms() 542 v21_args->cl_sk = cl_get_setkey(sp->setno, sp->setname); in clnt_imp_adddrvs() 574 sp->setno, hostname, NULL, NULL); in clnt_imp_adddrvs() 630 v21_args->cl_sk = cl_get_setkey(sp->setno, sp->setname); in clnt_adddrvs() 662 v1_args.cl_sk = cl_get_setkey(sp->setno, sp->setname); in clnt_adddrvs() 724 args->cl_sk = cl_get_setkey(sp->setno, sp->setname); in clnt_addhosts() 799 args->cl_sk = cl_get_setkey(sp->setno, sp->setname); in clnt_createset() 878 args->cl_sk = cl_get_setkey(sp->setno, sp->setname); in clnt_mncreateset() 906 sp->setno, hostname, NULL, sp->setname); in clnt_mncreateset() [all …]
|
| /titanic_41/usr/src/cmd/lvm/util/ |
| H A D | metaclust.c | 262 if (MD_MIN2SET(mnum) != sp->setno) { in compose_path() 264 mnum, sp->setno); in compose_path() 353 MD_SETDRIVERNAME(mir_state, MD_MIRROR, sp->setno); in reset_state() 395 MD_SETDRIVERNAME(ownpar, MD_MIRROR, sp->setno); in reset_state() 427 sp->setno, ownpar->d.mnum, in reset_state() 460 if (meta_mn_change_owner(&ownpar, sp->setno, in reset_state() 670 set_t max_sets, setno; in main() local 903 for (setno = 1; setno < max_sets; setno++) { in main() 904 if ((sp = metasetnosetname(setno, ep)) == NULL) { in main() 911 "get set %d information"), setno); in main() [all …]
|
| /titanic_41/usr/src/cmd/mdb/common/modules/md/ |
| H A D | metastat.c | 36 print_setname(int setno) in print_setname() argument 40 if (setno != 0) { in print_setname() 42 (uintptr_t)set_dbs[setno].s_setname) == -1) { in print_setname() 44 set_dbs[setno].s_setname); in print_setname() 54 int setno; in print_stripe() local 69 setno = MD_MIN2SET(un_self_id); in print_stripe() 70 print_setname(setno); in print_stripe() 187 int setno = 0; in print_mirror() local 209 setno = MD_MIN2SET(un_self_id); in print_mirror() 210 print_setname(setno); in print_mirror() [all …]
|
| H A D | walk_units.c | 35 int setno; member 62 ((unit_data_t *)wsp->walk_data)->setno = 0; in units_walk_init() 70 ((unit_data_t *)wsp->walk_data)->setno = i; in units_walk_init() 86 un->setno += 1; in units_walk_step() 87 if ((un->setno < md_nsets) && (un->do_all == 1)) { in units_walk_step() 89 wsp->walk_addr = (uintptr_t)mdset[un->setno].s_un; in units_walk_step() 92 un->setno); in units_walk_step()
|
| /titanic_41/usr/src/uts/common/io/lvm/trans/ |
| H A D | mdtrans.c | 255 set_t setno = MD_MIN2SET(MD_SID(un)); in trans_open_all_devs() local 256 side_t side = mddb_getsidenum(setno); in trans_open_all_devs() 262 md_devid_found(setno, side, un->un_m_key) == 1) { in trans_open_all_devs() 288 set_t setno; in trans_build_incore() local 302 setno = MD_MIN2SET(mnum); in trans_build_incore() 309 un->un_m_dev = md_getdevnum(setno, mddb_getsidenum(setno), in trans_build_incore() 529 sv.setno = MD_MIN2SET(mnum); in trans_reset() 769 sv.setno = MD_UN2SET(un); in trans_cleanup() 778 trans_snarf(md_snarfcmd_t cmd, set_t setno) in trans_snarf() argument 795 if (md_get_setstatus(setno) & MD_SET_STALE) in trans_snarf() [all …]
|
| /titanic_41/usr/src/uts/common/io/lvm/softpart/ |
| H A D | sp.c | 217 set_t setno; in sp_build_incore() local 233 setno = MD_MIN2SET(mnum); in sp_build_incore() 235 tmpdev = md_getdevnum(setno, mddb_getsidenum(setno), in sp_build_incore() 286 sv->setno = MD_MIN2SET(mnum); in reset_sp() 335 set_t setno = MD_UN2SET(un); in sp_send_stat_msg() local 346 rval = mdmn_ksend_message(setno, MD_MN_MSG_SP_SETSTAT2, MD_MSGF_NO_LOG, in sp_send_stat_msg() 508 set_t setno = MD_UN2SET(ps->ps_un); in sp_error() local 542 if (MD_MNSET_SETNO(setno)) { in sp_error() 685 set_t setno; in sp_validate() local 688 setno = MD_UN2SET(un); in sp_validate() [all …]
|
| H A D | sp_ioctl.c | 110 set_t setno = MD_MIN2SET(mnum); in sp_getun() local 113 if ((setno >= md_nsets) || (MD_MIN2UNIT(mnum) >= md_nunits)) { in sp_getun() 118 if (md_get_setstatus(setno) & MD_SET_STALE) { in sp_getun() 119 (void) mdmddberror(mde, MDE_DB_STALE, mnum, setno); in sp_getun() 224 set_t setno; in sp_update_watermarks() local 239 setno = MD_MIN2SET(mnum); in sp_update_watermarks() 240 side = mddb_getsidenum(setno); in sp_update_watermarks() 251 if ((setno >= md_nsets) || (MD_MIN2UNIT(mnum) >= md_nunits)) in sp_update_watermarks() 253 if (md_get_setstatus(setno) & MD_SET_STALE) in sp_update_watermarks() 254 return (mdmddberror(mdep, MDE_DB_STALE, mnum, setno)); in sp_update_watermarks() [all …]
|
| /titanic_41/usr/src/uts/common/io/lvm/stripe/ |
| H A D | stripe.c | 182 set_t setno = MD_MIN2SET(MD_SID(un)); in stripe_open_all_devs() local 183 side_t side = mddb_getsidenum(setno); in stripe_open_all_devs() 218 if (MD_MNSET_SETNO(setno)) { in stripe_open_all_devs() 228 md_devid_found(setno, side, key) == 1) { in stripe_open_all_devs() 317 set_t setno; in stripe_build_incore() local 327 setno = MD_MIN2SET(mnum); in stripe_build_incore() 329 tmpdev = md_getdevnum(setno, mddb_getsidenum(setno), in stripe_build_incore() 451 sv[isv].setno = MD_MIN2SET(mnum); in reset_stripe() 698 set_t setno; in md_stripe_strategy() local 700 setno = MD_MIN2SET(getminor(pb->b_edev)); in md_stripe_strategy() [all …]
|
| /titanic_41/usr/src/uts/common/io/lvm/mirror/ |
| H A D | mirror.c | 221 set_t setno = (set_t)drq->dq.qlen; in send_poke_hotspares_msg() local 223 pokehsp.pokehsp_setno = setno; in send_poke_hotspares_msg() 228 rval = mdmn_ksend_message(setno, MD_MN_MSG_POKE_HOTSPARES, in send_poke_hotspares_msg() 267 send_poke_hotspares(set_t setno) in send_poke_hotspares() argument 269 daemon_request_t *drq = &mn_hs_request[setno]; in send_poke_hotspares() 274 drq->dq.qlen = (int)setno; in send_poke_hotspares() 428 set_t setno; in check_comp_4_hotspares() local 436 setno = MD_UN2SET(un); in check_comp_4_hotspares() 449 if (MD_MNSET_SETNO(setno) && (flags & MD_HOTSPARE_XMIT)) { in check_comp_4_hotspares() 492 rval = mdmn_ksend_message(setno, msgtype, msgflags, 0, in check_comp_4_hotspares() [all …]
|
| H A D | mirror_ioctl.c | 110 set_t setno = MD_MIN2SET(mnum); in mirror_getun() local 112 if ((setno >= md_nsets) || (MD_MIN2UNIT(mnum) >= md_nunits)) { in mirror_getun() 118 if (md_get_setstatus(setno) & MD_SET_STALE) { in mirror_getun() 119 (void) mdmddberror(mde, MDE_DB_STALE, mnum, setno); in mirror_getun() 171 set_t setno; in mirror_set() local 182 setno = MD_MIN2SET(mnum); in mirror_set() 184 typ1 = (mddb_type_t)md_getshared_key(setno, in mirror_set() 197 MD_CRO_64BIT | MD_CRO_MIRROR | MD_CRO_FN, setno); in mirror_set() 205 MD_CRO_32BIT | MD_CRO_MIRROR | MD_CRO_FN, setno); in mirror_set() 209 mnum, setno)); in mirror_set() [all …]
|