thefoxon/joy4
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rtmp: split connect from connectPlay

Browse Source
This commit is contained in:
nareix 2016-07-02 06:23:13 +08:00
parent 0b9155a9cf
commit bde39ebc16
1 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
format/rtmp/rtmp.go
View File

@ -578,20 +578,18 @@ func (self *Conn) probe() (err error) {
return
}
func (self *Conn) connectPlay() (err error) {
connectpath, playpath := splitPath(self.Path)
func (self *Conn) connect(path string) (err error) {
// > connect("app")
if self.Debug {
fmt.Printf("rtmp: > connect('%s') host=%s\n", connectpath, self.Host)
fmt.Printf("rtmp: > connect('%s') host=%s\n", path, self.Host)
}
w := self.writeCommandMsgStart()
flvio.WriteAMF0Val(w, "connect")
flvio.WriteAMF0Val(w, 1)
flvio.WriteAMF0Val(w, flvio.AMFMap{
"app": connectpath,
"app": path,
"flashVer": "MAC 22,0,0,192",
"tcUrl": fmt.Sprintf("rtmp://%s/%s", self.Host, connectpath),
"tcUrl": fmt.Sprintf("rtmp://%s/%s", self.Host, path),
"fpad": false,
"capabilities": 15,
"audioCodecs": 4071,
@ -629,11 +627,21 @@ func (self *Conn) connectPlay() (err error) {
}
}
return
}
func (self *Conn) connectPlay() (err error) {
connectpath, playpath := splitPath(self.Path)
if err = self.connect(connectpath); err != nil {
return
}
// > createStream()
if self.Debug {
fmt.Printf("rtmp: > createStream()\n")
}
w = self.writeCommandMsgStart()
w := self.writeCommandMsgStart()
flvio.WriteAMF0Val(w, "createStream")
flvio.WriteAMF0Val(w, 2)
flvio.WriteAMF0Val(w, nil)