Revision 7323
Added by ben leinfelder over 12 years ago
src/edu/ucsb/nceas/metacat/dataone/hazelcast/HazelcastService.java | ||
---|---|---|
212 | 212 |
|
213 | 213 |
// Get a reference to the shared identifiers set as a cluster member |
214 | 214 |
// NOTE: this takes a long time to complete |
215 |
logMetacat.warn("Retrieving hzIdentifiers from Hazelcast"); |
|
215 | 216 |
identifiers = Hazelcast.getSet(identifiersSet); |
216 |
logMetacat.debug("got identifiersSet");
|
|
217 |
logMetacat.warn("Retrieved hzIdentifiers from Hazelcast");
|
|
217 | 218 |
|
218 |
identifiers.addAll(loadAllKeys()); |
|
219 |
logMetacat.debug("Initialized identifiers"); |
|
219 |
// add any identifiers not already present |
|
220 |
Set<Identifier> idKeys = loadAllKeys(); |
|
221 |
//identifiers.addAll(idKeys); |
|
222 |
logMetacat.warn("Loading local keys into hzIdentifiers"); |
|
223 |
for (Identifier key: idKeys) { |
|
224 |
if (!identifiers.contains(key)) { |
|
225 |
logMetacat.debug("Adding missing hzIdentifiers key: " + key.getValue()); |
|
226 |
identifiers.add(key); |
|
227 |
} |
|
228 |
} |
|
229 |
logMetacat.warn("Initialized identifiers with local keys"); |
|
220 | 230 |
|
221 | 231 |
// Listen for changes to the system metadata map |
222 | 232 |
systemMetadata.addEntryListener(this, true); |
Also available in: Unified diff
only load local pids into hzIdentifiers if t hey do not already exist in the shared set. increase logging severity and detail of messages emitted during this process to get a better sense of what is taking so long.