Home
last modified time | relevance | path

Searched refs:lockp (Results 1 – 25 of 54) sorted by relevance

123

/titanic_41/usr/src/lib/krb5/plugins/kdb/db2/
H A Dadb_openclose.c143 struct _locklist *lockp; in osa_adb_init_db() local
195 lockp = locklist; in osa_adb_init_db()
196 while (lockp) { in osa_adb_init_db()
197 if (strcmp(lockp->lockinfo.filename, lockfilename) == 0) in osa_adb_init_db()
200 lockp = lockp->next; in osa_adb_init_db()
202 if (lockp == NULL) { in osa_adb_init_db()
204 lockp = (struct _locklist *) malloc(sizeof(*lockp)); in osa_adb_init_db()
205 if (lockp == NULL) { in osa_adb_init_db()
209 memset(lockp, 0, sizeof(*lockp)); in osa_adb_init_db()
210 lockp->next = locklist; in osa_adb_init_db()
[all …]
/titanic_41/usr/src/cmd/sendmail/db/lock/
H A Dlock.c269 struct __db_lock *lockp; local
283 lockp = OFFSET_TO_LOCK(lt, *lock);
286 locker, NULL, flags, obj, lock_mode, &lockp)) == 0) {
288 *lock = LOCK_TO_OFFSET(lt, lockp);
306 struct __db_lock *lockp; local
320 lockp = OFFSET_TO_LOCK(lt, *lock);
323 txn->txnid, txn, flags, obj, lock_mode, &lockp)) == 0) {
325 *lock = LOCK_TO_OFFSET(lt, lockp);
338 struct __db_lock *lockp; local
348 lockp = OFFSET_TO_LOCK(lt, lock);
[all …]
H A Dlock_deadlock.c420 struct __db_lock *lockp; local
433 lockp = SH_LIST_FIRST(&lockerp->heldby, __db_lock);
440 if (lockp == NULL) {
447 } else if (LOCK_TO_OFFSET(lt, lockp) != info->last_lock ||
448 lockp->status != DB_LSTAT_WAITING)
452 lockp->status = DB_LSTAT_ABORTED;
454 SH_LIST_REMOVE(lockp, locker_links, __db_lock);
455 sh_obj = (DB_LOCKOBJ *)((u_int8_t *)lockp + lockp->obj);
456 SH_TAILQ_REMOVE(&sh_obj->waiters, lockp, links, __db_lock);
457 (void)__db_mutex_unlock(&lockp->mutex, lt->reginfo.fd);
/titanic_41/usr/src/uts/common/io/xge/drv/
H A Dxge_osdep.h170 #define xge_os_spin_lock_init(lockp, ctxh) \ argument
171 mutex_init(lockp, NULL, MUTEX_DRIVER, NULL)
172 #define xge_os_spin_lock_init_irq(lockp, irqh) \ argument
173 mutex_init(lockp, NULL, MUTEX_DRIVER, DDI_INTR_PRI(irqh))
174 #define xge_os_spin_lock_destroy(lockp, cthx) \ argument
175 (cthx = cthx, mutex_destroy(lockp))
176 #define xge_os_spin_lock_destroy_irq(lockp, cthx) \ argument
177 (cthx = cthx, mutex_destroy(lockp))
178 #define xge_os_spin_lock(lockp) mutex_enter(lockp) argument
179 #define xge_os_spin_unlock(lockp) mutex_exit(lockp) argument
[all …]
/titanic_41/usr/src/uts/common/avs/ns/nsctl/
H A Dnsc_rmspin.c158 mutex_init(&lk->lockp, NULL, MUTEX_DRIVER, arg); in nsc_rm_lock_alloc()
169 mutex_destroy(&lk->lockp); in nsc_rm_lock_alloc()
217 mutex_destroy(&rmlockp->lockp);
238 mutex_enter(&rmlockp->lockp); in nsc_rm_lock()
246 mutex_exit(&rmlockp->lockp); in nsc_rm_lock()
265 ASSERT(MUTEX_HELD(&rmlockp->lockp)); in nsc_rm_unlock()
268 mutex_exit(&rmlockp->lockp); in nsc_rm_unlock()
H A Dnsc_rmspin.h42 kmutex_t lockp; member
/titanic_41/usr/src/uts/common/os/
H A Dnetstack.c677 netstack_apply_create(kmutex_t *lockp, netstack_t *ns, int moduleid) in netstack_apply_create() argument
684 ASSERT(MUTEX_HELD(lockp)); in netstack_apply_create()
687 if (wait_for_nms_inprogress(ns, nms, lockp)) in netstack_apply_create()
696 mutex_exit(lockp); in netstack_apply_create()
709 mutex_enter(lockp); in netstack_apply_create()
737 netstack_apply_shutdown(kmutex_t *lockp, netstack_t *ns, int moduleid) in netstack_apply_shutdown() argument
744 ASSERT(MUTEX_HELD(lockp)); in netstack_apply_shutdown()
747 if (wait_for_nms_inprogress(ns, nms, lockp)) in netstack_apply_shutdown()
756 mutex_exit(lockp); in netstack_apply_shutdown()
769 mutex_enter(lockp); in netstack_apply_shutdown()
[all …]
H A Dzone.c1011 zsd_apply_create(kmutex_t *lockp, boolean_t zone_lock_held, in zsd_apply_create() argument
1018 if (lockp != NULL) { in zsd_apply_create()
1019 ASSERT(MUTEX_HELD(lockp)); in zsd_apply_create()
1038 if (zsd_wait_for_inprogress(zone, t, lockp)) in zsd_apply_create()
1047 if (lockp != NULL) in zsd_apply_create()
1048 mutex_exit(lockp); in zsd_apply_create()
1061 if (lockp != NULL) in zsd_apply_create()
1062 mutex_enter(lockp); in zsd_apply_create()
1090 zsd_apply_shutdown(kmutex_t *lockp, boolean_t zone_lock_held, in zsd_apply_shutdown() argument
1097 if (lockp != NULL) { in zsd_apply_shutdown()
[all …]
/titanic_41/usr/src/cmd/sendmail/db/btree/
H A Dbt_page.c262 __bam_lget(dbc, do_couple, pgno, mode, lockp) in __bam_lget() argument
267 DB_LOCK *lockp;
276 *lockp = LOCK_INVALID;
292 couple[1].lock = *lockp;
302 __BT_LPUT(dbc, *lockp);
306 *lockp = couple[0].lock;
310 dbc->locker, 0, &dbc->lock_dbt, mode, lockp);
313 dbc->txn, 0, &dbc->lock_dbt, mode, lockp);
/titanic_41/usr/src/lib/libnsl/rpc/
H A Dsvc_door.c98 __svc_add_to_xlist(SVCXPRT_LIST **list, SVCXPRT *xprt, mutex_t *lockp) in __svc_add_to_xlist() argument
105 if (lockp != NULL) in __svc_add_to_xlist()
106 (void) mutex_lock(lockp); in __svc_add_to_xlist()
109 if (lockp != NULL) in __svc_add_to_xlist()
110 (void) mutex_unlock(lockp); in __svc_add_to_xlist()
115 __svc_rm_from_xlist(SVCXPRT_LIST **list, SVCXPRT *xprt, mutex_t *lockp) in __svc_rm_from_xlist() argument
119 if (lockp != NULL) in __svc_rm_from_xlist()
120 (void) mutex_lock(lockp); in __svc_rm_from_xlist()
129 if (lockp != NULL) in __svc_rm_from_xlist()
130 (void) mutex_unlock(lockp); in __svc_rm_from_xlist()
[all …]
/titanic_41/usr/src/uts/common/io/lvm/mirror/
H A Dmirror.c416 IOLOCK *lockp /* can be NULL */ in check_comp_4_hotspares() argument
647 if (lockp) { in check_comp_4_hotspares()
648 md_ioctl_writerexit(lockp); in check_comp_4_hotspares()
654 (void) mirror_resync_unit(mnum, NULL, &mde, lockp); in check_comp_4_hotspares()
656 if (lockp) { in check_comp_4_hotspares()
657 new_un = md_ioctl_writerlock(lockp, MDI_UNIT(mnum)); in check_comp_4_hotspares()
1116 mirror_open_all_devs(minor_t mnum, int md_oflags, IOLOCK *lockp) in mirror_open_all_devs() argument
1155 if (lockp) { in mirror_open_all_devs()
1156 md_ioctl_readerexit(lockp); in mirror_open_all_devs()
1157 (void) md_ioctl_writerlock(lockp, ui); in mirror_open_all_devs()
[all …]
H A Dmirror_ioctl.c1987 mirror_allocate_hotspare(md_alloc_hotsp_params_t *p, IOLOCK *lockp) in mirror_allocate_hotspare() argument
1998 if ((un = mirror_getun(p->mnum, &p->mde, WR_LOCK, lockp)) == NULL) in mirror_allocate_hotspare()
2007 p->hs_id, lockp); in mirror_allocate_hotspare()
2008 md_ioctl_writerexit(lockp); in mirror_allocate_hotspare()
2048 mirror_set_state(md_set_state_params_t *p, IOLOCK *lockp) in mirror_set_state() argument
2062 if ((un = mirror_getun(p->mnum, &p->mde, WR_LOCK, lockp)) == NULL) in mirror_set_state()
2099 md_ioctl_writerexit(lockp); in mirror_set_state()
2153 md_ioctl_writerexit(lockp); in mirror_set_state()
2206 mirror_set_capability(md_mn_setcap_params_t *p, IOLOCK *lockp) in mirror_set_capability() argument
2216 if ((un = mirror_getun(p->mnum, &p->mde, RD_LOCK, lockp)) == NULL) in mirror_set_capability()
[all …]
/titanic_41/usr/src/uts/common/sys/
H A Dcallb.h134 #define CALLB_CPR_INIT(cp, lockp, func, name) { \ argument
136 (cp)->cc_lockp = lockp; \
174 #define CALLB_CPR_SAFE_END(cp, lockp) { \ argument
177 cv_wait(&(cp)->cc_stop_cv, lockp); \
/titanic_41/usr/src/uts/common/io/lvm/softpart/
H A Dsp_ioctl.c157 sp_setstatus(void *d, int mode, IOLOCK *lockp) in sp_setstatus() argument
194 (void) md_ioctl_writerlock(lockp, MDI_UNIT(minors[i])); in sp_setstatus()
197 md_ioctl_writerexit(lockp); in sp_setstatus()
741 sp_grow(void *d, int mode, IOLOCK *lockp) in sp_grow() argument
801 un = (mp_unit_t *)md_ioctl_writerlock(lockp, ui); in sp_grow()
914 IOLOCK *lockp in sp_getdevs() argument
939 un = (mp_unit_t *)md_ioctl_readerlock(lockp, ui); in sp_getdevs()
967 sp_set_capability(md_mn_setcap_params_t *p, IOLOCK *lockp) in sp_set_capability() argument
983 (void) md_ioctl_readerlock(lockp, ui); in sp_set_capability()
1009 md_ioctl_readerexit(lockp); in sp_set_capability()
[all …]
/titanic_41/usr/src/uts/common/io/ib/clients/rds/
H A Drdssubr.c210 kmutex_t *lockp; in rds_bind_hash_remove() local
221 lockp = &rds_bind_fanout[RDS_BIND_HASH(rds->rds_port)]. in rds_bind_hash_remove()
223 ASSERT(lockp != NULL); in rds_bind_hash_remove()
224 mutex_enter(lockp); in rds_bind_hash_remove()
240 mutex_exit(lockp); in rds_bind_hash_remove()
/titanic_41/usr/src/uts/common/avs/ns/solaris/
H A Dnsc_proc.c204 nsc_do_lock(int mode, void **lockp) in nsc_do_lock() argument
277 *lockp = NULL; in nsc_do_lock()
286 *lockp = nlwp; in nsc_do_lock()
/titanic_41/usr/src/uts/common/avs/ns/sdbc/
H A Dsd_bio.c568 hook->lockp = &_sd_buflist.hook_locks[((long)hook >> 9) & in sd_alloc_iob()
1075 mutex_enter(hook->lockp); in sd_start_io()
1078 cv_wait(&hook->wait, hook->lockp); in sd_start_io()
1080 mutex_exit(hook->lockp); in sd_start_io()
1116 mutex_enter(hook->lockp); in _sd_sync_ea()
1127 mutex_exit(hook->lockp); in _sd_sync_ea()
1164 mutex_enter(hook->lockp); in _sd_async_ea()
1170 mutex_exit(hook->lockp); in _sd_async_ea()
/titanic_41/usr/src/uts/common/io/lvm/trans/
H A Dtrans_ioctl.c1506 trans_admin_ioctl(int cmd, void *data, int mode, IOLOCK *lockp) in trans_admin_ioctl() argument
1534 err = trans_get(d, mode, lockp); in trans_admin_ioctl()
1553 err = trans_get_log(d, mode, lockp); in trans_admin_ioctl()
1572 err = trans_reset_ioctl(p, lockp); in trans_admin_ioctl()
1591 err = trans_grow(d, mode, lockp); in trans_admin_ioctl()
1610 err = trans_detach_ioctl(d, mode, lockp); in trans_admin_ioctl()
1649 err = trans_getdevs(d, mode, lockp); in trans_admin_ioctl()
1738 err = trans_test_trygetblk(d, mode, lockp); in trans_admin_ioctl()
1758 err = trans_test_trypage(d, mode, lockp); in trans_admin_ioctl()
1779 err = trans_inject_errors(d, mode, lockp); in trans_admin_ioctl()
[all …]
/titanic_41/usr/src/uts/common/disp/
H A Dfx.c101 kmutex_t *lockp = &fx_cb_list_lock[index]; \
103 mutex_enter(lockp); \
108 mutex_exit(lockp); \
117 kmutex_t *lockp = &fx_cb_list_lock[index]; \
118 mutex_enter(lockp); \
121 mutex_exit(lockp); \
1655 kmutex_t *lockp = &fx_cb_list_lock[index]; in fx_list_release() local
1656 mutex_exit(lockp); in fx_list_release()
1663 kmutex_t *lockp = &fx_cb_list_lock[index]; in fx_list_lookup() local
1666 mutex_enter(lockp); in fx_list_lookup()
[all …]
/titanic_41/usr/src/uts/common/inet/tcp/
H A Dtcp_bind.c158 kmutex_t *lockp; in tcp_bind_hash_remove() local
170 lockp = &tcps->tcps_bind_fanout[TCP_BIND_HASH( in tcp_bind_hash_remove()
173 ASSERT(lockp != NULL); in tcp_bind_hash_remove()
174 mutex_enter(lockp); in tcp_bind_hash_remove()
193 mutex_exit(lockp); in tcp_bind_hash_remove()
/titanic_41/usr/src/uts/common/io/lvm/stripe/
H A Dstripe_ioctl.c398 stripe_grow(void *d, int mode, IOLOCK *lockp) in stripe_grow() argument
466 un = (ms_unit_t *)md_ioctl_writerlock(lockp, ui); in stripe_grow()
899 stripe_admin_ioctl(int cmd, void *data, int mode, IOLOCK *lockp) in stripe_admin_ioctl() argument
943 err = stripe_get(d, mode, lockp); in stripe_admin_ioctl()
977 err = stripe_grow(d, mode, lockp); in stripe_admin_ioctl()
994 err = stripe_getdevs(d, mode, lockp); in stripe_admin_ioctl()
1011 err = stripe_change((md_stripe_params_t *)d, lockp); in stripe_admin_ioctl()
1064 md_stripe_ioctl(dev_t dev, int cmd, void *data, int mode, IOLOCK *lockp) in md_stripe_ioctl() argument
1072 return (stripe_admin_ioctl(cmd, data, mode, lockp)); in md_stripe_ioctl()
/titanic_41/usr/src/uts/common/io/lvm/md/
H A Dmd_subr.c933 md_ioctl_openclose_enter(IOLOCK *lockp, mdi_unit_t *ui) in md_ioctl_openclose_enter() argument
937 ASSERT(lockp != NULL); in md_ioctl_openclose_enter()
944 lockp->l_ui = ui; in md_ioctl_openclose_enter()
945 lockp->l_flags |= MD_READER_HELD; in md_ioctl_openclose_enter()
957 md_ioctl_openclose_exit(IOLOCK *lockp) in md_ioctl_openclose_exit() argument
961 ASSERT(lockp != NULL); in md_ioctl_openclose_exit()
962 ui = lockp->l_ui; in md_ioctl_openclose_exit()
965 md_ioctl_readerexit(lockp); in md_ioctl_openclose_exit()
981 md_ioctl_openclose_exit_lh(IOLOCK *lockp) in md_ioctl_openclose_exit_lh() argument
985 ASSERT(lockp != NULL); in md_ioctl_openclose_exit_lh()
[all …]
/titanic_41/usr/src/uts/common/io/lvm/notify/
H A Dmd_notify.c334 int mode, IOLOCK *lockp) in md_wait_for_event() argument
340 (void) IOLOCK_RETURN(0, lockp); in md_wait_for_event()
372 notify_ioctl(dev_t dev, int icmd, void *ioctl_in, int mode, IOLOCK *lockp) in notify_ioctl() argument
490 ioctl, sz, mode, lockp); in notify_ioctl()
/titanic_41/usr/src/cmd/fm/fmd/common/
H A Dfmd_rpc_adm.c724 pthread_rwlock_t *lockp; in fmd_adm_logrotate_1_svc() local
736 lockp = &fmd.d_log_lock; in fmd_adm_logrotate_1_svc()
739 lockp = &fmd.d_log_lock; in fmd_adm_logrotate_1_svc()
742 lockp = &fmd.d_ilog_lock; in fmd_adm_logrotate_1_svc()
745 lockp = &fmd.d_hvilog_lock; in fmd_adm_logrotate_1_svc()
766 (void) pthread_rwlock_wrlock(lockp); in fmd_adm_logrotate_1_svc()
774 (void) pthread_rwlock_unlock(lockp); in fmd_adm_logrotate_1_svc()
/titanic_41/usr/src/lib/libc/port/threads/
H A Dsynch.c1251 volatile uint8_t *lockp = (volatile uint8_t *)&mp->mutex_lockw; in mutex_trylock_adaptive() local
1276 if (set_lock_byte(lockp) == 0) { in mutex_trylock_adaptive()
1304 if (*lockp == 0 && set_lock_byte(lockp) == 0) { in mutex_trylock_adaptive()
1352 if (set_lock_byte(lockp) == 0) { in mutex_trylock_adaptive()
1403 volatile uint8_t *lockp; in mutex_queuelock_adaptive() local
1412 lockp = (volatile uint8_t *)&mp->mutex_lockw; in mutex_queuelock_adaptive()
1415 if (*lockp == 0 && set_lock_byte(lockp) == 0) in mutex_queuelock_adaptive()
1440 volatile uint64_t *lockp = (volatile uint64_t *)&mp->mutex_lockword64; in mutex_trylock_process() local
1482 if (set_lock_byte64(lockp, udp->pid) == 0) { in mutex_trylock_process()
1510 if ((*lockp & LOCKMASK64) == 0 && in mutex_trylock_process()
[all …]

123