diff options
Diffstat (limited to 'src/lock/lock_timer.c')
| -rw-r--r-- | src/lock/lock_timer.c | 128 |
1 files changed, 128 insertions, 0 deletions
diff --git a/src/lock/lock_timer.c b/src/lock/lock_timer.c new file mode 100644 index 00000000..943047f0 --- /dev/null +++ b/src/lock/lock_timer.c @@ -0,0 +1,128 @@ +/*- + * See the file LICENSE for redistribution information. + * + * Copyright (c) 1996, 2012 Oracle and/or its affiliates. All rights reserved. + * + * $Id$ + */ + +#include "db_config.h" + +#include "db_int.h" +#include "dbinc/lock.h" + +/* + * __lock_set_timeout -- + * Set timeout values in shared memory. + * + * This is called from the transaction system. We either set the time that + * this transaction expires or the amount of time a lock for this transaction + * is permitted to wait. + * + * PUBLIC: int __lock_set_timeout __P((ENV *, + * PUBLIC: DB_LOCKER *, db_timeout_t, u_int32_t)); + */ +int +__lock_set_timeout(env, locker, timeout, op) + ENV *env; + DB_LOCKER *locker; + db_timeout_t timeout; + u_int32_t op; +{ + int ret; + + if (locker == NULL) + return (0); + LOCK_REGION_LOCK(env); + ret = __lock_set_timeout_internal(env, locker, timeout, op); + LOCK_REGION_UNLOCK(env); + return (ret); +} + +/* + * __lock_set_timeout_internal + * -- set timeout values in shared memory. + * + * This is the internal version called from the lock system. We either set + * the time that this transaction expires or the amount of time that a lock + * for this transaction is permitted to wait. + * + * PUBLIC: int __lock_set_timeout_internal + * PUBLIC: __P((ENV *, DB_LOCKER *, db_timeout_t, u_int32_t)); + */ +int +__lock_set_timeout_internal(env, sh_locker, timeout, op) + ENV *env; + DB_LOCKER *sh_locker; + db_timeout_t timeout; + u_int32_t op; +{ + DB_LOCKREGION *region; + region = env->lk_handle->reginfo.primary; + + if (op == DB_SET_TXN_TIMEOUT) { + if (timeout == 0) + timespecclear(&sh_locker->tx_expire); + else + __clock_set_expires(env, + &sh_locker->tx_expire, timeout); + } else if (op == DB_SET_LOCK_TIMEOUT) { + sh_locker->lk_timeout = timeout; + F_SET(sh_locker, DB_LOCKER_TIMEOUT); + } else if (op == DB_SET_TXN_NOW) { + timespecclear(&sh_locker->tx_expire); + __clock_set_expires(env, &sh_locker->tx_expire, 0); + sh_locker->lk_expire = sh_locker->tx_expire; + if (!timespecisset(®ion->next_timeout) || + timespeccmp( + ®ion->next_timeout, &sh_locker->lk_expire, >)) + region->next_timeout = sh_locker->lk_expire; + } else + return (EINVAL); + + return (0); +} + +/* + * __lock_inherit_timeout + * -- inherit timeout values from parent locker. + * This is called from the transaction system. This will + * return EINVAL if the parent does not exist or did not + * have a current txn timeout set. + * + * PUBLIC: int __lock_inherit_timeout __P((ENV *, DB_LOCKER *, DB_LOCKER *)); + */ +int +__lock_inherit_timeout(env, parent, locker) + ENV *env; + DB_LOCKER *parent, *locker; +{ + int ret; + + ret = 0; + LOCK_REGION_LOCK(env); + + /* + * If the parent is not there yet, that's ok. If it + * does not have any timouts set, then avoid creating + * the child locker at this point. + */ + if (parent == NULL || + (timespecisset(&parent->tx_expire) && + !F_ISSET(parent, DB_LOCKER_TIMEOUT))) { + ret = EINVAL; + goto err; + } + + locker->tx_expire = parent->tx_expire; + + if (F_ISSET(parent, DB_LOCKER_TIMEOUT)) { + locker->lk_timeout = parent->lk_timeout; + F_SET(locker, DB_LOCKER_TIMEOUT); + if (!timespecisset(&parent->tx_expire)) + ret = EINVAL; + } + +err: LOCK_REGION_UNLOCK(env); + return (ret); +} |