(ConcurrentHashMap<String, Connector> links, String linkName, long roleId)
| 1277 | } |
| 1278 | |
| 1279 | private static @Nullable AsyncSocket getLinkSocket(ConcurrentHashMap<String, Connector> links, |
| 1280 | String linkName, long roleId) { |
| 1281 | var connector = links.get(linkName); |
| 1282 | if (connector == null) { |
| 1283 | logger.warn("getLinkSocket: not found connector for linkName={} roleId={}", linkName, roleId); |
| 1284 | return null; |
| 1285 | } |
| 1286 | if (!connector.isHandshakeDone()) { |
| 1287 | logger.warn("getLinkSocket: not isHandshakeDone for linkName={} roleId={}", linkName, roleId); |
| 1288 | return null; |
| 1289 | } |
| 1290 | var linkSocket = connector.getSocket(); |
| 1291 | if (linkSocket == null) { |
| 1292 | logger.warn("getLinkSocket: closed connector for linkName={} roleId={}", linkName, roleId); |
| 1293 | return null; |
| 1294 | } |
| 1295 | return linkSocket; |
| 1296 | } |
| 1297 | |
| 1298 | private void processErrorSids(LongList errorSids, LinkRoles group) { |
| 1299 | errorSids.foreach(linkSid -> Task.run(providerApp.zeze.newProcedure(() -> { |
no test coverage detected