Lines Matching defs:lockp
1100 struct __db_lock *lockp;
1112 lockp = R_ADDR(<->reginfo, lock->off);
1113 if (lock->gen != lockp->gen) {
1121 lockp, lock->ndx, flags | DB_LOCK_UNLINK | DB_LOCK_FREE);
1153 struct __db_lock *lockp;
1171 lockp = R_ADDR(<->reginfo, lock->off);
1172 if (lock->gen != lockp->gen) {
1178 sh_locker = R_ADDR(<->reginfo, lockp->holder);
1180 if (IS_WRITELOCK(lockp->mode) && !IS_WRITELOCK(new_mode))
1183 lockp->mode = new_mode;
1187 obj = (DB_LOCKOBJ *)((u_int8_t *)lockp + lockp->obj);
1202 __lock_put_internal(lt, lockp, obj_ndx, flags)
1204 struct __db_lock *lockp;
1218 if (!OBJ_LINKS_VALID(lockp)) {
1225 (void)__lock_freelock(lt, lockp, NULL, DB_LOCK_FREE);
1231 lt->obj_stat[obj_ndx].st_nreleases += lockp->refcount;
1236 if (!LF_ISSET(DB_LOCK_DOALL) && lockp->refcount > 1) {
1237 lockp->refcount--;
1242 lockp->gen++;
1245 sh_obj = (DB_LOCKOBJ *)((u_int8_t *)lockp + lockp->obj);
1253 if (lockp->status != DB_LSTAT_HELD &&
1254 lockp->status != DB_LSTAT_PENDING) {
1256 lt, sh_obj, lockp, DB_LSTAT_ABORTED)) != 0)
1259 SH_TAILQ_REMOVE(&sh_obj->holders, lockp, links, __db_lock);
1260 lockp->links.stqe_prev = -1;
1294 ret = __lock_freelock(lt, lockp,
1295 R_ADDR(<->reginfo, lockp->holder), flags);
1314 __lock_freelock(lt, lockp, sh_locker, flags)
1316 struct __db_lock *lockp;
1330 SH_LIST_REMOVE(lockp, locker_links, __db_lock);
1331 if (lockp->status == DB_LSTAT_HELD) {
1333 if (IS_WRITELOCK(lockp->mode))
1344 part_id = LOCK_PART(region, lockp->indx);
1345 if (lockp->mtx_lock != MUTEX_INVALID &&
1346 lockp->status != DB_LSTAT_HELD &&
1347 lockp->status != DB_LSTAT_EXPIRED &&
1348 (ret = __mutex_free(env, &lockp->mtx_lock)) != 0)
1350 lockp->status = DB_LSTAT_FREE;
1352 lockp, links, __db_lock);
1354 STAT(lt->obj_stat[lockp->indx].st_nlocks--);
1790 __lock_remove_waiter(lt, sh_obj, lockp, status)
1793 struct __db_lock *lockp;
1801 do_wakeup = lockp->status == DB_LSTAT_WAITING;
1803 SH_TAILQ_REMOVE(&sh_obj->waiters, lockp, links, __db_lock);
1804 lockp->links.stqe_prev = -1;
1805 lockp->status = status;
1819 MUTEX_UNLOCK(lt->env, lockp->mtx_lock);