| 919 | |
| 920 | #if ENABLE_BONDING |
| 921 | void TransmitGroupSocketConnect(void* srtcommon, SRTSOCKET sock, int error, const sockaddr* /*peer*/, int token) |
| 922 | { |
| 923 | SrtCommon* that = (SrtCommon*)srtcommon; |
| 924 | |
| 925 | if (error == SRT_SUCCESS) |
| 926 | { |
| 927 | return; // nothing to do for a successful socket |
| 928 | } |
| 929 | |
| 930 | #ifdef PLEASE_LOG |
| 931 | applog.Debug("connect callback: error on @", sock, " erc=", error, " token=", token); |
| 932 | #endif |
| 933 | |
| 934 | /* Example: identify by target address |
| 935 | sockaddr_any peersa = peer; |
| 936 | sockaddr_any agentsa; |
| 937 | bool haveso = (srt_getsockname(sock, agentsa.get(), &agentsa.len) != -1); |
| 938 | */ |
| 939 | |
| 940 | for (auto& n: that->m_group_nodes) |
| 941 | { |
| 942 | if (n.token != -1 && n.token == token) |
| 943 | { |
| 944 | n.error = error; |
| 945 | n.reason = srt_getrejectreason(sock); |
| 946 | return; |
| 947 | } |
| 948 | |
| 949 | /* |
| 950 | |
| 951 | bool isso = haveso && !n.source.empty(); |
| 952 | if (n.target == peersa && (!isso || n.source.equal_address(agentsa))) |
| 953 | { |
| 954 | Verb() << " (by target)" << VerbNoEOL; |
| 955 | n.error = error; |
| 956 | n.reason = srt_getrejectreason(sock); |
| 957 | return; |
| 958 | } |
| 959 | */ |
| 960 | } |
| 961 | |
| 962 | Verb() << " IPE: LINK NOT FOUND???]"; |
| 963 | } |
| 964 | |
| 965 | SRT_GROUP_TYPE ResolveGroupType(const string& name) |
| 966 | { |
nothing calls this directly
no test coverage detected