diff --git a/src/input/input_tssrt.cpp b/src/input/input_tssrt.cpp index fc6c46a2..a63f840d 100644 --- a/src/input/input_tssrt.cpp +++ b/src/input/input_tssrt.cpp @@ -169,6 +169,7 @@ namespace Mist{ /// Live Setup of SRT Input. Runs only if we are the "main" thread bool InputTSSRT::preRun(){ + Socket::SRT::libraryInit(); rawMode = config->getBool("raw"); if (rawMode){INFO_MSG("Entering raw mode");} if (srtConn.getSocket() == -1){ @@ -301,6 +302,7 @@ namespace Mist{ HIGH_MSG("Spawned new thread for socket %i", S.getSocket()); } } + Socket::SRT::libraryCleanup(); return; } // If we are here: we have a proper connection (either accepted or pull input) and should start parsing it as such diff --git a/src/output/output_tssrt.cpp b/src/output/output_tssrt.cpp index e47ead9a..8f35ff7d 100644 --- a/src/output/output_tssrt.cpp +++ b/src/output/output_tssrt.cpp @@ -473,6 +473,7 @@ static void callThreadCallbackSRT(void *srtPtr){ } int main(int argc, char *argv[]){ + Socket::SRT::libraryInit(); DTSC::trackValidMask = TRACK_VALID_EXT_HUMAN; Util::redirectLogsIfNeeded(); Util::Config conf(argv[0]); @@ -563,5 +564,6 @@ int main(int argc, char *argv[]){ } } INFO_MSG("Exit reason: %s", Util::exitReason); + Socket::SRT::libraryCleanup(); return 0; }