MCPcopy Create free account
hub / github.com/Haivision/srt / TransmitGroupSocketConnect

Function TransmitGroupSocketConnect

testing/testmedia.cpp:921–963  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

919
920#if ENABLE_BONDING
921void 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
965SRT_GROUP_TYPE ResolveGroupType(const string& name)
966{

Callers

nothing calls this directly

Calls 2

srt_getrejectreasonFunction · 0.85
VerbFunction · 0.85

Tested by

no test coverage detected