honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-08 22:14:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

MockTransportService.doClose assertions should check openConnections under lock

Browse Source
This commit is contained in:
Boaz Leskes 2017-01-10 13:59:28 +01:00
parent 5f9dfe3186
commit f387848f83
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
test/framework/src/main/java/org/elasticsearch/test/transport/MockTransportService.java
View File

@ -64,7 +64,6 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Queue; import java.util.Queue;
import java.util.Set; import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.LinkedBlockingDeque; import java.util.concurrent.LinkedBlockingDeque;
@ -743,6 +742,8 @@ public final class MockTransportService extends TransportService {
@Override @Override
protected void doClose() { protected void doClose() {
super.doClose(); super.doClose();
synchronized (openConnections) {
assert openConnections.size() == 0 : "still open connections: " + openConnections; assert openConnections.size() == 0 : "still open connections: " + openConnections;
} }
} }
}