1 /*
2  *  Copyright (c) 2012 The WebM project authors. All Rights Reserved.
3  *
4  *  Use of this source code is governed by a BSD-style license
5  *  that can be found in the LICENSE file in the root of the source
6  *  tree. An additional intellectual property rights grant can be found
7  *  in the file PATENTS.  All contributing project authors may
8  *  be found in the AUTHORS file in the root of the source tree.
9  */
10 
11 #include "./vpx_config.h"
12 #include "test/codec_factory.h"
13 #include "test/encode_test_driver.h"
14 #include "test/decode_test_driver.h"
15 #include "test/register_state_check.h"
16 #include "test/video_source.h"
17 #include "third_party/googletest/src/include/gtest/gtest.h"
18 
19 namespace libvpx_test {
EncodeFrame(VideoSource * video,const unsigned long frame_flags)20 void Encoder::EncodeFrame(VideoSource *video, const unsigned long frame_flags) {
21   if (video->img())
22     EncodeFrameInternal(*video, frame_flags);
23   else
24     Flush();
25 
26   // Handle twopass stats
27   CxDataIterator iter = GetCxData();
28 
29   while (const vpx_codec_cx_pkt_t *pkt = iter.Next()) {
30     if (pkt->kind != VPX_CODEC_STATS_PKT)
31       continue;
32 
33     stats_->Append(*pkt);
34   }
35 }
36 
EncodeFrameInternal(const VideoSource & video,const unsigned long frame_flags)37 void Encoder::EncodeFrameInternal(const VideoSource &video,
38                                   const unsigned long frame_flags) {
39   vpx_codec_err_t res;
40   const vpx_image_t *img = video.img();
41 
42   // Handle first frame initialization
43   if (!encoder_.priv) {
44     cfg_.g_w = img->d_w;
45     cfg_.g_h = img->d_h;
46     cfg_.g_timebase = video.timebase();
47     cfg_.rc_twopass_stats_in = stats_->buf();
48     res = vpx_codec_enc_init(&encoder_, CodecInterface(), &cfg_,
49                              init_flags_);
50     ASSERT_EQ(VPX_CODEC_OK, res) << EncoderError();
51   }
52 
53   // Handle frame resizing
54   if (cfg_.g_w != img->d_w || cfg_.g_h != img->d_h) {
55     cfg_.g_w = img->d_w;
56     cfg_.g_h = img->d_h;
57     res = vpx_codec_enc_config_set(&encoder_, &cfg_);
58     ASSERT_EQ(VPX_CODEC_OK, res) << EncoderError();
59   }
60 
61   // Encode the frame
62   REGISTER_STATE_CHECK(
63       res = vpx_codec_encode(&encoder_,
64                              video.img(), video.pts(), video.duration(),
65                              frame_flags, deadline_));
66   ASSERT_EQ(VPX_CODEC_OK, res) << EncoderError();
67 }
68 
Flush()69 void Encoder::Flush() {
70   const vpx_codec_err_t res = vpx_codec_encode(&encoder_, NULL, 0, 0, 0,
71                                                deadline_);
72   ASSERT_EQ(VPX_CODEC_OK, res) << EncoderError();
73 }
74 
InitializeConfig()75 void EncoderTest::InitializeConfig() {
76   const vpx_codec_err_t res = codec_->DefaultEncoderConfig(&cfg_, 0);
77   ASSERT_EQ(VPX_CODEC_OK, res);
78 }
79 
SetMode(TestMode mode)80 void EncoderTest::SetMode(TestMode mode) {
81   switch (mode) {
82     case kRealTime:
83       deadline_ = VPX_DL_REALTIME;
84       break;
85 
86     case kOnePassGood:
87     case kTwoPassGood:
88       deadline_ = VPX_DL_GOOD_QUALITY;
89       break;
90 
91     case kOnePassBest:
92     case kTwoPassBest:
93       deadline_ = VPX_DL_BEST_QUALITY;
94       break;
95 
96     default:
97       ASSERT_TRUE(false) << "Unexpected mode " << mode;
98   }
99 
100   if (mode == kTwoPassGood || mode == kTwoPassBest)
101     passes_ = 2;
102   else
103     passes_ = 1;
104 }
105 // The function should return "true" most of the time, therefore no early
106 // break-out is implemented within the match checking process.
compare_img(const vpx_image_t * img1,const vpx_image_t * img2)107 static bool compare_img(const vpx_image_t *img1,
108                         const vpx_image_t *img2) {
109   bool match = (img1->fmt == img2->fmt) &&
110                (img1->d_w == img2->d_w) &&
111                (img1->d_h == img2->d_h);
112 
113   const unsigned int width_y  = img1->d_w;
114   const unsigned int height_y = img1->d_h;
115   unsigned int i;
116   for (i = 0; i < height_y; ++i)
117     match = (memcmp(img1->planes[VPX_PLANE_Y] + i * img1->stride[VPX_PLANE_Y],
118                     img2->planes[VPX_PLANE_Y] + i * img2->stride[VPX_PLANE_Y],
119                     width_y) == 0) && match;
120   const unsigned int width_uv  = (img1->d_w + 1) >> 1;
121   const unsigned int height_uv = (img1->d_h + 1) >> 1;
122   for (i = 0; i <  height_uv; ++i)
123     match = (memcmp(img1->planes[VPX_PLANE_U] + i * img1->stride[VPX_PLANE_U],
124                     img2->planes[VPX_PLANE_U] + i * img2->stride[VPX_PLANE_U],
125                     width_uv) == 0) && match;
126   for (i = 0; i < height_uv; ++i)
127     match = (memcmp(img1->planes[VPX_PLANE_V] + i * img1->stride[VPX_PLANE_V],
128                     img2->planes[VPX_PLANE_V] + i * img2->stride[VPX_PLANE_V],
129                     width_uv) == 0) && match;
130   return match;
131 }
132 
MismatchHook(const vpx_image_t * img1,const vpx_image_t * img2)133 void EncoderTest::MismatchHook(const vpx_image_t *img1,
134                                const vpx_image_t *img2) {
135   ASSERT_TRUE(0) << "Encode/Decode mismatch found";
136 }
137 
RunLoop(VideoSource * video)138 void EncoderTest::RunLoop(VideoSource *video) {
139   vpx_codec_dec_cfg_t dec_cfg = {0};
140 
141   stats_.Reset();
142 
143   ASSERT_TRUE(passes_ == 1 || passes_ == 2);
144   for (unsigned int pass = 0; pass < passes_; pass++) {
145     last_pts_ = 0;
146 
147     if (passes_ == 1)
148       cfg_.g_pass = VPX_RC_ONE_PASS;
149     else if (pass == 0)
150       cfg_.g_pass = VPX_RC_FIRST_PASS;
151     else
152       cfg_.g_pass = VPX_RC_LAST_PASS;
153 
154     BeginPassHook(pass);
155     Encoder* const encoder = codec_->CreateEncoder(cfg_, deadline_, init_flags_,
156                                                    &stats_);
157     ASSERT_TRUE(encoder != NULL);
158     Decoder* const decoder = codec_->CreateDecoder(dec_cfg, 0);
159     bool again;
160     for (again = true, video->Begin(); again; video->Next()) {
161       again = (video->img() != NULL);
162 
163       PreEncodeFrameHook(video);
164       PreEncodeFrameHook(video, encoder);
165       encoder->EncodeFrame(video, frame_flags_);
166 
167       CxDataIterator iter = encoder->GetCxData();
168 
169       bool has_cxdata = false;
170       bool has_dxdata = false;
171       while (const vpx_codec_cx_pkt_t *pkt = iter.Next()) {
172         pkt = MutateEncoderOutputHook(pkt);
173         again = true;
174         switch (pkt->kind) {
175           case VPX_CODEC_CX_FRAME_PKT:
176             has_cxdata = true;
177             if (decoder && DoDecode()) {
178               vpx_codec_err_t res_dec = decoder->DecodeFrame(
179                   (const uint8_t*)pkt->data.frame.buf, pkt->data.frame.sz);
180               ASSERT_EQ(VPX_CODEC_OK, res_dec) << decoder->DecodeError();
181               has_dxdata = true;
182             }
183             ASSERT_GE(pkt->data.frame.pts, last_pts_);
184             last_pts_ = pkt->data.frame.pts;
185             FramePktHook(pkt);
186             break;
187 
188           case VPX_CODEC_PSNR_PKT:
189             PSNRPktHook(pkt);
190             break;
191 
192           default:
193             break;
194         }
195       }
196 
197       if (has_dxdata && has_cxdata) {
198         const vpx_image_t *img_enc = encoder->GetPreviewFrame();
199         DxDataIterator dec_iter = decoder->GetDxData();
200         const vpx_image_t *img_dec = dec_iter.Next();
201         if (img_enc && img_dec) {
202           const bool res = compare_img(img_enc, img_dec);
203           if (!res) {  // Mismatch
204             MismatchHook(img_enc, img_dec);
205           }
206         }
207         if (img_dec)
208           DecompressedFrameHook(*img_dec, video->pts());
209       }
210       if (!Continue())
211         break;
212     }
213 
214     EndPassHook();
215 
216     if (decoder)
217       delete decoder;
218     delete encoder;
219 
220     if (!Continue())
221       break;
222   }
223 }
224 
225 }  // namespace libvpx_test
226