Method API_replay_ts

http.go:300–327

(w http.ResponseWriter, r *http.Request)

}

func (conf *GlobalConfig) API_replay_ts(w http.ResponseWriter, r *http.Request) {
	q := r.URL.Query()
	streamPath := q.Get("streamPath")
	if streamPath == "" {
		streamPath = "dump/ts"
	}
	dumpFile := q.Get("dump")
	if dumpFile == "" {
		dumpFile = streamPath + ".ts"
	}
	f, err := os.Open(dumpFile)
	if err != nil {
		util.ReturnError(util.APIErrorOpen, err.Error(), w, r)
		return
	}
	var pub TSPublisher
	if err := Engine.Publish(streamPath, &pub); err != nil {
		util.ReturnError(util.APIErrorPublish, err.Error(), w, r)
	} else {
		tsReader := NewTSReader(&pub)
		pub.SetIO(f)
		go func() {
			tsReader.Feed(f)
			tsReader.Close()
		}()
		util.ReturnOK(w, r)
	}
}

func (conf *GlobalConfig) API_replay_mp4(w http.ResponseWriter, r *http.Request) {
	q := r.URL.Query()