5 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
195b00abf2 fixed dependencies 2025-06-25 23:23:31 +02:00
cb478e8b4d Update go.mod 2024-12-16 19:47:28 +01:00
0e93c0cafb added GetDemuxerCacheTime 2024-02-22 19:48:21 +01:00
6 changed files with 29 additions and 11 deletions

View File

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

8
go.mod
View File

@ -1,5 +1,7 @@
module git.milar.in/milarin/mpvipc
module git.tordarus.net/tordarus/mpvipc
go 1.21.5
go 1.23
require git.milar.in/milarin/channel v0.1.1
toolchain go1.24.4
require git.tordarus.net/tordarus/channel v0.1.19

4
go.sum
View File

@ -1,2 +1,2 @@
git.milar.in/milarin/channel v0.1.1 h1:s8+BdiOMmuRUDmChQ2i4G5GWsDCK9tKNHt1knLJx9zM=
git.milar.in/milarin/channel v0.1.1/go.mod h1:We83LTI8S7u7II3pD+A2ChCDWJfCkcBUCUqii9HjTtM=
git.tordarus.net/tordarus/channel v0.1.19 h1:d9xnSwFyvBh4B1/82mt0A7Gpm2nIZJTc+9ceJMIOu5Q=
git.tordarus.net/tordarus/channel v0.1.19/go.mod h1:8/dWFTdGO7g4AeSZ7cF6GerkGbe9c4dBVMVDBxOd9m4=

View File

@ -58,6 +58,15 @@ func GetDuration(socket string) (time.Duration, error) {
return time.Duration(durationInSeconds * float64(time.Second)), nil
}
func GetDemuxerCacheTime(socket string) (time.Duration, error) {
cacheInSeconds, err := GetProperty[float64](socket, "demuxer-cache-time")
if err != nil {
return 0, err
}
return time.Duration(cacheInSeconds * float64(time.Second)), nil
}
func GetPercentPos(socket string) (float64, error) {
return GetProperty[float64](socket, "percent-pos")
}

View File

@ -4,7 +4,7 @@ import (
"context"
"time"
"git.milar.in/milarin/channel"
"git.tordarus.net/tordarus/channel"
)
func ObserveEndOfFile(ctx context.Context, socket string) (<-chan string, error) {

View File

@ -6,7 +6,7 @@ import (
"errors"
"net"
"git.milar.in/milarin/channel"
"git.tordarus.net/tordarus/channel"
)
type Command struct {