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
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
/*
* ============LICENSE_START=======================================================
* api-resource-locks
* ================================================================================
* Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*/
package org.onap.policy.drools.core.lock;
import org.onap.policy.drools.utils.OrderedService;
import org.onap.policy.drools.utils.OrderedServiceImpl;
/**
* Resource locks. Each lock has an "owner", which is intended to be unique across a
* single instance of a running PolicyEngine.
* <p>
* This interface provides a way to invoke optional features at various points in the
* code. At appropriate points in the application, the code iterates through this list,
* invoking these optional methods.
* <p>
* Implementers may choose to implement a level of locking appropriate to the application.
* For instance, they may choose to implement an engine-wide locking scheme, or they may
* choose to implement a global locking scheme (e.g., through a shared DB).
*/
public interface PolicyResourceLockFeatureAPI extends OrderedService {
/**
* 'FeatureAPI.impl.getList()' returns an ordered list of objects implementing the
* 'FeatureAPI' interface.
*/
public static OrderedServiceImpl<PolicyResourceLockFeatureAPI> impl =
new OrderedServiceImpl<>(PolicyResourceLockFeatureAPI.class);
/**
*
* Result of a requested operation.
*/
public enum OperResult {
/**
* The implementer accepted the request; no additional locking logic should be
* performed.
*/
OPER_ACCEPTED,
/**
* The implementer denied the request; no additional locking logic should be
* performed.
*/
OPER_DENIED,
/**
* The implementer did not handle the request; additional locking logic <i>should
* be<i> performed.
*/
OPER_UNHANDLED
}
/**
* This method is called before a lock is acquired on a resource.
*
* @param resourceId
* @param owner
* @param holdSec the amount of time, in seconds, that the lock should be held
* @return the result, where <b>OPER_DENIED</b> indicates that the lock is currently
* held by another owner
*/
public default OperResult beforeLock(String resourceId, String owner, int holdSec) {
return OperResult.OPER_UNHANDLED;
}
/**
* This method is called after a lock for a resource has been acquired or denied.
*
* @param resourceId
* @param owner
* @param locked {@code true} if the lock was acquired, {@code false} if it was denied
* @return {@code true} if the implementer handled the request, {@code false}
* otherwise
*/
public default boolean afterLock(String resourceId, String owner, boolean locked) {
return false;
}
/**
* This method is called before a lock is refreshed on a resource. It may be invoked
* repeatedly to extend the time that a lock is held.
*
* @param resourceId
* @param owner
* @param holdSec the amount of time, in seconds, that the lock should be held
* @return the result, where <b>OPER_DENIED</b> indicates that the resource is not
* currently locked by the given owner
*/
public default OperResult beforeRefresh(String resourceId, String owner, int holdSec) {
return OperResult.OPER_UNHANDLED;
}
/**
* This method is called after a lock for a resource has been refreshed (or after the
* refresh has been denied).
*
* @param resourceId
* @param owner
* @param locked {@code true} if the lock was acquired, {@code false} if it was denied
* @return {@code true} if the implementer handled the request, {@code false}
* otherwise
*/
public default boolean afterRefresh(String resourceId, String owner, boolean locked) {
return false;
}
/**
* This method is called before a lock on a resource is released.
*
* @param resourceId
* @param owner
* @return the result, where <b>OPER_DENIED</b> indicates that the lock is not
* currently held by the given owner
*/
public default OperResult beforeUnlock(String resourceId, String owner) {
return OperResult.OPER_UNHANDLED;
}
/**
* This method is called after a lock on a resource is released.
*
* @param resourceId
* @param owner
* @param unlocked {@code true} if the lock was released, {@code false} if the owner
* did not have a lock on the resource
* @return {@code true} if the implementer handled the request, {@code false}
* otherwise
*/
public default boolean afterUnlock(String resourceId, String owner, boolean unlocked) {
return false;
}
/**
* This method is called before a check is made to determine if a resource is locked.
*
* @param resourceId
* @return the result, where <b>OPER_ACCEPTED</b> indicates that the resource is
* locked, while <b>OPER_DENIED</b> indicates that it is not
*/
public default OperResult beforeIsLocked(String resourceId) {
return OperResult.OPER_UNHANDLED;
}
/**
* This method is called before a check is made to determine if a particular owner
* holds the lock on a resource.
*
* @param resourceId
* @param owner
* @return the result, where <b>OPER_ACCEPTED</b> indicates that the resource is
* locked by the given owner, while <b>OPER_DENIED</b> indicates that it is
* not
*/
public default OperResult beforeIsLockedBy(String resourceId, String owner) {
return OperResult.OPER_UNHANDLED;
}
}
|
