mirror of
https://github.com/livepeer/lpms
synced 2026-04-23 00:07:25 +08:00
fix examples
This commit is contained in:
+6
-1
@@ -9,6 +9,7 @@ import (
|
||||
"fmt"
|
||||
"math/rand"
|
||||
"net/url"
|
||||
"os"
|
||||
"regexp"
|
||||
"strings"
|
||||
"time"
|
||||
@@ -57,7 +58,11 @@ func main() {
|
||||
flag.Set("logtostderr", "true")
|
||||
flag.Parse()
|
||||
|
||||
lpms := core.New("1935", "8000", "", "")
|
||||
dir, err := os.Getwd()
|
||||
if err != nil {
|
||||
glog.Infof("Error getting work directory: %v", err)
|
||||
}
|
||||
lpms := core.New("1935", "8000", "", "", fmt.Sprintf("%v/.tmp", dir))
|
||||
|
||||
//Streams needed for transcoding:
|
||||
var rtmpStrm stream.RTMPVideoStream
|
||||
|
||||
@@ -3,8 +3,10 @@ package main
|
||||
import (
|
||||
"context"
|
||||
"flag"
|
||||
"fmt"
|
||||
"io"
|
||||
"net/url"
|
||||
"os"
|
||||
"strings"
|
||||
|
||||
"time"
|
||||
@@ -250,7 +252,11 @@ func main() {
|
||||
flag.Set("logtostderr", "true")
|
||||
flag.Parse()
|
||||
|
||||
lpms := core.New("1935", "8000", "", "")
|
||||
dir, err := os.Getwd()
|
||||
if err != nil {
|
||||
glog.Infof("Error getting work directory: %v", err)
|
||||
}
|
||||
lpms := core.New("1935", "8000", "", "", fmt.Sprintf("%v/.tmp", dir))
|
||||
|
||||
lpms.HandleRTMPPublish(
|
||||
//makeStreamID
|
||||
|
||||
Reference in New Issue
Block a user