mykola/mptv
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

handle SocketClosedException, so we could atleast notice that our socket got shutdown. TODO: fix possible recursion at line 232

Browse source
This commit is contained in:
mykola2312 2024-04-29 10:54:04 +03:00
parent acdad8acb0
commit 5d5c47d259
1 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/main/java/com/mykola2312/mptv/mpv/MPV.java
View file

@ -12,6 +12,7 @@ import org.newsclub.net.unix.AFInputStream;
import org.newsclub.net.unix.AFOutputStream; import org.newsclub.net.unix.AFOutputStream;
import org.newsclub.net.unix.AFUNIXSocket; import org.newsclub.net.unix.AFUNIXSocket;
import org.newsclub.net.unix.AFUNIXSocketAddress; import org.newsclub.net.unix.AFUNIXSocketAddress;
import org.newsclub.net.unix.SocketClosedException;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -221,6 +222,17 @@ public class MPV implements TaskProcess {
return commandResult; return commandResult;
} catch (JsonProcessingException e) { } catch (JsonProcessingException e) {
throw new RuntimeException("failed to serialize command", e); throw new RuntimeException("failed to serialize command", e);
} catch (SocketClosedException e) {
logger.warn("socket's closed. lets try re-open ipc connection and request again");
// so, for some reason socket got closed. we're gonna re-open it
// (hopefully) and try executing command again
try {
waitForConnection(MPV_SOCKET_PATH);
return executeCommand(command);
} catch (MPVSocketFailure e1) {
throw new MPVCommandTimeout();
}
} catch (IOException e) { } catch (IOException e) {
throw new RuntimeException("io exception", e); throw new RuntimeException("io exception", e);
} }