garionion/ffmpeg-playout
1
0
Fork 0
Code Issues Pull requests Projects Releases 3 Wiki Activity

set go module

Browse source
This commit is contained in:
garionion 2020-12-29 16:23:12 +01:00
parent 7b0cdac7c3
commit e57d4c191d
3 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
go.mod
View file

@ -1,4 +1,4 @@
module ffmpeg-playout module github.com/Garionion/ffmpeg-playout
go 1.15 go 1.15

6
main.go
View file

@ -2,9 +2,9 @@ package main
import ( import (
"errors" "errors"
"ffmpeg-playout/playout"
"ffmpeg-playout/store"
"fmt" "fmt"
"github.com/Garionion/ffmpeg-playout/playout"
"github.com/Garionion/ffmpeg-playout/store"
"github.com/gofiber/fiber/v2" "github.com/gofiber/fiber/v2"
"github.com/gofiber/fiber/v2/middleware/cors" "github.com/gofiber/fiber/v2/middleware/cors"
"github.com/ilyakaznacheev/cleanenv" "github.com/ilyakaznacheev/cleanenv"
@ -108,7 +108,7 @@ func schedulePlayout(s *store.Store) fiber.Handler {
for { for {
select { select {
case ctrlMsg := <-p.ControlChannel: case ctrlMsg := <-p.ControlChannel:
log.Println(ctrlMsg) log.Printf("%d Control Message: %s", p.ID, ctrlMsg)
continue continue
case <-time.After(time.Until(p.StartAt)): case <-time.After(time.Until(p.StartAt)):
break Waiting break Waiting

4
playout/playout.go
View file

@ -2,8 +2,8 @@ package playout
import ( import (
"bytes" "bytes"
"ffmpeg-playout/status"
"fmt" "fmt"
"github.com/Garionion/ffmpeg-playout/status"
"github.com/grafov/bcast" "github.com/grafov/bcast"
"log" "log"
"net/http" "net/http"
@ -137,7 +137,7 @@ func (p *Job) Playout(cfg *Config) {
case <-fChannelMember.Read: case <-fChannelMember.Read:
break ProcessManagement break ProcessManagement
case ctrlMsg := <-p.ControlChannel: case ctrlMsg := <-p.ControlChannel:
log.Println(ctrlMsg) log.Printf("%d Control Message: %s", p.ID, ctrlMsg)
break break
case <-time.After(time.Until(p.StopAt)): case <-time.After(time.Until(p.StopAt)):
break ProcessManagement break ProcessManagement