2 Commits

Author SHA1 Message Date
4fef37ceca introduced Ping() function 2025-06-28 13:17:11 +02:00
0e44626c13 check instantly if mpv is ready 2025-06-28 13:10:43 +02:00

View File

@ -2,7 +2,6 @@ package mpvipc
import ( import (
"context" "context"
"net"
"time" "time"
) )
@ -30,21 +29,29 @@ func Quit(socket string) error {
return err return err
} }
func Ping(socket string) bool {
_, err := GetPID(socket)
return err == nil
}
func IsReady(ctx context.Context, socket string) <-chan bool { func IsReady(ctx context.Context, socket string) <-chan bool {
out := make(chan bool, 1) out := make(chan bool, 1)
go func() { go func() {
defer close(out) defer close(out)
if Ping(socket) {
out <- true
return
}
ticker := time.NewTicker(100 * time.Millisecond) ticker := time.NewTicker(100 * time.Millisecond)
defer ticker.Stop() defer ticker.Stop()
for { for {
select { select {
case <-ticker.C: case <-ticker.C:
conn, err := net.Dial("unix", socket) if Ping(socket) {
if err == nil {
defer conn.Close()
out <- true out <- true
return return
} }