1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
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);
}
|
