1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.eclipse.aether.internal.impl.synccontext.named;
20
21 import java.util.ArrayDeque;
22 import java.util.ArrayList;
23 import java.util.Collection;
24 import java.util.Deque;
25 import java.util.concurrent.TimeUnit;
26
27 import org.eclipse.aether.ConfigurationProperties;
28 import org.eclipse.aether.RepositorySystemSession;
29 import org.eclipse.aether.SyncContext;
30 import org.eclipse.aether.artifact.Artifact;
31 import org.eclipse.aether.metadata.Metadata;
32 import org.eclipse.aether.named.NamedLock;
33 import org.eclipse.aether.named.NamedLockFactory;
34 import org.eclipse.aether.named.providers.FileLockNamedLockFactory;
35 import org.eclipse.aether.util.ConfigUtils;
36 import org.slf4j.Logger;
37 import org.slf4j.LoggerFactory;
38
39 import static java.util.Objects.requireNonNull;
40
41
42
43
44 public final class NamedLockFactoryAdapter {
45 public static final String CONFIG_PROPS_PREFIX = ConfigurationProperties.PREFIX_SYNC_CONTEXT + "named.";
46
47
48
49
50
51
52
53
54
55 public static final String CONFIG_PROP_TIME = CONFIG_PROPS_PREFIX + "time";
56
57 public static final long DEFAULT_TIME = 30L;
58
59
60
61
62
63
64
65
66
67 public static final String CONFIG_PROP_TIME_UNIT = CONFIG_PROPS_PREFIX + "time.unit";
68
69 public static final String DEFAULT_TIME_UNIT = "SECONDS";
70
71
72
73
74
75
76
77
78
79 public static final String CONFIG_PROP_RETRY = CONFIG_PROPS_PREFIX + "retry";
80
81 public static final int DEFAULT_RETRY = 1;
82
83
84
85
86
87
88
89
90
91 public static final String CONFIG_PROP_RETRY_WAIT = CONFIG_PROPS_PREFIX + "retry.wait";
92
93 public static final long DEFAULT_RETRY_WAIT = 200L;
94
95 private final NameMapper nameMapper;
96
97 private final NamedLockFactory namedLockFactory;
98
99 public NamedLockFactoryAdapter(final NameMapper nameMapper, final NamedLockFactory namedLockFactory) {
100 this.nameMapper = requireNonNull(nameMapper);
101 this.namedLockFactory = requireNonNull(namedLockFactory);
102
103 if (this.namedLockFactory instanceof FileLockNamedLockFactory && !this.nameMapper.isFileSystemFriendly()) {
104 throw new IllegalArgumentException(
105 "Misconfiguration: FileLockNamedLockFactory lock factory requires FS friendly NameMapper");
106 }
107 }
108
109 public SyncContext newInstance(final RepositorySystemSession session, final boolean shared) {
110 return new AdaptedLockSyncContext(session, shared, nameMapper, namedLockFactory);
111 }
112
113
114
115
116 public NameMapper getNameMapper() {
117 return nameMapper;
118 }
119
120
121
122
123 public NamedLockFactory getNamedLockFactory() {
124 return namedLockFactory;
125 }
126
127 public String toString() {
128 return getClass().getSimpleName()
129 + "(nameMapper=" + nameMapper
130 + ", namedLockFactory=" + namedLockFactory
131 + ")";
132 }
133
134 private static class AdaptedLockSyncContext implements SyncContext {
135 private static final Logger LOGGER = LoggerFactory.getLogger(AdaptedLockSyncContext.class);
136
137 private final RepositorySystemSession session;
138
139 private final boolean shared;
140
141 private final NameMapper lockNaming;
142
143 private final NamedLockFactory namedLockFactory;
144
145 private final long time;
146
147 private final TimeUnit timeUnit;
148
149 private final int retry;
150
151 private final long retryWait;
152
153 private final Deque<NamedLock> locks;
154
155 private AdaptedLockSyncContext(
156 final RepositorySystemSession session,
157 final boolean shared,
158 final NameMapper lockNaming,
159 final NamedLockFactory namedLockFactory) {
160 this.session = session;
161 this.shared = shared;
162 this.lockNaming = lockNaming;
163 this.namedLockFactory = namedLockFactory;
164 this.time = getTime(session);
165 this.timeUnit = getTimeUnit(session);
166 this.retry = getRetry(session);
167 this.retryWait = getRetryWait(session);
168 this.locks = new ArrayDeque<>();
169
170 if (time < 0L) {
171 throw new IllegalArgumentException(CONFIG_PROP_TIME + " value cannot be negative");
172 }
173 if (retry < 0L) {
174 throw new IllegalArgumentException(CONFIG_PROP_RETRY + " value cannot be negative");
175 }
176 if (retryWait < 0L) {
177 throw new IllegalArgumentException(CONFIG_PROP_RETRY_WAIT + " value cannot be negative");
178 }
179 }
180
181 private long getTime(final RepositorySystemSession session) {
182 return ConfigUtils.getLong(session, DEFAULT_TIME, CONFIG_PROP_TIME);
183 }
184
185 private TimeUnit getTimeUnit(final RepositorySystemSession session) {
186 return TimeUnit.valueOf(ConfigUtils.getString(session, DEFAULT_TIME_UNIT, CONFIG_PROP_TIME_UNIT));
187 }
188
189 private int getRetry(final RepositorySystemSession session) {
190 return ConfigUtils.getInteger(session, DEFAULT_RETRY, CONFIG_PROP_RETRY);
191 }
192
193 private long getRetryWait(final RepositorySystemSession session) {
194 return ConfigUtils.getLong(session, DEFAULT_RETRY_WAIT, CONFIG_PROP_RETRY_WAIT);
195 }
196
197 @Override
198 public void acquire(Collection<? extends Artifact> artifacts, Collection<? extends Metadata> metadatas) {
199 Collection<String> keys = lockNaming.nameLocks(session, artifacts, metadatas);
200 if (keys.isEmpty()) {
201 return;
202 }
203
204 final int attempts = retry + 1;
205 final ArrayList<IllegalStateException> illegalStateExceptions = new ArrayList<>();
206 for (int attempt = 1; attempt <= attempts; attempt++) {
207 LOGGER.trace(
208 "Attempt {}: Need {} {} lock(s) for {}", attempt, keys.size(), shared ? "read" : "write", keys);
209 int acquiredLockCount = 0;
210 try {
211 if (attempt > 1) {
212 Thread.sleep(retryWait);
213 }
214 for (String key : keys) {
215 NamedLock namedLock = namedLockFactory.getLock(key);
216 LOGGER.trace("Acquiring {} lock for '{}'", shared ? "read" : "write", key);
217
218 boolean locked;
219 if (shared) {
220 locked = namedLock.lockShared(time, timeUnit);
221 } else {
222 locked = namedLock.lockExclusively(time, timeUnit);
223 }
224
225 if (!locked) {
226 String timeStr = time + " " + timeUnit;
227 LOGGER.trace(
228 "Failed to acquire {} lock for '{}' in {}",
229 shared ? "read" : "write",
230 key,
231 timeStr);
232
233 namedLock.close();
234 closeAll();
235 illegalStateExceptions.add(new IllegalStateException(
236 "Attempt " + attempt + ": Could not acquire " + (shared ? "read" : "write")
237 + " lock for '" + namedLock.name() + "' in " + timeStr));
238 break;
239 } else {
240 locks.push(namedLock);
241 acquiredLockCount++;
242 }
243 }
244 } catch (InterruptedException e) {
245 Thread.currentThread().interrupt();
246 throw new RuntimeException(e);
247 }
248 LOGGER.trace("Attempt {}: Total locks acquired: {}", attempt, acquiredLockCount);
249 if (acquiredLockCount == keys.size()) {
250 break;
251 }
252 }
253 if (!illegalStateExceptions.isEmpty()) {
254 IllegalStateException ex = new IllegalStateException("Could not acquire lock(s)");
255 illegalStateExceptions.forEach(ex::addSuppressed);
256 throw namedLockFactory.onFailure(ex);
257 }
258 }
259
260 private void closeAll() {
261 if (locks.isEmpty()) {
262 return;
263 }
264
265
266 int released = 0;
267 while (!locks.isEmpty()) {
268 try (NamedLock namedLock = locks.pop()) {
269 LOGGER.trace("Releasing {} lock for '{}'", shared ? "read" : "write", namedLock.name());
270 namedLock.unlock();
271 released++;
272 }
273 }
274 LOGGER.trace("Total locks released: {}", released);
275 }
276
277 @Override
278 public void close() {
279 closeAll();
280 }
281 }
282 }