| | |
| | | ,record_(false) |
| | | ,fps_(0.0f) |
| | | ,format_name_("mp4") |
| | | ,in_v_stream_(NULL) |
| | | ,in_a_stream_(NULL) |
| | | {} |
| | | |
| | | FormatOut::~FormatOut() |
| | |
| | | return true; |
| | | } |
| | | |
| | | bool FormatOut::copyCodecFromIn(AVFormatContext* in){ |
| | | |
| | | for(int i = 0; i < in->nb_streams; i++) |
| | | { //根据输入流创建输出流 |
| | | AVStream *in_stream = in->streams[i]; |
| | | AVStream *out_stream = avformat_new_stream(ctx_, in_stream->codec->codec); |
| | | if(!out_stream) |
| | | { |
| | | logIt("Failed allocating output stream.\n"); |
| | | return false; |
| | | } |
| | | |
| | | //将输出流的编码信息复制到输入流 |
| | | auto ret = avcodec_copy_context(out_stream->codec, in_stream->codec); |
| | | if(ret<0) |
| | | { |
| | | logIt("Failed to copy context from input to output stream codec context\n"); |
| | | return false; |
| | | } |
| | | |
| | | if (in_stream->codecpar->codec_type == AVMEDIA_TYPE_VIDEO){ |
| | | v_idx_ = i; |
| | | }else{ |
| | | a_idx_ = i; |
| | | } |
| | | |
| | | out_stream->codecpar->codec_tag = out_stream->codec->codec_tag = 0; |
| | | |
| | | if(ctx_->oformat->flags & AVFMT_GLOBALHEADER) |
| | | out_stream->codec->flags |= AV_CODEC_FLAG_GLOBAL_HEADER; |
| | | |
| | | bool FormatOut::addStream(AVStream *s){ |
| | | AVStream *in_stream = s; |
| | | |
| | | AVStream *out_stream = avformat_new_stream(ctx_, in_stream->codec->codec); |
| | | if(!out_stream) |
| | | { |
| | | logIt("Failed allocating output stream.\n"); |
| | | return false; |
| | | } |
| | | |
| | | in_ctx_ = in; |
| | | |
| | | //将输出流的编码信息复制到输入流 |
| | | auto ret = avcodec_copy_context(out_stream->codec, in_stream->codec); |
| | | if(ret<0) |
| | | { |
| | | logIt("Failed to copy context from input to output stream codec context\n"); |
| | | return false; |
| | | } |
| | | out_stream->codecpar->codec_tag = out_stream->codec->codec_tag = 0; |
| | | |
| | | if(ctx_->oformat->flags & AVFMT_GLOBALHEADER) |
| | | out_stream->codec->flags |= AV_CODEC_FLAG_GLOBAL_HEADER; |
| | | |
| | | return true; |
| | | } |
| | | |
| | | bool FormatOut::JustWriter(AVFormatContext *in, const char *filename){ |
| | | bool FormatOut::copyCodecFromIn(AVStream *v, AVStream *a){ |
| | | if (v){ |
| | | v_idx_ = 0; |
| | | in_v_stream_ = v; |
| | | |
| | | if (!addStream(v)){ |
| | | logIt("format out add video stream error"); |
| | | return false; |
| | | }else{ |
| | | logIt("copy video from instream"); |
| | | } |
| | | } |
| | | if (a){ |
| | | a_idx_ = 1; |
| | | in_a_stream_ = a; |
| | | if (!addStream(a)){ |
| | | logIt("format out add audio stream error"); |
| | | return false; |
| | | }else{ |
| | | logIt("copy audio from instream"); |
| | | } |
| | | } |
| | | return true; |
| | | } |
| | | |
| | | bool FormatOut::JustWriter(AVStream *v, AVStream *a, const char *filename){ |
| | | if(ctx_){ |
| | | clear(); |
| | | } |
| | | |
| | | bool flag = open(NULL, format_name_.c_str()); |
| | | |
| | | flag = copyCodecFromIn(in) && flag; |
| | | flag = copyCodecFromIn(v, a) && flag; |
| | | if(!flag){ |
| | | logIt("FormatOut JustWriter error from in"); |
| | | return false; |
| | |
| | | av_dict_set(&avdic,option_key,option_value,0); |
| | | flag = writeHeader(&avdic); |
| | | av_dict_free(&avdic); |
| | | |
| | | } |
| | | |
| | | return flag; |
| | |
| | | return; |
| | | } |
| | | |
| | | if (pkt->pts == AV_NOPTS_VALUE && pkt->pts == AV_NOPTS_VALUE){ |
| | | if (!in_a_stream_){ |
| | | int64_t time_stamp = frame_cnt; |
| | | |
| | | pkt->pos = -1; |
| | |
| | | } |
| | | |
| | | AVStream *in_stream,*out_stream; |
| | | int out_idx = -1; |
| | | std::vector<AVStream*> in_streams{in_v_stream_, in_a_stream_}; |
| | | for (auto i : in_streams){ |
| | | if (i->index == pkt->stream_index){ |
| | | if (i->codecpar->codec_type == AVMEDIA_TYPE_VIDEO){ |
| | | out_idx = v_idx_; |
| | | in_stream = i; |
| | | break; |
| | | }else if (i->codecpar->codec_type == AVMEDIA_TYPE_AUDIO){ |
| | | in_stream = i; |
| | | out_idx = a_idx_; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (out_idx == -1) return; |
| | | |
| | | out_stream = ctx_->streams[out_idx]; |
| | | pkt->stream_index = out_idx; |
| | | |
| | | in_stream = in_ctx_->streams[pkt->stream_index]; |
| | | out_stream = ctx_->streams[pkt->stream_index]; |
| | | |
| | | // logIt("BEFORE in stream timebase %d:%d, out timebase %d:%d, \ |
| | | // logIt("BEFORE in stream timebase %d:%d, out timebase %d:%d, |
| | | // pts: %lld, dts: %lld, duration: %lld", |
| | | // in_stream->time_base.num, in_stream->time_base.den, |
| | | // out_stream->time_base.num, out_stream->time_base.den, |