kunmeng/vdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix rtmp handshake flashphoner

Browse Source
This commit is contained in:
deepch
2023-03-13 19:26:29 +03:00
parent cc3f215a23
commit c923e0010b
1 changed files with 5 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
format/rtmp/rtmp.go
View File

@@ -1623,20 +1623,15 @@ func (self *Conn) handshakeServer() (err error) {
clitime := pio.U32BE(C1[0:4]) clitime := pio.U32BE(C1[0:4])
srvtime := clitime srvtime := clitime
srvver := uint32(0x0d0e0a0d) srvver := uint32(0x0d0e0a0d)
cliver := pio.U32BE(C1[4:8])
if cliver != 0 { var ok bool
var ok bool var digest []byte
var digest []byte if ok, digest = hsParse1(C1, hsClientPartialKey, hsServerFullKey); ok {
if ok, digest = hsParse1(C1, hsClientPartialKey, hsServerFullKey); !ok {
err = fmt.Errorf("rtmp: handshake server: C1 invalid")
return
}
hsCreate01(S0S1, srvtime, srvver, hsServerPartialKey) hsCreate01(S0S1, srvtime, srvver, hsServerPartialKey)
hsCreate2(S2, digest) hsCreate2(S2, digest)
} else { } else {
copy(S1, C1) copy(S1, C2)
copy(S2, C2) copy(S2, C1)
} }
if _, err = self.bufw.Write(S0S1S2); err != nil { if _, err = self.bufw.Write(S0S1S2); err != nil {