mirror
/
av
mirror of https://bitbucket.org/ausocean/av.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

revid: added some commentary

This commit is contained in:
Saxon 2019-03-29 13:29:31 +10:30
parent 3896a5e804
commit 648b43c50a
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
revid/senders.go
View File

@ -113,8 +113,13 @@ func (s *minimalHttpSender) send(d []byte) error {
// When a loadSender has finished using the *ring.Chunk // When a loadSender has finished using the *ring.Chunk
// it must be Closed. // it must be Closed.
type loadSender interface { type loadSender interface {
// load assigns the *ring.Chunk to the loadSender.
// The load call may fail, but must not mutate the
// the chunk.
load(d []byte) error load(d []byte) error
// send performs a destination-specific send
// operation. It must not mutate the chunk.
send() error send() error
// release releases the *ring.Chunk. // release releases the *ring.Chunk.
@ -136,6 +141,7 @@ type fileSender struct {
data []byte data []byte
} }
// Write implements io.Writer. This will attempt to load and send the data given.
func (s *fileSender) Write(d []byte) (int, error) { func (s *fileSender) Write(d []byte) (int, error) {
err := s.load(d) err := s.load(d)
if err != nil { if err != nil {
@ -185,6 +191,7 @@ type mtsSender struct {
curPid int curPid int
} }
// Write implements io.Writer. This will attempt to load and send the data given.
func (s *mtsSender) Write(d []byte) (int, error) { func (s *mtsSender) Write(d []byte) (int, error) {
return write(s, d) return write(s, d)
} }
@ -372,6 +379,7 @@ func newRtmpSender(url string, timeout uint, retries int, log func(lvl int8, msg
return s, err return s, err
} }
// Write implements io.Writer. This will attempt to load and send the data given.
func (s *rtmpSender) Write(d []byte) (int, error) { func (s *rtmpSender) Write(d []byte) (int, error) {
return write(s, d) return write(s, d)
} }
@ -425,6 +433,7 @@ type rtpSender struct {
data []byte data []byte
} }
// Write implements io.Writer. This will attempt to load and send the data given.
func (s *rtpSender) Write(d []byte) (int, error) { func (s *rtpSender) Write(d []byte) (int, error) {
return write(s, d) return write(s, d)
} }
@ -456,6 +465,7 @@ func (s *rtpSender) send() error {
return err return err
} }
// write wraps the load and send method for loadSenders.
func write(s loadSender, d []byte) (int, error) { func write(s loadSender, d []byte) (int, error) {
err := s.load(d) err := s.load(d)
if err != nil { if err != nil {