|
|
|
@ -153,9 +153,10 @@ func (s *Server) handleConn(conn *core.Conn) error {
@@ -153,9 +153,10 @@ func (s *Server) handleConn(conn *core.Conn) error {
|
|
|
|
|
writer := s.getter.GetWriter(reader.Info()) |
|
|
|
|
s.handler.HandleWriter(writer) |
|
|
|
|
} |
|
|
|
|
//FIXME: should flv should be configurable, not always on -gs
|
|
|
|
|
flvWriter := new(flv.FlvDvr) |
|
|
|
|
s.handler.HandleWriter(flvWriter.GetWriter(reader.Info())) |
|
|
|
|
if configure.Config.GetBool("flv_archive") { |
|
|
|
|
flvWriter := new(flv.FlvDvr) |
|
|
|
|
s.handler.HandleWriter(flvWriter.GetWriter(reader.Info())) |
|
|
|
|
} |
|
|
|
|
} else { |
|
|
|
|
writer := NewVirWriter(connServer) |
|
|
|
|
log.Debugf("new player: %+v", writer.Info()) |
|
|
|
|