@@ -187,7 +187,7 @@ private void prepareCollectionFlushes(PersistenceContext persistenceContext) thr
187
187
LOG .debug ( "Dirty checking collections" );
188
188
189
189
for ( Map .Entry <PersistentCollection ,CollectionEntry > entry :
190
- IdentityMap .entriesIterable ( (Map <PersistentCollection ,CollectionEntry >) persistenceContext .getCollectionEntries () )) {
190
+ IdentityMap .concurrentEntries ( (Map <PersistentCollection ,CollectionEntry >) persistenceContext .getCollectionEntries () )) {
191
191
entry .getValue ().preFlush ( entry .getKey () );
192
192
}
193
193
}
@@ -246,7 +246,7 @@ private void flushCollections(final EventSource session, final PersistenceContex
246
246
LOG .trace ( "Processing unreferenced collections" );
247
247
248
248
for ( Map .Entry <PersistentCollection ,CollectionEntry > me :
249
- IdentityMap .entriesIterable ( (Map <PersistentCollection ,CollectionEntry >) persistenceContext .getCollectionEntries () )) {
249
+ IdentityMap .concurrentEntries ( (Map <PersistentCollection ,CollectionEntry >) persistenceContext .getCollectionEntries () )) {
250
250
CollectionEntry ce = me .getValue ();
251
251
if ( !ce .isReached () && !ce .isIgnore () ) {
252
252
Collections .processUnreachableCollection ( me .getKey (), session );
@@ -259,7 +259,7 @@ private void flushCollections(final EventSource session, final PersistenceContex
259
259
260
260
ActionQueue actionQueue = session .getActionQueue ();
261
261
for ( Map .Entry <PersistentCollection ,CollectionEntry > me :
262
- IdentityMap .entriesIterable ( (Map <PersistentCollection ,CollectionEntry >) persistenceContext .getCollectionEntries () )) {
262
+ IdentityMap .concurrentEntries ( (Map <PersistentCollection ,CollectionEntry >) persistenceContext .getCollectionEntries () )) {
263
263
PersistentCollection coll = me .getKey ();
264
264
CollectionEntry ce = me .getValue ();
265
265
0 commit comments