|
|
@ -134,6 +134,8 @@ func (s *Server) handleConn(conn *core.Conn) error { |
|
|
|
writer := s.getter.GetWriter(reader.Info()) |
|
|
|
writer := s.getter.GetWriter(reader.Info()) |
|
|
|
s.handler.HandleWriter(writer) |
|
|
|
s.handler.HandleWriter(writer) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
flvWriter:=new(flv.FlvDvr) |
|
|
|
|
|
|
|
s.handler.HandleWriter(flvWriter.GetWriter(reader.Info())) |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
writer := NewVirWriter(connServer) |
|
|
|
writer := NewVirWriter(connServer) |
|
|
|
log.Printf("new player: %+v", writer.Info()) |
|
|
|
log.Printf("new player: %+v", writer.Info()) |
|
|
|