(ConcurrentHashMap<String, Connector> links, String linkName, String account, String clientId)
| 841 | } |
| 842 | |
| 843 | private static AsyncSocket getLinkSocket(ConcurrentHashMap<String, Connector> links, String linkName, |
| 844 | String account, String clientId) { |
| 845 | var connector = links.get(linkName); |
| 846 | if (connector == null) { |
| 847 | logger.warn("sendDirect: not found connector for linkName={} clientId={} account={}", |
| 848 | linkName, account, clientId); |
| 849 | return null; |
| 850 | } |
| 851 | if (!connector.isHandshakeDone()) { |
| 852 | logger.warn("sendDirect: not isHandshakeDone for linkName={} clientId={} account={}", |
| 853 | linkName, account, clientId); |
| 854 | return null; |
| 855 | } |
| 856 | var linkSocket = connector.getSocket(); |
| 857 | if (linkSocket == null) { |
| 858 | logger.warn("sendDirect: closed connector for linkName={} clientId={} account={}", |
| 859 | linkName, account, clientId); |
| 860 | return null; |
| 861 | } |
| 862 | return linkSocket; |
| 863 | } |
| 864 | |
| 865 | private void processErrorSids(LongList errorSids, LinkRoles group) { |
| 866 | errorSids.foreach(linkSid -> Task.run(providerApp.zeze.newProcedure(() -> { |
no test coverage detected